很久沒有寫Spring Boot的內(nèi)容了，正好最近在寫Spring Cloud Bus的內(nèi)容，因為內(nèi)容會有一些相關(guān)性，所以先補一篇關(guān)于AMQP的整合。
Message Broker與AMQP簡介
Message Broker是一種消息驗證、傳輸、路由的架構(gòu)模式，其設(shè)計目標(biāo)主要應(yīng)用于下面這些場景：
- 消息路由到一個或多個目的地
- 消息轉(zhuǎn)化為其他的表現(xiàn)方式
- 執(zhí)行消息的聚集、消息的分解，并將結(jié)果發(fā)送到他們的目的地，然后重新組合相應(yīng)返回給消息用戶
- 調(diào)用Web服務(wù)來檢索數(shù)據(jù)
- 響應(yīng)事件或錯誤
- 使用發(fā)布-訂閱模式來提供內(nèi)容或基于主題的消息路由
AMQP是Advanced Message Queuing Protocol的簡稱，它是一個面向消息中間件的開放式標(biāo)準(zhǔn)應(yīng)用層協(xié)議。AMQP定義了這些特性：
- 消息方向
- 消息隊列
- 消息路由（包括：點到點和發(fā)布-訂閱模式）
- 可靠性
- 安全性
RabbitMQ
本文要介紹的RabbitMQ就是以AMQP協(xié)議實現(xiàn)的一種中間件產(chǎn)品，它可以支持多種操作系統(tǒng)，多種編程語言，幾乎可以覆蓋所有主流的企業(yè)級技術(shù)平臺。
安裝
在RabbitMQ官網(wǎng)的下載頁面https://www.rabbitmq.com/download.html中，我們可以獲取到針對各種不同操作系統(tǒng)的安裝包和說明文檔。這里，我們將對幾個常用的平臺一一說明。
下面我們采用的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安裝完成之后，會自動的注冊為服務(wù)，并以默認配置啟動起來。
Rabbit管理
我們可以直接通過配置文件的訪問進行管理，也可以通過Web的訪問進行管理。下面我們將介紹如何通過Web進行管理。
- 執(zhí)行rabbitmq-plugins enable rabbitmq_management命令，開啟Web管理插件，這樣我們就可以通過瀏覽器來進行管理了。
> rabbitmq-plugins enable rabbitmq_management
The following plugins have been enabled:
mochiweb
webmachine
rabbitmq_web_dispatch
amqp_client
rabbitmq_management_agent
rabbitmq_management
Applying plugin configuration to rabbit@PC-201602152056... started 6 plugins.
- 打開瀏覽器并訪問：http://localhost:15672/，并使用默認用戶guest登錄，密碼也為guest。我們可以看到如下圖的管理頁面：
從圖中，我們可以看到之前章節(jié)中提到的一些基本概念，比如：Connections、Channels、Exchanges、Queue等。第一次使用的讀者，可以都點開看看都有些什么內(nèi)容，熟悉一下RabbitMQ Server的服務(wù)端。
- 點擊
Admin標(biāo)簽，在這里可以進行用戶的管理。
Spring Boot整合
下面，我們通過在Spring Boot應(yīng)用中整合RabbitMQ，并實現(xiàn)一個簡單的發(fā)送、接收消息的例子來對RabbitMQ有一個直觀的感受和理解。
在Spring Boot中整合RabbitMQ是一件非常容易的事，因為之前我們已經(jīng)介紹過Starter POMs，其中的AMQP模塊就可以很好的支持RabbitMQ，下面我們就來詳細說說整合過程：
新建一個Spring Boot工程，命名為：“rabbitmq-hello”。
在pom.xml中引入如下依賴內(nèi)容，其中spring-boot-starter-amqp用于支持RabbitMQ。
<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中配置關(guān)于RabbitMQ的連接和用戶信息，用戶可以回到上面的安裝內(nèi)容，在管理頁面中創(chuàng)建用戶。默認的Client端通信口5672，管理頁面端口15672，server間內(nèi)部通信端口口25672，erlang發(fā)現(xiàn)端口：4369
spring.application.name=rabbitmq-hello
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=spring
spring.rabbitmq.password=123456
- 創(chuàng)建消息生產(chǎn)者Sender。通過注入
AmqpTemplate接口的實例來實現(xiàn)消息的發(fā)送，AmqpTemplate接口定義了一套針對AMQP協(xié)議的基礎(chǔ)操作。在Spring Boot中會根據(jù)配置來注入其具體實現(xiàn)。在該生產(chǎn)者，我們會產(chǎn)生一個字符串，并發(fā)送到名為hello的隊列中。
@Component
public class Sender {
@Autowired
private AmqpTemplate rabbitTemplate;
public void send() {
String context = "hello " + new Date();
System.out.println("Sender : " + context);
this.rabbitTemplate.convertAndSend("hello", context);
}
}
- 創(chuàng)建消息消費者Receiver。通過
@RabbitListener注解定義該類對hello隊列的監(jiān)聽，并用@RabbitHandler注解來指定對消息的處理方法。所以，該消費者實現(xiàn)了對hello隊列的消費，消費操作為輸出消息的字符串內(nèi)容。
@Component
@RabbitListener(queues = "hello")
public class Receiver {
@RabbitHandler
public void process(String hello) {
System.out.println("Receiver : " + hello);
}
}
- 創(chuàng)建RabbitMQ的配置類RabbitConfig，用來配置隊列、交換器、路由等高級信息。這里我們以入門為主，先以最小化的配置來定義，以完成一個基本的生產(chǎn)和消費過程。
@Configuration
public class RabbitConfig {
@Bean
public Queue helloQueue() {
return new Queue("hello");
}
}
- 創(chuàng)建應(yīng)用主類：
@SpringBootApplication
public class HelloApplication {
public static void main(String[] args) {
SpringApplication.run(HelloApplication.class, args);
}
}
- 創(chuàng)建單元測試類，用來調(diào)用消息生產(chǎn)：
@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(classes = HelloApplication.class)
public class HelloApplicationTests {
@Autowired
private Sender sender;
@Test
public void hello() throws Exception {
sender.send();
}
}
完成程序編寫之后，下面開始嘗試運行。首先確保RabbitMQ Server已經(jīng)開始，然后進行下面的操作：
- 啟動應(yīng)用主類，從控制臺中，我們看到如下內(nèi)容，程序創(chuàng)建了一個訪問127.0.0.1:5672中springcloud的連接。
o.s.a.r.c.CachingConnectionFactory : Created new connection: SimpleConnection@29836d32 [delegate=amqp://springcloud@127.0.0.1:5672/]
同時，我們通過RabbitMQ的控制面板，可以看到Connection和Channels中包含當(dāng)前連接的條目。
- 運行單元測試類，我們可以看到控制臺中輸出下面的內(nèi)容，消息被發(fā)送到了RabbitMQ Server的hello隊列中。
Sender : hello Sun Sep 25 11:06:11 CST 2016
- 切換到應(yīng)用主類的控制臺，我們可以看到類似如下輸出，消費者對hello隊列的監(jiān)聽程序執(zhí)行了，并輸出了接受到的消息信息。
Receiver : hello Sun Sep 25 11:06:11 CST 2016
通過上面的示例，我們在Spring Boot應(yīng)用中引入spring-boot-starter-amqp模塊，進行簡單配置就完成了對RabbitMQ的消息生產(chǎn)和消費的開發(fā)內(nèi)容。然而在實際應(yīng)用中，我們還有很多內(nèi)容沒有演示，這里不做更多的講解，讀者可以自行查閱RabbitMQ的官方教程，有更全面的了解。
在上面的例子中，忽略了所需要配置的RabbitMQ的客戶端用戶名、密碼，我在RabbitMQ的Web控制臺配置了一個新的用戶Ozan，密碼為123456，角色為任意。
工程啟動會報錯，一開始以為是因為角色配置的原因，但是更改至最高權(quán)限也并無用處，但是使用guest帳號就沒問題，差異就在下圖
因此切換至Virtual Hosts標(biāo)簽，并點擊/。
這樣新建的用戶信息，在應(yīng)用啟動時可以正常啟動。
完整示例：Chapter5-2-1
