1、订阅者(Subscriber)开发流程(TopicListener.java):
1.1
实现MessageListener接口:
在onMessage()方法中监听发布者发出的消息队列,并做相应处理。
1.2
创建Connection:
根据url,user和password创建一个jms
Connection。
1.3
创建Session:
在connection的基础上创建一个session,同时设置是否支持事务和ACKNOWLEDGE标识。
1.4
创建Topic:
创建2个Topic, topictest.messages用于接收发布者发出的消息,topictest.control用于向发布者发送消息,实现双方的交互。
1.5
创建consumer和producer对象:
根据topictest.messages创建consumer,根据topictest.control创建producer。
1.6 接收处理消息:
在onMessage()方法中,对收到的消息进行处理,可直接简单在本地显示消息,或者根据消息内容不同处理对应的业务逻辑(比如:数据库更新、文件操作等等),并且可以使用producer对象将处理结果返回给发布者。
2、发布者(Publisher)开发流程(TopicPublisher.java):
2.1
实现MessageListener接口:
在onMessage()方法中接收订阅者的反馈消息。
2.2
创建Connection:
根据url,user和password创建一个jms
Connection。
2.3
创建Session:
在connection的基础上创建一个session,同时设置是否支持事务和ACKNOWLEDGE标识。
2.4
创建Topic:
创建2个Topic,topictest.messages用于向订阅者发布消息,topictest.control用于接收订阅者反馈的消息。这2个topic与订阅者开发流程中的topic是一一对应的。
2.5
创建consumer和producer对象:
根据topictest.messages创建publisher;
根据topictest.control创建consumer,同时监听订阅者反馈的消息。
2.6
给所有订阅者发送消息,并接收反馈消息:
示例代码中,一共重复10轮操作。
每轮先向所有订阅者发送2000个消息;
然后堵塞线程,开始等待;
最后通过onMessage()方法,接收到订阅者反馈的“REPORT”类信息后,才print反馈信息并解除线程堵塞,进入下一轮。
注:可同时运行多个订阅者测试查看此模式效果
相关推荐
Apache ActiveMQ 教程 提供了相关的部署过程、开发方式等
Apache ActiveMQ教程 JMS 整合Tomcat
Apatch 提供的一套JMS 引擎,非常好用,开源,免费, 可以和spring继承,运行稳定。个人感觉比openJMS等这样的小型的要好用的多。
Apache_ActiveMQ教程
Apache_ActiveMQ 教程 中文 JMS 通讯
apache-activemq-5.11.2 附全解教程 apache-activemq-5.11.2 附全解教程
Apache_ActiveMQ教程.doc
Apache ActiveMQ Queue Topic 详解 教程 加入代码解释说明
SUN JMS 教程 APACHE ACTIVEMQ 教程
activemq对应安装教程:https://blog.csdn.net/tangcv/article/details/86715723
ActiveMQ 教程和简要介绍,AMQ是apache公司开发的业界应用较为广泛的消息中间件
<a href=http://activemq.apache.org/version-5-getting-started.html >http://activemq.apache.org/version-5-getting-started.html</a> <a href=http://java.sun.com/j2ee/1.4/docs/tutorial/doc/index.html>...
教程视频:Apache ActiveMQ是Apache软件基金会所研发的开放源代码消息中间件
Apache+ActiveMQ教程.pdf JMS规范教程.pdf JMS简明教程.pdf 三份教程
主要讲解activemq的安装,使用,集群的搭建,以及拓展
ActiveMQ是Apache下的开源项目,完全支持JMS1.1和J2EE1.4规范的JMS Provider实现。?特点:?1、支持多种语言编写客户端?2、对spring的支持,很容易和spring整合?3、支持多种传输协议:TCPSSLNIOUDP等?4、支持AJAX?...
apache ActiveMQ强大的消息中间件,入门资料,高手绕行,
教程视频:Apache ActiveMQ是Apache软件基金会所研发的开放源代码消息中间件
摘要:本文主要讲述ActiveMQ的基本知识和使用方法,并简单结合spring使用ActiveMQ。 企业消息软件从80年代起就存在,它不只是一种应用间消息传递...Apache ActiveMQ就是其中一种。它使应用间能以异步,松耦合方式交流。