您好,登錄后才能下訂單哦!
在Rabbit基礎的API中,聲明一個exchange、聲明一個綁定、聲明一個隊列都是通過channel創建出來的。如下圖:
那么在spring AMQP中這些對象是怎么聲明的?
在使用springAMQP去聲明,就需要使用springAMQP的如下模式。即使用@Bean模式:
下面我們就進行代碼演示:
在上一篇代碼中修改RabbitMQConfig類。添加如下:
/**
*?針對消費者配置
* 1.?設置交換機類型
* 2.?將隊列綁定到交換機
FanoutExchange:?將消息分發到所有的綁定隊列,無routingkey的概念
HeadersExchange?:通過添加屬性key-value匹配
DirectExchange:按照routingkey分發到指定隊列
TopicExchange:多關鍵字匹配
*/
說明:
我們需要根據不同的交換機特性進行設置。
如topic的:
啟動測試代碼,查看隊列:
查看交換機:
查看綁定關系:
以topic001這個交換機為例:
綁定了兩個隊列。隊列1和隊列3.routingkey分別為:spring.*和mq.*.到底對不對呢?
我們查看代碼:
可以看到代碼中確實是這么綁定的。說明,我們聲明隊列、綁定、交換機成功。
本文由凱哥Java(凱哥Java)發布于51CTO。凱哥公眾號:凱哥Java(kaigejava)。個人博客:www.kaigejava.com
本節總結:
通過bean注解獲取exchange、binding、queue對象。
本文是《rabbitMq精講系列》教程中的:rabbitMQ精講系列第十九篇?高級整合應用第二篇?Spring AMQP聲明。系列教程,建議從第一篇看起。
下節預告:
下節課,我們將講解一個重要對象rabbitTemplate對象。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。