Spring Boot中使用RabbitMQ

很久沒有寫Spring Boot的内容了，正好最近在寫Spring Cloud Bus的内容，因為内容會有一些相關性，是以先補一篇關于AMQP的整合。

Message Broker是一種消息驗證、傳輸、路由的架構模式，其設計目标主要應用于下面這些場景：

消息路由到一個或多個目的地

消息轉化為其他的表現方式

執行消息的聚集、消息的分解，并将結果發送到他們的目的地，然後重新組合相應傳回給消息使用者

調用Web服務來檢索資料

響應事件或錯誤

使用釋出-訂閱模式來提供内容或基于主題的消息路由

AMQP是Advanced Message Queuing Protocol的簡稱，它是一個面向消息中間件的開放式标準應用層協定。AMQP定義了這些特性：

消息方向

消息隊列

消息路由（包括：點到點和釋出-訂閱模式）

可靠性

安全性

本文要介紹的RabbitMQ就是以AMQP協定實作的一種中間件産品，它可以支援多種作業系統，多種程式設計語言，幾乎可以覆寫所有主流的企業級技術平台。

在RabbitMQ官網的下載下傳頁面<code>https://www.rabbitmq.com/download.html</code>中，我們可以擷取到針對各種不同作業系統的安裝包和說明文檔。這裡，我們将對幾個常用的平台一一說明。

下面我們采用的Erlang和RabbitMQ Server版本說明：

Erlang/OTP 19.1

RabbitMQ Server 3.6.5

安裝Erland，通過官方下載下傳頁面<code>http://www.erlang.org/downloads</code>擷取exe安裝包，直接打開并完成安裝。

安裝RabbitMQ，通過官方下載下傳頁面<code>https://www.rabbitmq.com/download.html</code>擷取exe安裝包。

下載下傳完成後，直接運作安裝程式。

RabbitMQ Server安裝完成之後，會自動的注冊為服務，并以預設配置啟動起來。

在Mac OS X中使用brew工具，可以很容易的安裝RabbitMQ的服務端，隻需要按如下指令操作即可：

brew更新到最新版本，執行：brew update

安裝Erlang，執行：<code>brew install erlang</code>

安裝RabbitMQ Server，執行：<code>brew install rabbitmq</code>

通過上面的指令，RabbitMQ Server的指令會被安裝到<code>/usr/local/sbin</code>，并不會自動加到使用者的環境變量中去，是以我們需要在<code>.bash_profile</code>或<code>.profile</code>檔案中增加下面内容：

這樣，我們就可以通過<code>rabbitmq-server</code>指令來啟動RabbitMQ的服務端了。

在Ubuntu中，我們可以使用APT倉庫來進行安裝

安裝Erlang，執行：<code>apt-get install erlang</code>

執行下面的指令，新增APT倉庫到<code>/etc/apt/sources.list.d</code>

更新APT倉庫的package list，執行<code>sudo apt-get update</code>指令

安裝Rabbit Server，執行<code>sudo apt-get install rabbitmq-server</code>指令

我們可以直接通過配置檔案的通路進行管理，也可以通過Web的通路進行管理。下面我們将介紹如何通過Web進行管理。

執行<code>rabbitmq-plugins enable rabbitmq_management</code>指令，開啟Web管理插件，這樣我們就可以通過浏覽器來進行管理了。

打開浏覽器并通路：<code>http://localhost:15672/</code>，并使用預設使用者<code>guest</code>登入，密碼也為<code>guest</code>。我們可以看到如下圖的管理頁面：

從圖中，我們可以看到之前章節中提到的一些基本概念，比如：Connections、Channels、Exchanges、Queue等。第一次使用的讀者，可以都點開看看都有些什麼内容，熟悉一下RabbitMQ Server的服務端。

點選<code>Admin</code>标簽，在這裡可以進行使用者的管理。

下面，我們通過在Spring Boot應用中整合RabbitMQ，并實作一個簡單的發送、接收消息的例子來對RabbitMQ有一個直覺的感受和了解。

在Spring Boot中整合RabbitMQ是一件非常容易的事，因為之前我們已經介紹過Starter POMs，其中的AMQP子產品就可以很好的支援RabbitMQ，下面我們就來詳細說說整合過程：

建立一個Spring Boot工程，命名為：“rabbitmq-hello”。

在<code>pom.xml</code>中引入如下依賴内容，其中<code>spring-boot-starter-amqp</code>用于支援RabbitMQ。

在<code>application.properties</code>中配置關于RabbitMQ的連接配接和使用者資訊，使用者可以回到上面的安裝内容，在管理頁面中建立使用者。

建立消息生産者<code>Sender</code>。通過注入<code>AmqpTemplate</code>接口的執行個體來實作消息的發送，<code>AmqpTemplate</code>接口定義了一套針對AMQP協定的基礎操作。在Spring Boot中會根據配置來注入其具體實作。在該生産者，我們會産生一個字元串，并發送到名為<code>hello</code>的隊列中。

建立消息消費者<code>Receiver</code>。通過<code>@RabbitListener</code>注解定義該類對<code>hello</code>隊列的監聽，并用<code>@RabbitHandler</code>注解來指定對消息的處理方法。是以，該消費者實作了對<code>hello</code>隊列的消費，消費操作為輸出消息的字元串内容。

建立RabbitMQ的配置類<code>RabbitConfig</code>，用來配置隊列、交換器、路由等進階資訊。這裡我們以入門為主，先以最小化的配置來定義，以完成一個基本的生産和消費過程。

建立應用主類：

建立單元測試類，用來調用消息生産：

完成程式編寫之後，下面開始嘗試運作。首先確定RabbitMQ Server已經開始，然後進行下面的操作：

啟動應用主類，從控制台中，我們看到如下内容，程式建立了一個通路<code>127.0.0.1:5672</code>中<code>springcloud</code>的連接配接。

同時，我們通過RabbitMQ的控制台，可以看到Connection和Channels中包含目前連接配接的條目。

運作單元測試類，我們可以看到控制台中輸出下面的内容，消息被發送到了RabbitMQ Server的<code>hello</code>隊列中。

切換到應用主類的控制台，我們可以看到類似如下輸出，消費者對<code>hello</code>隊列的監聽程式執行了，并輸出了接受到的消息資訊。

通過上面的示例，我們在Spring Boot應用中引入<code>spring-boot-starter-amqp</code>子產品，進行簡單配置就完成了對RabbitMQ的消息生産和消費的開發内容。然而在實際應用中，我們還有很多内容沒有示範，這裡不做更多的講解，讀者可以自行查閱RabbitMQ的官方教程，有更全面的了解。

完整示例：Chapter5-2-1