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()));
}