小編給大家分享一下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進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
