spring boot 集成 activeMQ 之 P2P 的简单应用

      在实际项目中,很多时候要消息中间件来进行分布式系统之间的通信。它具有低耦合,可靠投递广播,流量控制,最终一致性等一系列功能。

      消息机制主要有三种: P2P、订阅/发布、应答模式。本人也是初步学习使用消息机制,先写个P2P的消息机制以供记录学习笔记。

直接上代码:

第一步 pom.xml中引入activeMq的依赖

<!--消息队列  -->
<!-- activeMq support -->
<dependency>
<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
<!-- activeMq end -->

第二步 application.properties文件中添加如下配置

spring boot 集成 activeMQ 之 P2P 的简单应用

第三步  定义一个 P2P 队列

spring boot 集成 activeMQ 之 P2P 的简单应用


第四步:  定义一个生产者,通过springboot提供的JmsMessagingTemplate实现send动作,并生产p2p消息;

spring boot 集成 activeMQ 之 P2P 的简单应用

第五步: 定义消费者

spring boot 集成 activeMQ 之 P2P 的简单应用

第六步 测试接口

spring boot 集成 activeMQ 之 P2P 的简单应用

第七步 测试结果

spring boot 集成 activeMQ 之 P2P 的简单应用

spring boot 集成 activeMQ 之 P2P 的简单应用

P2P消息机制就到这里了。