ActiveMQ与Spring的整合使用

 我来答
青柠姑娘17
2022-07-07 · TA获得超过1.2万个赞
知道大有可为答主
回答量:6175
采纳率:100%
帮助的人:33.3万
展开全部

在介绍ActiveMQ特性的时候有一条就是,对spring的支持,ActiveMQ可以很容易内嵌到使用Spring的系统里面去,而且也支持Spring2.0的特性,那么这里就来进行二者的整合与测试使用。
1、生产者
创建maven工程spring-activemq-producer,整一个spring的配置文件放到resource目录下。
在配置文件applicationContext.xml中
1、配置ConnectionFactory;
2、配置spring提供的用于管理ConnectionFactory的ConnectionFactory;
3、配置生成者,Spring为我们提供了JsmTemplate这个工具类,用它可以进行消息发送;
4、配置目的地(有点对点的和一对多的);

编写测试类,测试点对点消息发送

运行方法后页面查看如下

发现一个挂起的消息(该消息是被持久化的,被消费时消失),一个入队消息。

2、消费者
创建另外一个maven工程spring-activemq-consumer,整一个spring的配置文件放到resource目录下。
在配置文件applicationContext.xml中
1、配置ConnectionFactory;
2、配置spring提供的用于管理ConnectionFactory的ConnectionFactory;
3、配置目的地(有点对点的和一对多的),到这都是跟配置生产者一致;
4、编写消息监听器,MyMessageListener(名字随意)实现MessageListener接口。

5、配置文件中配置自定义消息监听器;
6、配置消息监听容器。

注意:消费者接收消息目的地必须跟生产者发送消息目的地名称一致,不然不在一个频道是接收不到消息的。
测试接收消息,由于前面发送了一个消息,这里是应该能接收到的。

注:System.in.read()表示按下回车程序才会继续往下执行,否则是处于一直能接收消息的状态,生成者发送几条消息这就接收几条(也就会打印几条生产者发送的消息的内容 “发送了一个消息“)。

查看页面:

能看到被挂起的消息被消费了,所以有一条出队消息,一个消费者。这里测试的是点对点的,关于发布/订阅形式的上面改一下配置文件,以及测试方法中发布消息目的地改为”topic”即可,注释里面已经写过就不再写测试了。

已赞过 已踩过<
你对这个回答的评价是?
评论 收起
推荐律师服务: 若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询

为你推荐:

下载百度知道APP,抢鲜体验
使用百度知道APP,立即抢鲜体验。你的手机镜头里或许有别人想知道的答案。
扫描二维码下载
×

类别

我们会通过消息、邮箱等方式尽快将举报结果通知您。

说明

0/200

提交
取消

辅 助

模 式