1、生产者(producer)开发流程(ProducerTool.java):
1.1
创建Connection:
根据url,user和password创建一个jms
Connection。
1.2
创建Session:
在connection的基础上创建一个session,同时设置是否支持事务和ACKNOWLEDGE标识。
1.3
创建Destination对象:
需指定其对应的主题(subject)名称,producer和consumer将根据subject来发送/接收对应的消息。
1.4
创建MessageProducer:
根据Destination创建MessageProducer对象,同时设置其持久模式。
1.5
发送消息到队列(Queue):
封装TextMessage消息,使用MessageProducer的send方法将消息发送出去。
2、消费者(consumer)开发流程(ConsumerTool.java):
2.1
实现MessageListener接口:
消费者类必须实现MessageListener接口,然后在onMessage()方法中监听消息的到达并处理。
2.2
创建Connection:
根据url,user和password创建一个jms
Connection,如果是durable模式,还需要给connection设置一个clientId。
2.3
创建Session和Destination:
与ProducerTool.java中的流程类似,不再赘述。
2.4创建replyProducer【可选】:
可以用来将消息处理结果发送给producer。
2.5
创建MessageConsumer:
根据Destination创建MessageConsumer对象。
2.6
消费message:
在onMessage()方法中接收producer发送过来的消息进行处理,并可以通过replyProducer反馈信息给producer
if (message.getJMSReplyTo() !=
null) {
replyProducer.send(message.getJMSReplyTo(),
session.createTextMessage("Reply: " + message.getJMSMessageID()));
}
|
相关推荐
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就是其中一种。它使应用间能以异步,松耦合方式交流。