很久沒有寫Spring Boot的內(nèi)容了，正好最近在寫Spring Cloud Bus的內(nèi)容，因?yàn)閮?nèi)容會(huì)有一些相關(guān)性，所以先補(bǔ)一篇關(guān)于AMQP的整合。

Message Broker與AMQP簡(jiǎn)介

Message Broker是一種消息驗(yàn)證、傳輸、路由的架構(gòu)模式，其設(shè)計(jì)目標(biāo)主要應(yīng)用于下面這些場(chǎng)景：

• 消息路由到一個(gè)或多個(gè)目的地
• 消息轉(zhuǎn)化為其他的表現(xiàn)方式
• 執(zhí)行消息的聚集、消息的分解，并將結(jié)果發(fā)送到他們的目的地，然后重新組合相應(yīng)返回給消息用戶
• 調(diào)用Web服務(wù)來檢索數(shù)據(jù)
• 響應(yīng)事件或錯(cuò)誤
• 使用發(fā)布-訂閱模式來提供內(nèi)容或基于主題的消息路由

AMQP是Advanced Message Queuing Protocol的簡(jiǎn)稱，它是一個(gè)面向消息中間件的開放式標(biāo)準(zhǔn)應(yīng)用層協(xié)議。AMQP定義了這些特性：

• 消息方向
• 消息隊(duì)列
• 消息路由（包括：點(diǎn)到點(diǎn)和發(fā)布-訂閱模式）
• 可靠性
• 安全性

RabbitMQ

本文要介紹的RabbitMQ就是以AMQP協(xié)議實(shí)現(xiàn)的一種中間件產(chǎn)品，它可以支持多種操作系統(tǒng)，多種編程語言，幾乎可以覆蓋所有主流的企業(yè)級(jí)技術(shù)平臺(tái)。

安裝

詳情見《安裝RabbitMQ》

Rabbit管理

我們可以直接通過配置文件的訪問進(jìn)行管理，也可以通過Web的訪問進(jìn)行管理。下面我們將介紹如何通過Web進(jìn)行管理。

• 執(zhí)行rabbitmq-plugins.bat enable rabbitmq_management命令，開啟Web管理插件，這樣我們就可以通過瀏覽器來進(jìn)行管理了。

D:\myProgram\RabbitMQ Server\rabbitmq_server-3.6.9\sbin>rabbitmq-plugins.bat enable rabbitmq_management The following plugins have been enabled:amqp_clientcowlibcowboyrabbitmq_web_dispatchrabbitmq_management_agentrabbitmq_managementApplying plugin configuration to rabbit@SF0001107252A... started 6 plugins.D:\myProgram\RabbitMQ Server\rabbitmq_server-3.6.9\sbin>

?

• 打開瀏覽器并訪問：http://localhost:15672/，并使用默認(rèn)用戶guest登錄，密碼也為guest。我們可以看到如下圖的管理頁面：

從圖中，我們可以看到之前章節(jié)中提到的一些基本概念，比如：Connections、Channels、Exchanges、Queue等。第一次使用的讀者，可以都點(diǎn)開看看都有些什么內(nèi)容，熟悉一下RabbitMQ Server的服務(wù)端。

• • 點(diǎn)擊Admin標(biāo)簽，在這里可以進(jìn)行用戶的管理。

?

Spring Boot整合

下面，我們通過在Spring Boot應(yīng)用中整合RabbitMQ，并實(shí)現(xiàn)一個(gè)簡(jiǎn)單的發(fā)送、接收消息的例子來對(duì)RabbitMQ有一個(gè)直觀的感受和理解。

在Spring Boot中整合RabbitMQ是一件非常容易的事，因?yàn)橹拔覀円呀?jīng)介紹過Starter POMs，其中的AMQP模塊就可以很好的支持RabbitMQ，下面我們就來詳細(xì)說說整合過程：

• 新建一個(gè)Spring Boot工程，命名為：“rabbitmq-hello”。
• 在pom.xml中引入如下依賴內(nèi)容，其中spring-boot-starter-amqp用于支持RabbitMQ。

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.dxz</groupId><artifactId>rabbitmq-hello</artifactId><version>0.0.1-SNAPSHOT</version><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> </project>

• 在application.properties中配置關(guān)于RabbitMQ的連接和用戶信息，用戶可以回到上面的安裝內(nèi)容，在管理頁面中創(chuàng)建用戶。

spring.application.name=rabbitmq-hello spring.rabbitmq.host=localhost spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.password=guest

