Spring Boot企业级开发(三)异步消息

异步消息

异步消息主要目的是为了系统与系统之间的通信。所谓异步消息即消息发送者无须等待消息接收者的处理及返回,甚至无须关心消息是否发送成功。
在异步消息中有两个很重要的概念,即消息代理和目的地。当消息发送者发送消息后,消息将由消息代理接管,消息代理保证消息传递到指定的目的地。
异步消息主要有两种形式的目的地:队列(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发送的消息。
Spring Boot企业级开发(三)异步消息
在ActiveMQ的管理页面可以查看我们目的地的相关信息:
Spring Boot企业级开发(三)异步消息

参考书籍:Spring Boot实战;
以上只是学习所做的笔记,以供日后参考!!!

上一篇:站在K2角度审视流程--任务的独占与释放


下一篇:AutoMapper用法