小编给大家分享一下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.#";// 创建队列@Beanpublic Queue queue() {return new Queue(QUEUE_NAME);}// 创建一个 topic 类型的交换器@Beanpublic TopicExchange exchange() {return new TopicExchange(EXCHANGE_NAME);}// 使用路由键（routingKey）把队列（Queue）绑定到交换器（Exchange）@Beanpublic 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”有了一定的了解，如果想了解更多相关知识，欢迎关注亿速云行业资讯频道，感谢各位的阅读！
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
