溫馨提示×

溫馨提示×

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

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

rabbitMQ系列高級整合應用Spring AMQP

發(fā)布時間:2020-04-09 17:43:13 來源:網(wǎng)絡 閱讀:349 作者:凱哥Java 欄目:軟件技術

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

rabbitMQ系列高級整合應用Spring AMQP

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

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

rabbitMQ系列高級整合應用Spring AMQP

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

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

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

說明:

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

topic的:

rabbitMQ系列高級整合應用Spring AMQP

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

rabbitMQ系列高級整合應用Spring AMQP

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

查看綁定關系:

topic001這個交換機為例:

rabbitMQ系列高級整合應用Spring AMQP

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

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

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

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

本節(jié)總結:

通過bean注解獲取exchange、binding、queue對象。

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

下節(jié)預告:

下節(jié)課,我們將講解一個重要對象rabbitTemplate對象。



向AI問一下細節(jié)

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

AI