AMQ: Publisher/Subscriber(发布/订阅者)消息模式开发流程

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 反馈信息并解除线程堵塞，进入下一轮。

注： 可 同时运行多个订阅者测试查看此模式效果