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

2024-03-22 13:00:34

异步消息

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

1：点对点式

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

2：发布/订阅式

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

消息代理

1：JMS（Java Message Service）

JMS即Java消息服务，是基于JVM消息代理的规范。而ActiveMQ、HornetQ是一个JMS消息代理的实现；

2：AMQP（Advanced Message Queuing Protocol）

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

JMS实战

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

        <dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-jms</artifactId>
		</dependency>
		
		<dependency>
			<groupId>org.apache.activemq</groupId>
			<artifactId>activemq-client</artifactId>
		</dependency>

2：配置属性
application.properties

spring.activemq.broker-url=tcp://localhost:61616       //消息代理的地址

3：消息定义

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

4：消息发送及目的地的定义

@SpringBootApplication
//Spring Boot提供了CommandLineRunner接口，用于程序启动后执行的代码，通过重写其run方法执行
public class ActiveMqApplication implements CommandLineRunner{ 
	
	@Autowired
	JmsTemplate jmsTemplate; //注入Spring Boot为我们配置好的JmsTemplate的Bean

    public static void main(String[] args) {
        SpringApplication.run(ActiveMqApplication.class, args);
        
    }

	@Override
	public void run(String... args) throws Exception {
	    //通过JmsTemplate的send方法向my-destination目的地发送Msg的消息，这里也等于在消息代理上定义了一个目的地叫my-destination。
		jmsTemplate.send("my-destination", new Msg()); 
		
	}
}

5：消息监听

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

}

运行测试：
启动程序，程序会自动向目的地my-destination发送消息，而Receiver类注解了@JmsListener的方法会自动监听my-destination发送的消息。

在ActiveMQ的管理页面可以查看我们目的地的相关信息：

参考书籍：Spring Boot实战；
以上只是学习所做的笔记，以供日后参考！！！

码农公寓