很久沒有寫spring boot的內容了，正好最近在寫spring cloud bus的內容，因為內容會有一些相關性，所以先補一篇關于amqp的整合。
message broker與amqp簡介
message broker是一種消息驗證、傳輸、路由的架構模式，其設計目標主要應用于下面這些場景：
- 消息路由到一個或多個目的地
- 消息轉化為其他的表現方式
- 執行消息的聚集、消息的分解，并將結果發送到他們的目的地，然后重新組合相應返回給消息用戶
- 調用web服務來檢索數據
- 響應事件或錯誤
- 使用發布-訂閱模式來提供內容或基于主題的消息路由
amqp是advanced message queuing protocol的簡稱，它是一個面向消息中間件的開放式標準應用層協議。amqp定義了這些特性：
- 消息方向
- 消息隊列
- 消息路由（包括：點到點和發布-訂閱模式）
- 可靠性
- 安全性
rabbitmq
本文要介紹的rabbitmq就是以amqp協議實現的一種中間件產品，它可以支持多種操作系統，多種編程語言，幾乎可以覆蓋所有主流的企業級技術平臺。
安裝
在rabbitmq官網的下載頁面https://www.rabbitmq.com/download.html中，我們可以獲取到針對各種不同操作系統的安裝包和說明文檔。這里，我們將對幾個常用的平臺一一說明。
下面我們采用的erlang和rabbitmq server版本說明：
- erlang/otp 19.1
- rabbitmq server 3.6.5
windows安裝
安裝Erland，通過官方下載頁面http://www.erlang.org/downloads獲取exe安裝包，直接打開并完成安裝。
安裝RabbitMQ，通過官方下載頁面https://www.rabbitmq.com/download.html獲取exe安裝包。
下載完成后，直接運行安裝程序。
rabbitmq server安裝完成之后，會自動的注冊為服務，并以默認配置啟動起來。
mac os x安裝
在mac os x中使用brew工具，可以很容易的安裝rabbitmq的服務端，只需要按如下命令操作即可：
-
brew更新到最新版本，執行：brew update
-
安裝erlang，執行：brew install erlang
-
安裝rabbitmq server，執行：brew install rabbitmq
通過上面的命令，rabbitmq server的命令會被安裝到/usr/local/sbin，并不會自動加到用戶的環境變量中去，所以我們需要在.bash_profile或.profile文件中增加下面內容：
|
1
|
path=$path:/usr/local/sbin |
這樣，我們就可以通過rabbitmq-server命令來啟動rabbitmq的服務端了。
ubuntu安裝
在ubuntu中，我們可以使用apt倉庫來進行安裝
安裝erlang，執行：apt-get install erlang
執行下面的命令，新增apt倉庫到/etc/apt/sources.list.d
|
1
2
|
echo 'deb http://www.rabbitmq.com/debian/ testing main' | sudo tee /etc/apt/sources.list.d/rabbitmq.list |
更新apt倉庫的package list，執行sudo apt-get update命令
安裝rabbit server，執行sudo apt-get install rabbitmq-server命令
rabbit管理
我們可以直接通過配置文件的訪問進行管理，也可以通過web的訪問進行管理。下面我們將介紹如何通過web進行管理。
執行rabbitmq-plugins enable rabbitmq_management命令，開啟web管理插件，這樣我們就可以通過瀏覽器來進行管理了。
|
1
2
3
4
5
6
7
8
9
10
|
> rabbitmq-plugins enable rabbitmq_managementthe following plugins have been enabled: mochiweb webmachine rabbitmq_web_dispatch amqp_client rabbitmq_management_agent rabbitmq_managementapplying plugin configuration to rabbit@pc-201602152056... started 6 plugins. |
打開瀏覽器并訪問：http://localhost:15672/，并使用默認用戶guest登錄，密碼也為guest。我們可以看到如下圖的管理頁面：
從圖中，我們可以看到之前章節中提到的一些基本概念，比如：connections、channels、exchanges、queue等。第一次使用的讀者，可以都點開看看都有些什么內容，熟悉一下rabbitmq server的服務端。
點擊admin標簽，在這里可以進行用戶的管理。
spring boot整合
下面，我們通過在spring boot應用中整合rabbitmq，并實現一個簡單的發送、接收消息的例子來對rabbitmq有一個直觀的感受和理解。
在spring boot中整合rabbitmq是一件非常容易的事，因為之前我們已經介紹過starter poms，其中的amqp模塊就可以很好的支持rabbitmq，下面我們就來詳細說說整合過程：
新建一個spring boot工程，命名為：“rabbitmq-hello”。
在pom.xml中引入如下依賴內容，其中spring-boot-starter-amqp用于支持rabbitmq。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
<parent> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-parent</artifactid> <version>1.3.7.release</version> <relativepath/> <!-- lookup parent from repository --></parent><dependencies> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-amqp</artifactid> </dependency> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-test</artifactid> <scope>test</scope> </dependency></dependencies> |
在application.properties中配置關于rabbitmq的連接和用戶信息，用戶可以回到上面的安裝內容，在管理頁面中創建用戶。
spring.application.name=rabbitmq-hello
|
1
2
3
4
|
spring.rabbitmq.host=localhostspring.rabbitmq.port=5672spring.rabbitmq.username=springspring.rabbitmq.password=123456 |
創建消息生產者sender。通過注入amqptemplate接口的實例來實現消息的發送，amqptemplate接口定義了一套針對amqp協議的基礎操作。在spring boot中會根據配置來注入其具體實現。在該生產者，我們會產生一個字符串，并發送到名為hello的隊列中。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
@componentpublic class sender { @autowired private amqptemplate rabbittemplate; public void send() { string context = "hello " + new date(); system.out.println("sender : " + context); this.rabbittemplate.convertandsend("hello", context); }} |
創建消息消費者receiver。通過@rabbitlistener注解定義該類對hello隊列的監聽，并用@rabbithandler注解來指定對消息的處理方法。所以，該消費者實現了對hello隊列的消費，消費操作為輸出消息的字符串內容。
|
1
2
3
4
5
6
7
8
9
10
|
@component@rabbitlistener(queues = "hello")public class receiver { @rabbithandler public void process(string hello) { system.out.println("receiver : " + hello); }} |
創建rabbitmq的配置類rabbitconfig，用來配置隊列、交換器、路由等高級信息。這里我們以入門為主，先以最小化的配置來定義，以完成一個基本的生產和消費過程。
|
1
2
3
4
5
6
7
8
9
|
@configurationpublic class rabbitconfig { @bean public queue helloqueue() { return new queue("hello"); }} |
創建應用主類：
|
1
2
3
4
5
6
7
8
|
@springbootapplicationpublic class helloapplication { public static void main(string[] args) { springapplication.run(helloapplication.class, args); }} |
創建單元測試類，用來調用消息生產：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
@runwith(springjunit4classrunner.class)@springapplicationconfiguration(classes = helloapplication.class)public class helloapplicationtests { @autowired private sender sender; @test public void hello() throws exception { sender.send(); }} |
完成程序編寫之后，下面開始嘗試運行。首先確保rabbitmq server已經開始，然后進行下面的操作：
啟動應用主類，從控制臺中，我們看到如下內容，程序創建了一個訪問127.0.0.1:5672中springcloud的連接。
同時，我們通過rabbitmq的控制面板，可以看到connection和channels中包含當前連接的條目。
運行單元測試類，我們可以看到控制臺中輸出下面的內容，消息被發送到了rabbitmq server的hello隊列中。
|
1
|
sender : hello sun sep 25 11:06:11 cst 2016 |
切換到應用主類的控制臺，我們可以看到類似如下輸出，消費者對hello隊列的監聽程序執行了，并輸出了接受到的消息信息。
|
1
|
receiver : hello sun sep 25 11:06:11 cst 2016 |
通過上面的示例，我們在spring boot應用中引入spring-boot-starter-amqp模塊，進行簡單配置就完成了對rabbitmq的消息生產和消費的開發內容。然而在實際應用中，我們還有很多內容沒有演示，這里不做更多的講解，讀者可以自行查閱rabbitmq的官方教程，有更全面的了解。
完整示例：chapter5-2-1
開源中國：http://git.oschina.net/didispace/springboot-learning/tree/master/chapter5-2-1
github：https://github.com/dyc87112/springboot-learning/tree/master/chapter5-2-1
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
原文鏈接：http://blog.didispace.com/spring-boot-rabbitmq/
