Spring消息之AMQP.

来源:https://www.cnblogs.com/jmcui/archive/2018/04/28/8968315.html
-Advertisement-
Play Games

一、AMQP 概述 AMQP(Advanced Message Queuing Protocol)，高級消息隊列協議。 簡單回憶一下JMS的消息模型，可能會有助於理解AMQP的消息模型。在JMS中，有三個主要的參與者：消息的生產者、消息的消費者以及在生產者和消費者之間傳遞消息的通道（隊列或主題）。在 ...


一、AMQP 概述

    AMQP(Advanced Message Queuing Protocol)，高級消息隊列協議。

    簡單回憶一下JMS的消息模型，可能會有助於理解AMQP的消息模型。在JMS中，有三個主要的參與者：消息的生產者、消息的消費者以及在生產者和消費者之間傳遞消息的通道（隊列或主題）。在JMS中，通道有助於解耦消息的生產者和消費者，但是這兩者依然會與通道相耦合。與之不同的是，AMQP的生產者並不會直接將消息發佈到隊列中。AMQP在消息的生產者以及傳遞信息的隊列之間引入了一種間接的機制：Exchange。如下圖：

    

    哈哈，筆主從今天開始也要學著自己畫圖了。

    來看看 AMQP 消息的通信過程。首先，生產者把消息發給 Exchange，並帶有一個 routing key。其次，Exchange 和 隊列 之間 通過 binging 通信，binging 上也有 一個 routing key，AMQP定義了四種不同類型的Exchange，每一種都有不同的路由演算法，根據Exchange的演算法不同，它可能會使用消息的routing key或參數，並與 binding 的routing key或參數進行對比，來決定是否要將信息放到隊列中。然後，消費者從每個隊列中取出消息。

    Exchange 的路由演算法：

  • Direct：如果 消息的routing key 與 binding的routing key 直接匹配的話，消息將會路由到該隊列上；
  • Topic：如果 消息的routing key 與 binding的routing key 符合通配符匹配的話，消息將會路由到該隊列上；
  • Headers：如果 消息參數表中的頭信息和值 都與 bingding參數表中 相匹配，消息將會路由到該隊列上；
  • Fanout：不管消息的routing key和參數表的頭信息/值是什麼，消息將會路由到所有隊列上。

    AMQP 與 JMS 的區別：

1、AMQP為消息定義了線路層（wire-level protocol）的協議，而JMS所定義的是API規範。JMS的API協議能夠確保所有的實現都能通過通用的API來使用，但是並不能保證某個JMS實現所發送的消息能夠被另外不同的JMS實現所使用。而AMQP的線路層協議規範了消息的格式，消息在生產者和消費者間傳送的時候會遵循這個格式。這樣AMQP在互相協作方面就要優於JMS——它不僅能跨不同的AMQP實現，還能跨語言和平臺。

2、JMS 支持TextMessage、MapMessage 等複雜的消息類型；而AMQP 僅支持 byte[] 消息類型（複雜的類型可序列化後發送），個人認為這也是它能夠跨平臺和跨語言使用的原因之一。

3、由於Exchange 提供的路由演算法，AMQP可以提供多樣化的路由方式來傳遞消息到消息隊列，而 JMS 僅支持 隊列 和 主題/訂閱 方式兩種。 

二、Spring 集成 RabbitMQ

    RabbitMQ是一個流行的開源消息代理，它實現了AMQP。Spring AMQP為RabbitMQ提供了支持，包括RabbitMQ連接工廠、模板以及Spring配置命名空間。

    首先，需要安裝 RabbitMQ，我們可以在 http://www.rabbitmq.com/download.html 上找到安裝指南，具體怎麼安裝，不是這篇博文的重點，請筆友們自行解決。

    接下來，讓我們一起來看看，Spring 和 RabbitMQ 的集成：

1、pom 依賴

    <dependency>
      <groupId>org.springframework.amqp</groupId>
      <artifactId>spring-rabbit</artifactId>
      <version>2.0.3.RELEASE</version>
    </dependency>

2、連接工廠 和 admin

    <rabbit:connection-factory id="connectionFactory"
                               host="${rabbitmq.host}"
                               port="${rabbitmq.port}"
                               username="${rabbitmq.userName}"
                               password="${rabbitmq.password}"/>
    
    <rabbit:admin connection-factory="connectionFactory"/>
View Code

admin 元素會自動創建一個RabbitMQ管理組件，它會自動創建隊列、Exchange以及binding

3、聲明隊列、Exchange以及binding

聲明隊列：

    <rabbit:queue name="queue1"/>
    <rabbit:queue name="queue2"/>
    <rabbit:queue name="queue3"/>
    <rabbit:queue name="queue4"/>
    <rabbit:queue name="queue5"/>
    <rabbit:queue name="queue6"/>
