SpringBoot企业级开发（三）异步消息

异步消息主要目的是为了系统与系统之间的通信。所谓异步消息即消息发送者无须等待消息接收者的处理及返回&＃xff0c;甚至无须关心消息是否发送成功。
在异步消息中有两个很重要的概念&＃xff0c;即消息代理和目的地。当消息发送者发送消息后&＃xff0c;消息将由消息代理接管&＃xff0c;消息代理保证消息传递到指定的目的地。
异步消息主要有两种形式的目的地&＃xff1a;队列&＃xff08;queue&＃xff09;和主题&＃xff08;topic&＃xff09;。队列用于点对点式的消息通信&＃xff1b;主题用于发布/订阅式的消息通信。

1&＃xff1a;点对点式

当消息发送者发送消息&＃xff0c;消息代理获得消息后将消息放进一个队列&＃xff08;queue&＃xff09;里&＃xff0c;当有消息接收者来接收消息的时候&＃xff0c;消息将从队列里取出来传递给接收者&＃xff0c;这时候队列里 就没有了这条消息。
点对点式确保的是每一条消息只有唯一的发送者和接收者&＃xff0c;但这并不能说明只有一个接收者可以从队列里接收消息。因为队列里有多个消息&＃xff0c;点对点式只保证每一条消息只有唯一的发送者和接收者。

2&＃xff1a;发布/订阅式

和点对点不同&＃xff0c;发布/订阅式是消息发送者发送消息到主题&＃xff08;topic&＃xff09;&＃xff0c;而多个消息接收者监听这个主题。此时的消息发送者和接收者分别叫做发布者和订阅者。

1&＃xff1a;JMS&＃xff08;Java Message Service&＃xff09;

JMS即Java消息服务&＃xff0c;是基于JVM消息代理的规范。而ActiveMQ、HornetQ是一个JMS消息代理的实现&＃xff1b;

2&＃xff1a;AMQP&＃xff08;Advanced Message Queuing Protocol&＃xff09;

AMQP也是一个消息代理的规范&＃xff0c;但它不仅兼容JMS&＃xff0c;还支持跨语言和平台。AMQP的主要实现有RabbitMQ;

1&＃xff1a;新建Spring Boot项目&＃xff0c;依赖无&＃xff1b;虽然Spring Boot提供了JMS的依赖&＃xff0c;但默认使用的消息代理是HornetQ&＃xff0c;本例使用的是ActiveMQ&＃xff0c;所以我们需要添加spring-jms和activemq-client的依赖&＃xff1a;

org.springframeworkspring-jmsorg.apache.activemqactivemq-client


2&＃xff1a;配置属性
application.properties

spring.activemq.broker-url&＃61;tcp://localhost:61616 //消息代理的地址


3&＃xff1a;消息定义

//定义JMS发送的消息需实现MessageCreator接口&＃xff0c;并重写createMessage方法
public class Msg implements MessageCreator{&＃64;Overridepublic Message createMessage(Session session) throws JMSException {return session.createTextMessage("测试消息");}}


4&＃xff1a;消息发送及目的地的定义

&＃64;SpringBootApplication
//Spring Boot提供了CommandLineRunner接口&＃xff0c;用于程序启动后执行的代码&＃xff0c;通过重写其run方法执行
public class ActiveMqApplication implements CommandLineRunner{ &＃64;AutowiredJmsTemplate jmsTemplate; //注入Spring Boot为我们配置好的JmsTemplate的Beanpublic static void main(String[] args) {SpringApplication.run(ActiveMqApplication.class, args);}&＃64;Overridepublic void run(String... args) throws Exception {//通过JmsTemplate的send方法向my-destination目的地发送Msg的消息&＃xff0c;这里也等于在消息代理上定义了一个目的地叫my-destination。jmsTemplate.send("my-destination", new Msg()); }
}


5&＃xff1a;消息监听

&＃64;Component
public class Receiver {//&＃64;JmsListener用来简化JMS开发&＃xff0c;destination属性指定要监听的目的地&＃xff0c;即可接收该目的地发送的消息。此例监听my-destination目的地发送的消息&＃64;JmsListener(destination &＃61; "my-destination") public void receiveMessage(String message) {System.out.println("接受到: <" &＃43; message &＃43; ">");}}


运行测试&＃xff1a;
启动程序&＃xff0c;程序会自动向目的地my-destination发送消息&＃xff0c;而Receiver类注解了&＃64;JmsListener的方法会自动监听my-destination发送的消息。

在ActiveMQ的管理页面可以查看我们目的地的相关信息&＃xff1a;

参考书籍&＃xff1a;Spring Boot实战&＃xff1b;
以上只是学习所做的笔记&＃xff0c;以供日后参考&＃xff01;&＃xff01;&＃xff01;