首页 > 其他 > 详细

JMS-activeMq发布订阅模式

时间:2017-03-25 23:56:48      阅读:342      评论:0      收藏:0      [点我收藏+]

  上一篇对点对点模式进行总结,这一篇都发布订阅模式进行总结,代码都差不多,唯一区别就是创建队(session.createQueue(目的地))列改为创建主题(session.createTopic(目的地))。

  代码如下:

  发布订阅模式-生产者类HelloTopicProducer

  技术分享

  发布订阅模式-生产者类HelloTopicConsumer

  技术分享

  代码结束,本地测试的时候,先启动消费者代码(先订阅再收消息),然后再启动生产者代码。生产者和消费者类分别启动两个环境进行运行(启动两个eclipse),因为在同一个环境下运行,生产者和消费者不能同时在线,这样会导致生产者生产消息,actimeMq控制台已经收到消息,但是消费者一直读取不到消息。

  

JMS-activeMq发布订阅模式

原文:http://www.cnblogs.com/gdpuzxs/p/6618832.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!