标签：SpringBoot integration RabbitMQ 消息 整合 组件 ActiveMQ mldnboot

在进行分布式系统设计时，经常会使用消息服务组件进行系统整合与异步服务通信，其基本结构为生产者与消费者处理，如图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

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。