中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

rabbitMQ系列高級整合應用Spring AMQP

發布時間:2020-04-09 17:43:13 來源:網絡 閱讀:350 作者:凱哥Java 欄目:軟件技術

在Rabbit基礎的API中,聲明一個exchange、聲明一個綁定、聲明一個隊列都是通過channel創建出來的。如下圖:

rabbitMQ系列高級整合應用Spring AMQP

那么在spring AMQP中這些對象是怎么聲明的?

在使用springAMQP去聲明,就需要使用springAMQP的如下模式。即使用@Bean模式:

rabbitMQ系列高級整合應用Spring AMQP

下面我們就進行代碼演示:

在上一篇代碼中修改RabbitMQConfig類。添加如下:

/**
*?針對消費者配置
* 1.?設置交換機類型
* 2.?將隊列綁定到交換機
FanoutExchange:?將消息分發到所有的綁定隊列,無routingkey的概念
HeadersExchange?:通過添加屬性key-value匹配
DirectExchange:按照routingkey分發到指定隊列
TopicExchange:多關鍵字匹配
*/

說明:

我們需要根據不同的交換機特性進行設置。

topic的:

rabbitMQ系列高級整合應用Spring AMQP

啟動測試代碼,查看隊列:

rabbitMQ系列高級整合應用Spring AMQP

查看交換機:
rabbitMQ系列高級整合應用Spring AMQP

查看綁定關系:

topic001這個交換機為例:

rabbitMQ系列高級整合應用Spring AMQP

綁定了兩個隊列。隊列1和隊列3.routingkey分別為:spring.*mq.*.到底對不對呢?

我們查看代碼:
rabbitMQ系列高級整合應用Spring AMQP

可以看到代碼中確實是這么綁定的。說明,我們聲明隊列、綁定、交換機成功。

本文由凱哥Java(凱哥Java)發布于51CTO。凱哥公眾號:凱哥Java(kaigejava)。個人博客:www.kaigejava.com

本節總結:

通過bean注解獲取exchangebindingqueue對象。

本文是《rabbitMq精講系列》教程中的:rabbitMQ精講系列第十九篇?高級整合應用第二篇?Spring AMQP聲明。系列教程,建議從第一篇看起

下節預告:

下節課,我們將講解一個重要對象rabbitTemplate對象



向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

莲花县| 贞丰县| 塘沽区| 许昌县| 绥滨县| 肃南| 察雅县| 攀枝花市| 泉州市| 平武县| 柳林县| 平阴县| 丰宁| 页游| 保定市| 扎兰屯市| 绩溪县| 恩施市| 济源市| 资中县| 北流市| 晴隆县| 彭泽县| 潜山县| 绥滨县| 丰宁| 鄯善县| 蒙自县| 汝阳县| 兴化市| 静宁县| 中江县| 普陀区| 昭觉县| 阿拉善左旗| 宣威市| 松江区| 自治县| 平阴县| 永寿县| 台中县|