View Code

聲明 Exchange 以及 binding：

direct-exchange:

    <rabbit:direct-exchange name="directExchange">
        <rabbit:bindings>
            <rabbit:binding key="queue1" queue="queue1"/>
            <rabbit:binding key="queue2" queue="queue2"/>
            <rabbit:binding key="queue3" queue="queue3"/>
        </rabbit:bindings>
    </rabbit:direct-exchange>
View Code

        如果消息的routing key 與 routing key 直接匹配的話，消息將會路由到該隊列上。

topic-exchange

    <rabbit:topic-exchange name="topicExchange">
        <rabbit:bindings>
            <rabbit:binding pattern="routing.*" queue="queue2"/>
            <rabbit:binding pattern="routing.*" queue="queue3"/>
        </rabbit:bindings>
    </rabbit:topic-exchange>
View Code

消息的 routing key 與 binding的routing key 符合通配符匹配的話，消息將會路由到該隊列上。

這個通配符匹配特別坑，賊坑！我本來寫了個 "routing*" ，自以為能匹配 "routingrrr" 這樣的字元，不行！然後我又寫了個"routing?"、"rounting."，預想著能不能匹配單個任意字元，不行！

終於我得出了一個結論，只能使用 "*"（匹配 0 個或任意多個）通配符，並且，並且！"*" 前面一定要有 個 "."  ! 太可怕了，不知道我總結的對不對哈！

headers-exchange

    <rabbit:headers-exchange name="headersExchange">
        <rabbit:bindings>
            <rabbit:binding queue="queue4" key="betty" value="rubble"   />
            <rabbit:binding queue="queue5" key="barney" value="rubble"   />
        </rabbit:bindings>
    </rabbit:headers-exchange>
View Code

消息參數表中的頭信息和值都與bingding參數表中相匹配，消息將會路由到該隊列上。

這個用法比較少用，也比較難用，原因是因為它僅支持 發送 byte[] 的消息類型。

fanout-exchange

    <rabbit:fanout-exchange name="fanoutExchange">
        <rabbit:bindings>
            <rabbit:binding queue="queue5"/>
            <rabbit:binding queue="queue6"/>
        </rabbit:bindings>
    </rabbit:fanout-exchange>
View Code

這個是最簡單粗暴的匹配規則，不管消息的routing key和參數表的頭信息/值是什麼，消息將會路由到所有隊列上。

 4、發送和接收消息

    還是Spring的那一套，Spring 為我們提供了一個模板 bean（rabbitTemplate） 來發送和接收消息。其中，像前文提到的 jmsTemplate 那樣，rabbitTemplate 也為我們 提供了 convertAndSend() 方法來自動轉換和發送消息，提供了receiveAndConvret() 方法來接收和自動轉換成對象（消息和對象之間預設的消息轉換器是SimpleMessageConverter，它適用於String、Serializable實例以及位元組數組）。另外，rabbitTemplate 也照常提供了 send() 和 receive() 方法來發送和接收消息，不過貌似僅支持發送位元組數組...

配置 rabbitTemplate：

    <rabbit:template id="rabbitTemplate"
                     connection-factory="connectionFactory"
                     exchange="directExchange"
                     routing-key="queue1"/>
View Code

   

    下麵僅演示 通配符路由方式 和 header 路由方式 發送和接收消息。其他具體詳細的內容可參考我下麵附上的源碼：

通配符路由方式：

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext.xml")
public class TopicExchange {

    @Autowired
    private RabbitTemplate rabbitTemplate;


    @Test
    public void convertAndSend(){
        List<String> list = new ArrayList<>();
        list.add("java");
        list.add("python");
        list.add("c++");
        rabbitTemplate.convertAndSend("topicExchange","routing.123", list);
    }


    @Test
    public void receiveAndConvert(){
        List<String> queue2List =(List) rabbitTemplate.receiveAndConvert("queue2");
        printList(queue2List);

        System.out.println("----------------華麗的分隔符-----------------");

        List<String> queue3List =(List) rabbitTemplate.receiveAndConvert("queue3");
        printList(queue3List);

    }


    private <E> void printList(List<E> list){
        if (list != null && list.size() > 0){
            for (Object o : list){
                System.out.println("-----------------"+ o +"---------------");
            }
        }
    }
}
View Code

header 路由方式：

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext.xml")
public class HeadersExchangeTest {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    public void convertAndSend(){
        MessageProperties messageProperties = new MessageProperties();
        messageProperties.setHeader("betty", "rubble");
        messageProperties.setHeader("fred", "flintstone");
        messageProperties.setHeader("barney", "rubble");