• 創(chuàng)建消息生產(chǎn)者Sender。通過注入AmqpTemplate接口的實(shí)例來實(shí)現(xiàn)消息的發(fā)送，AmqpTemplate接口定義了一套針對(duì)AMQP協(xié)議的基礎(chǔ)操作。在Spring Boot中會(huì)根據(jù)配置來注入其具體實(shí)現(xiàn)。在該生產(chǎn)者，我們會(huì)產(chǎn)生一個(gè)字符串，并發(fā)送到名為hello的隊(duì)列中。

package com.dxz;import java.util.Date;import org.springframework.amqp.core.AmqpTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component;@Component public class Sender {@Autowiredprivate AmqpTemplate rabbitTemplate;public void send() {String context = "hello " + new Date();System.out.println("Sender : " + context);this.rabbitTemplate.convertAndSend("hello", context);}}

• 創(chuàng)建消息消費(fèi)者Receiver。通過@RabbitListener注解定義該類對(duì)hello隊(duì)列的監(jiān)聽，并用@RabbitHandler注解來指定對(duì)消息的處理方法。所以，該消費(fèi)者實(shí)現(xiàn)了對(duì)hello隊(duì)列的消費(fèi)，消費(fèi)操作為輸出消息的字符串內(nèi)容。

package com.dxz;import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component;@Component @RabbitListener(queues = "hello") public class Receiver {@RabbitHandlerpublic void process(String hello) {System.out.println("Receiver : " + hello);}}

• 創(chuàng)建RabbitMQ的配置類RabbitConfig，用來配置隊(duì)列、交換器、路由等高級(jí)信息。這里我們以入門為主，先以最小化的配置來定義，以完成一個(gè)基本的生產(chǎn)和消費(fèi)過程。

package com.dxz;import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration;import com.rabbitmq.client.impl.AMQImpl.Queue;@Configuration public class RabbitConfig {@Beanpublic Queue helloQueue() {return new Queue();} }

• 創(chuàng)建應(yīng)用主類：

package com.dxz;import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication public class RabbitmqHelloApplication {public static void main(String[] args) {SpringApplication.run(RabbitmqHelloApplication.class, args);}}

• 創(chuàng)建單元測(cè)試類，用來調(diào)用消息生產(chǎn)：

package com.dxz;import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.SpringApplicationConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;@RunWith(SpringJUnit4ClassRunner.class) @SpringApplicationConfiguration(classes = RabbitmqHelloApplication.class) public class RabbitmqHelloApplicationTests {@Autowiredprivate Sender sender;@Testpublic void hello() throws Exception {sender.send();}}

啟動(dòng)應(yīng)用主類，從控制臺(tái)中，我們看到如下內(nèi)容，程序創(chuàng)建了一個(gè)訪問127.0.0.1:5672中springcloud的連接。完成程序編寫之后，下面開始嘗試運(yùn)行。首先確保RabbitMQ Server已經(jīng)開始，然后進(jìn)行下面的操作：

2017-04-07 14:57:06.596 INFO 11120 --- [cTaskExecutor-1] o.s.a.r.c.CachingConnectionFactory : Created new connection: SimpleConnection@185f5797 [delegate=amqp://guest@127.0.0.1:5672/]

?

運(yùn)行單元測(cè)試類，我們可以看到控制臺(tái)中輸出下面的內(nèi)容，消息被發(fā)送到了RabbitMQ Server的hello隊(duì)列中。同時(shí)，我們通過RabbitMQ的控制面板，可以看到Connection和Channels中包含當(dāng)前連接的條目。

1	Sender : hello Sun Sep 25 11:06:11 CST 2016

• 切換到應(yīng)用主類的控制臺(tái)，我們可以看到類似如下輸出，消費(fèi)者對(duì)hello隊(duì)列的監(jiān)聽程序執(zhí)行了，并輸出了接受到的消息信息。

1	Receiver : hello Sun Sep 25 11:06:11 CST 2016

通過上面的示例，我們?cè)赟pring Boot應(yīng)用中引入spring-boot-starter-amqp模塊，進(jìn)行簡(jiǎn)單配置就完成了對(duì)RabbitMQ的消息生產(chǎn)和消費(fèi)的開發(fā)內(nèi)容。然而在實(shí)際應(yīng)用中，我們還有很多內(nèi)容沒有演示，這里不做更多的講解，讀者可以自行查閱RabbitMQ的官方教程，有更全面的了解。

完整示例：Chapter5-2-1

轉(zhuǎn)載于:https://www.cnblogs.com/duanxz/p/3772644.html

總結(jié)

以上是生活随笔為你收集整理的Spring Boot中使用RabbitMQ的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。