Apache ActiveMQ教程（二）
Apache ActiveMQ教程（二）2008-06-03 14:25
五、Point-to-Point (点对点)消息模式开发流程
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()));
}
页:
[1]