        String str = new String("Hello RabbitMQ");
        Message message = new Message(str.getBytes(), messageProperties);
        rabbitTemplate.convertAndSend("headersExchange","",message);
    }

    @Test
    public void receiveAndConvert(){

        Message queue4 = rabbitTemplate.receive("queue4");
        System.out.println("第一個輸出：" + new String(queue4.getBody()));
        Message queue5 = rabbitTemplate.receive("queue5");
        System.out.println("第三個輸出：" + new String(queue5.getBody()));

    }

}
View Code

5、定義消息驅動的AMQP POJO

    用 receive()和 receiveAndConvert()方法都會立即返回，如果隊列中沒有等待的消息時，將會得到 null。Spring AMQP提供了消息驅動POJO的支持，也就是相當於一個監聽器，監聽某些隊列，當消息到達指定隊列的時候，可以立即調用方法處理該消息。

listener-container 配置：

    <rabbit:listener-container connection-factory="connectionFactory" concurrency="2" prefetch="3" type="direct">
        <rabbit:listener ref="handlerListener" method="handler" queue-names="queue5,queue6"/>
    </rabbit:listener-container>

其中，ref 指定Spring bean 的 id，method 指定 該bean中處理隊列中消息的方法，queue-names 指定要監聽哪些隊列，隊列之間用 "," 分隔。

三、結語

    祝大家五一節快樂！

    演示源碼下載鏈接：https://github.com/JMCuixy/SpringMessageRabbitMQ

    參考資料：《Spring 實戰第四版》

                Spring-amqp文檔


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 爬蟲簡單基礎代碼
    以下代碼可以去掉註釋單獨運行： ...
  • 洛谷P3690 【模板】Link Cut Tree （LCT）
    題目背景 動態樹 題目描述 給定n個點以及每個點的權值，要你處理接下來的m個操作。操作有4種。操作從0到3編號。點從1到n編號。 0：後接兩個整數(x，y)，代表詢問從x到y的路徑上的點的權值的xor和。保證x到y是聯通的。 1：後接兩個整數(x，y)，代表連接x到y，若x到y已經聯通則無需連接。 ...
  • Java關鍵字---this的由來和其三大作用
    【聲明】歡迎轉載，但請保留文章原始出處→_→ 秦學苦練：http://www.cnblogs.com/Qinstudy/ 文章來源：http://www.cnblogs.com/Qinstudy/p/Qinstudy.html 【正文】 秦學苦練博主，你好！我是立志要掌握Java編程語言的一名小白， ...
  • Python筆記（十三）：urllib模塊
    （一） URL地址 URL地址組件 URL組件 說明 scheme 網路協議或下載方案 net_loc 伺服器所在地（也許含有用戶信息） path 使用（/）分割的文件或CGI應用的路徑 params 可選參數 query 連接符（&）分割的一系列鍵值對 fragment 指定文檔內特定錨的部分 n ...
  • Python Django框架筆記（一）：安裝及創建項目
    #推薦一本書《Python核心編程》（適合有一定基礎的），美國人Wesley Chun編寫的，京東、淘寶應該都有。我是覺得寫的很好，詳細、簡潔、滿滿的乾貨，不像有的書整本看完也沒什麼用。 （一） Web框架 Web開發除了全部從底層寫起，還可以在其他人已有的基礎上進行開發，簡化開發流程。這些Web開 ...
  • 隨機輸入日期計算星期幾（1900年1月1日為基礎）
    已知，1900年1月1日是星期1，用戶隨機輸入年月日，計算星期幾 代碼如下（未改進），歡迎批評指正 year=int(input('year')) month=int(input('month')) day=int(input('day')) if year >=1900:#大於等於1900 rye ...
  • 《大型網站技術架構 核心原理與案例分析》讀書筆記
    一、大型網站架構演化 1、大型網站特點 高併發，大流量 高可用 海量數據 用戶分佈廣泛，網路情況複雜 安全環境惡劣 需求快速變更，發佈頻繁 漸進式發展 2、大型網站架構發展歷程 文件伺服器，資料庫伺服器，應用伺服器分離 應用伺服器增加本地緩存，本地緩存優先，增加分散式緩存伺服器 使用應用程式伺服器集 ...
  • Python學習-終端字體高亮顯示
    實現過程： 終端的字元顏色是用轉義序列控制的，是文本模式下的系統顯示功能，和具體的語言無關。 轉義序列是以ESC開頭,即用\033來完成（ESC的ASCII碼用十進位表示是27，用八進位表示就是033）。 格式： 開頭部分：\033[顯示方式;前景色;背景色m + 結尾部分：\033[0m 註意：開 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類