框架篇——Spring整合ActiveMQ（MQ服务端与消费端演示）

Posted 2021-04-24 java之web项目

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管控台（队列有接收到消息，并且消费）