作者:百色金融新闻网日期:
返回目录:金融新闻
最新资讯《框架篇——Spring整合ActiveMQ(MQ服务端与消费端演示)-activemq》主要内容是activemq,这篇文章主要演示的是Spring整合ActiveMQ,并进行了服务端发送消息到MQ队列与消费端监听MQ队列消费消息的案例。,现在请大家看具体新闻资讯。
1.前言
这篇文章主要演示的是Spring整合ActiveMQ,并进行了服务端发送消息到MQ队列与消费端监听MQ队列消费消息的案例。
2.浅谈项目中MQ使用场景
主要说下目前我负责搭建在的公司的支付架构中使用场景(只用到Queue)
①.用于处理分布式事务(基于消息一致性),因为在订单处理,资金变动方面 并发量比较高,没有考虑使用tcc,或者柔性事务,不仅增加代码量,性能也比较差。
②.用于短信发送,微信消息推送,以及一些日志等集中处理。
③.拥有流量削锋,秒杀等活动控制活动的人数
3.环境准备
使用框架
1.ActiveMQ5.13.0
2.Spring4.3.0
3.MQ部分maven所需包
项目目录结构
4.框架整合
Producer服务者
spring-activemq.xml(spring和mq的整合配置)
MQProducer.java(发送消息到MQ)
测试类
ProducerTest.java
Consumer消费者
spring-activemq.xml(配置文件只粘贴了增加监听器部分)
队列监听器DefaultMessageQueueListener.java
ConsumerTest测试类
5.功能测试
先执行ConsumerTest监听测试队列,再执行ProducerTest.观察控制台以及ActiveMQ管控台(队列有接收到消息,并且消费)
6.代码下载
github地址 https://github.com/ty1972873004/ActiveMQ_Spring