SpringBoot整合消息服务组件
作者：互联网
在进行分布式系统设计时，经常会使用消息服务组件进行系统整合与异步服务通信，其基本结构为生产者与消费者处理，如图5-1所示。常用的消息组件主要包括两类：JMS标准（ActiveMQ）和AMQP标准（RabbitMQ、Kafka），本章将为读者讲解这两类组件与SpringBoot的整合。
5.3.1 SpringBoot整合ActiveMQ消息组件
ActiveMQ是Apache提供的开源组件，是基于JMS标准的实现组件。下面将利用SpringBoot整合ActiveMQ组件，实现队列消息的发送与接收。
1．【mldnboot-integration项目】修改pom.xml配置文件，追加spring-boot-starter-activemq依赖库。
2．【mldnboot-integration项目】修改application.yml配置文件，进行ActiveMQ的配置。
3．【mldnboot-integration项目】定义消息消费监听类。
4．【mldnboot-integration项目】定义消息生产者业务接口。
5．【mldnboot-integration项目】定义消息业务实现类。
6．【mldnboot-integration项目】定义JMS消息发送配置类，该类主要用于配置队列信息。
本例利用ActiveMQ实现了消息的发送与接收处理。每当有消息接收到时，都会自动执行MessageConsumer类，进行消息消费。
5.3.2 SpringBoot整合RabbitMQ消息组件
RabbitMQ是一个在AMQP基础上构建的新一代企业级消息系统，该组件由Pivotal公司提供，使用ErLang语言开发。本小节将为读者讲解如何使用SpringBoot实现指定RoutingKey的消息处理。
1．【mldnboot-integration项目】修改pom.xml配置文件，追加spring-boot-starter-amqp依赖包。
2．【mldnboot-integration项目】修改yml.xml配置文件，进行RabbitMQ的相关配置。
3．【mldnboot-integration项目】为了可以正常使用RabbitMQ进行消息处理，还需要做一个消息生产配置类。
4．【mldnboot-integration项目】建立消息发送接口。
5．【mldnboot-integration项目】建立消息业务实现子类。
6．【mldnboot-integration项目】建立一个消息消费端的配置程序类。
7．【mldnboot-integration项目】定义监听处理类。
此时程序实现了与RabbitMQ消息组件的整合，同时在整个程序中只需要调用IMessageProducer接口中的send()方法就可以正常发送，而后会找到设置同样ROUTINGKEY的消费者进行消息消费。
标签：SpringBoot,integration,RabbitMQ,消息,整合,组件,ActiveMQ,mldnboot 来源： https://www.cnblogs.com/callbin/p/15343538.html