用户工具

站点工具


spring:rabbitmq

差别

这里会显示出您选择的修订版和当前版本之间的差别。

到此差别页面的链接

spring:rabbitmq [2018/08/10 11:17]
guest 创建
spring:rabbitmq [2018/08/10 11:20] (当前版本)
guest
行 16: 行 16:
     }     }
     @Bean     @Bean
-    TopicExchange exchange() {+    TopicExchange exchange() { //​RabbitTemplate发送消息到exchange,然后可发送到多个queue,类似topic概念
         return new TopicExchange(topicExchangeName);//​String topicExchangeName = "​spring-boot-exchange";​         return new TopicExchange(topicExchangeName);//​String topicExchangeName = "​spring-boot-exchange";​
     }     }
     @Bean     @Bean
     Binding binding(Queue queue, TopicExchange exchange) {     Binding binding(Queue queue, TopicExchange exchange) {
-        return BindingBuilder.bind(queue).to(exchange).with("​foo.bar.#"​);​+        return BindingBuilder.bind(queue).to(exchange).with("​foo.bar.#"​); ​//​路由绑定foo.bar.#​
     }     }
     //​消息监听容器     //​消息监听容器
行 39: 行 39:
     }     }
 </​code>​ </​code>​
 +
 +发送消息
 +
 +  rabbitTemplate.convertAndSend(topicExchangeName,​ "​foo.bar.baz",​ "Hello from RabbitMQ!"​);​
 +
 +
 +
 +
  
  
spring/rabbitmq.txt · 最后更改: 2018/08/10 11:20 由 guest