SpringBoot對消息隊列(MQ)的支持

1.異步消息的定義

??

異步消息的主要目的是為了系統(tǒng)與系統(tǒng)之間的通信，所謂異步消息即消息發(fā)送者無需等待消息接收者的處理以及返回，甚至無需關(guān)心消息是否發(fā)送成功。
??

在異步消息中有兩個很重要的概念，即消息代理和目的地，當(dāng)消息發(fā)送者發(fā)送消息之后，消息將由消息代理接管，消息代理保證消息傳遞到指定目的地。
??

異步消息主要有兩種目的地形式，隊列（queue）和主題(topic)，隊列用于點對點形式的消息通信，主題用于發(fā)布訂閱式的消息通信。

1.1目的地形式分類

1.1.1點對點式

??

當(dāng)消息發(fā)送者發(fā)送消息，消息代理將消息后將消息放進一個隊列里，當(dāng)有消息接收者來接收消息的時候，消息將從隊列中取出傳遞給消息接收者，這時候隊列里就沒有了這條消息。點對點式確保每一條消息只有唯一的發(fā)送者和接收者，但這并不能說明只有一個接收者能夠從隊列中接收消息，因為隊列中有多個消息，點對點式只保證每一條消息只有唯一的發(fā)送者和接收者。

1.1.2發(fā)布/訂閱式

??

發(fā)布訂閱式是消息發(fā)送者發(fā)送消息到主題，而多個消息接收者監(jiān)聽這個主題，此時的消息發(fā)送者和接收者分別叫做發(fā)布者和訂閱者。

1.2 企業(yè)級消息代理

??

JMS即JAVA消息服務(wù)，是基于JVM的消息代理規(guī)范，ActiveMQ是一個JMS的實現(xiàn)
AMQP也是一個消息代理的規(guī)范，他不僅兼容JMS，還支持跨語言和平臺，AMQP的主要實現(xiàn)是RabbitMQ。

1.3 Spring以及SpringBoot的支持

??

Spring針對JMS和RabbitMQ分別提供了JmsTemplete和RabbitTemplete來發(fā)送消息。為我們提供了@JmsListener,@RabbitListener注解來監(jiān)聽消息代理發(fā)送的消息。我們分別需要通過@EnableJms和@EnableRabbit來開啟支持。
??

SpringBoot自動配置了上述@EnableJms，@EnableRabbit，JmsTemplete，RabbitTemplete的支持，同時我們可以在application.properties文件中分別以spring.activemq和spring.rabbitmq來分別配置所需的屬性。

2.SpringBoot對JMS（ActiveMQ）的支持下載安裝

ActiveMQ的官方下載地址：http://activemq.apache.org/download.html，下載安裝完成后，進入bin目錄，發(fā)現(xiàn)有win32和win64兩個文件夾，這2個文件夾分別對應(yīng)windows32位和windows64位操作系統(tǒng)的啟動腳本。進入對應(yīng)的文件夾中雙擊activemq.bat。即可正常啟動。

訪問http://localhost:8161/admin。輸入默認(rèn)的用戶名和密碼：admin/admin即可進入ActiveMQ的控制臺。

2.2 配置

SpringBoot提供了針對ActiveMQ的支持，只需要在pom.xml文件中引入即可：

<dependency>
???<groupId>org.springframework.bootgroupId>
???<artifactId>spring-boot-starter-activemqartifactId>
dependency>

在application.properties配置ActiveMQ的消息代理地址:

spring.activemq.broker-url=tcp://localhost:61616

注意，此處配置的消息代理必須讓ActiveMQ啟動時才有作用，否則無效。

在實際情況下，消息的發(fā)布者和接受者一般都是分開的，而這里，我們僅作測試，將消息發(fā)送者和接收者放在一個程序中。

2.3代碼文件

2.3.1消息定義

public?class?Msg?implements?MessageCreator?{
????@Override
????public?Message createMessage(Session session)?throws?JMSException {
????????return?session.createTextMessage("測試消息");
????}
}

2.3.2消息發(fā)送及目的地定義

@SpringBootApplication
public?class?SpringBootMqApplication?implements?CommandLineRunner{

????@Autowired
????JmsTemplate jmsTemplate;
????public?static?void?main(String[] args)?{
????????SpringApplication.run(SpringBootMqApplication.class, args);
????}

????@Override
????public?void?run(String... args)?throws?Exception {
????????????jmsTemplate.send("my-destination",new?Msg());
????}
}

CommandLineRunner接口中的run方法，是在程序啟動后就會執(zhí)行的代碼。JmsTemplate ?是用來操作JMS消息的操作類。

2.3.3消息監(jiān)聽

@Component
public?class?Receiver?{
????@JmsListener(destination = "my-destination")
????public?void??receivedMessage(String message){
????????System.out.println("接受到"+message);
????}
}

@JmsListener顯示的定義了指定要監(jiān)聽的目的地。

2.3.4運行結(jié)果

運行結(jié)果顯示監(jiān)聽收到了消息

ActiveMQ的控制臺中顯示我們發(fā)送的消息

3.SpringBoot對AMQP（RabbitMQ）的支持

3.1RabbitMQ的安裝配置

RabbitMQ是基于Erlang語言開發(fā)的。所以安裝RabbitMQ之前需要先下載安裝配置Erlang，下載地址：http://www.erlang.org/downloads

并將安裝后的D:\Program Files\erl9.0\bin的bin目錄配置到path環(huán)境變量中。然后下載安裝RabbitMQ。下載地址:http://www.rabbitmq.com/download.html
安裝完成之后在開始菜單中找到RabbitMQ Command Promt，打開控制臺，輸入命令

rabbitmq-plugins enable rabbitmq_management

控制臺無錯誤之后，訪問http://localhost:15672。使用默認(rèn)的用戶名/密碼：guest/guest進行登錄。

即可見到如圖所示界面：

3.2 RabbitMQ測試代碼文件

SpringBoot默認(rèn)Rabbit的主機為localhost，端口號為5672，所以我們無需為RabbitMQ配置其他信息。

入口文件

import?org.springframework.amqp.core.Queue;
import?org.springframework.amqp.rabbit.core.RabbitTemplate;
import?org.springframework.beans.factory.annotation.Autowired;
import?org.springframework.boot.CommandLineRunner;
import?org.springframework.boot.SpringApplication;
import?org.springframework.boot.autoconfigure.SpringBootApplication;
import?org.springframework.context.annotation.Bean;

import?java.lang.annotation.Annotation;

@SpringBootApplication
public?class?SpringBootAmqpApplication?implements?CommandLineRunner?{
????@Autowired
?????RabbitTemplate rabbitTemplate;
????public?static?void?main(String[] args)?{
????????SpringApplication.run(SpringBootAmqpApplication.class, args);
????}

????@Bean?//2
????public?Queue wiselyQueue(){
????????return?new?Queue("my-queue");
????}

????@Override
????public?void?run(String... strings)?throws?Exception {
????????rabbitTemplate.convertAndSend("my-queue","來自RabbitMQ的問候");
????}
}

接收類

@Component
public?class?Receiver?{
????@RabbitListener(queues = "my-queue")
????public??void??ReceiveMesaage(String message){
????????System.out.println("接受到"+message);
????}
}

3.3 測試結(jié)果

在RabbitMQ控制臺中額可以看到

4 小結(jié)

這里主要是對ActiveMQ和RabbitMQ進行了簡單的嘗試，了解了異步消息的通信。有興趣的同學(xué)可以進行深入研究。

作者：微瞰技術(shù)

出處：csdn.net/u011342403/article/details/77940765