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

　　代码如下：

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

　　

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

　　

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

　　

最新文章

1. 解决ubuntu16.04软件中心闪退的问题
2. java面试题总汇
3. ZOJ Problem Set - 1402 Magnificent Meatballs
4. session_id 恢复 session的内容
5. jackson json转实体 com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException
6. （进阶篇）Cookie与 Session使用详解
7. 自然语言处理1——语言处理与Python（内含纠错）
8. 第4章3节《MonkeyRunner源码剖析》ADB协议及服务: ADB协议概览SYNC.TXT翻译参考(原创)
9. MYSQL 分表实践
10. webstorm 激活码
11. Python中的赋值(复制)、浅拷贝、深拷贝之间的区别
12. robotframework导入测试库使用方法
13. vue的事件处理梳理
14. 《从Lucene到Elasticsearch：全文检索实战》学习笔记五
15. vue返回上一页面如果没有上一页面返回首页
16. springboot maven项目，为什么build成功，build path也没错误，project-->clean 也没用，项目上面还是有个红x呢？
17. 20155233 《网络对抗》Exp4 恶意代码分析
18. 使用idea 在springboot添加本地jar包的方法 部署的时候本地jar没有包含的解决方法
19. Java批量插入更新操作
20. python 获取字符串中所有数字

热门文章

1. struts2的配置文件为什么可以使用${}符号?
2. 160630、五句话搞定JavaScript作用域
3. AsyncTaskLoader设计原理大揭秘
4. mysql主从同步因断电产生的不能同步问题
5. Java 语言基础之运算符
6. python基础之类的isinstance与issubclass、反射
7. jQuery选择器-常用
8. Linux bridge 资料链接
9. python基础教程_学习笔记19：标准库：一些最爱——集合、堆和双端队列
10. thinkphp使用阿里云OSS最新SDK，文件部署