Spring Cloud 2.x系列之springboot集成ActiveMQ

消息队列中间件是分布式系统中重要的组件,主要解决应用耦合,异步消息,流量削锋等问题。实现高性能,高可用,可伸缩和最终一致性架构;是大型分布式系统不可缺少的中间件。目前使用较多的消息队列有ActiveMQ、RabbitMQ、Kafka、RocketMQ、MetaMQ等。springboot提供了对JMS系统的支持;springboot很方便就可以集成这些消息中间件。

对于异步消息在实际的应用之中会有两类:

JMS:代表作就是ActiveMQ,但是其性能不高,因为其是用java程序实现的。

AMQP:直接利用协议实现的消息组件,其大众代表作为RabbitMQ,高性能代表作为Kafka。

1、新建项目,对应的pom.xml文件如下

2、新建springboot启动类ActiveMqApplication.java

3、新建配置文件application.yml

4、新建消费生产者

5、新建消息消费者

队列模式:

订阅模式:

6、新建测试类

7、进行测试

先登录ActiveMq管理平台:http://localhost:8161/

队列模式:

(2)注释测试类的如下代码

(3)运行测试类

订阅模式:

(2)注释测试类的如下代码

(3)运行测试类

源码:

一个聚百万人脉的技术圈子

  • 发表于:
  • 原文链接https://kuaibao.qq.com/s/20181015G0CK5M00?refer=cp_1026
  • 腾讯「云+社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。
  • 如有侵权,请联系 yunjia_community@tencent.com 删除。

扫码关注云+社区

领取腾讯云代金券