小编给大家分享一下Spring Boot如何整合RabbitMQ,希望大家阅读完这篇文章之后都有所收获,下面让我们一起去探讨吧!
交换器就像路由器,我们先是把消息发到交换器,然后交换器再根据绑定键(binding key)和生产者发送消息时的路由键routingKey,
按照交换类型Exchange Type(fanout,direct,topic)把消息投递到对应的队列。
存放消息的队列。
交换器怎么知道把这条消息投递到哪个队列呢?这就需要用到绑定了。大概就是:使用某个绑定键(binding key),把某个队列(Queue)绑定到某个交换器(Exchange),这样交换器就知道根据路由键把这条消息投递到哪个队列了。
application.yaml文件中配置
@Configurationpublic class RabbitMQConfig { public final static String QUEUE_NAME = "spring-boot-queue"; public final static String EXCHANGE_NAME = "spring-boot-exchange"; public final static String BINDING_KEY = "spring.boot.key.#";// 创建队列 @Bean public Queue queue() { return new Queue(QUEUE_NAME); }// 创建一个 topic 类型的交换器 @Bean public TopicExchange exchange() { return new TopicExchange(EXCHANGE_NAME); }// 使用路由键(routingKey)把队列(Queue)绑定到交换器(Exchange) @Bean public Binding binding(Queue queue, TopicExchange exchange) { return BindingBuilder.bind(queue).to(exchange).with(BINDING_KEY); }}
注:上面配置的是TopicExchange
实际业务中,可以配置多个队列和binding来满足需求。
直接调用 rabbitTemplate 的 convertAndSend 方法就可以了。从下面的代码里也可以看出,我们不是把消息直接发送到队列里面的,而是先发送到了交换器,交换器再根据路由键把我们的消息投递到对应的队列。
消费者也很简单,只需要对应的方法上加入 @RabbitListener 注解,指定需要监听的队列名称即可。
运行项目,然后打开浏览器,输入 http://localhost:9999/sendMessage (具体地址根据服务器)。在控制台就可以看到生产者在不停的的发送消息,消费者不断的在消费消息。
看完了这篇文章,相信你对“Spring Boot如何整合RabbitMQ”有了一定的了解,如果想了解更多相关知识,欢迎关注亿速云行业资讯频道,感谢各位的阅读!
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。
原文链接:https://my.oschina.net/u/2335629/blog/4642080