JMS调用IBM MQ发布订阅模式
发布订阅模式使用的代码还是和上一篇的相同，但是需要改一些参数以及个别需要注意的地方。首先发布订阅模式需要的参数不一样。
发布订阅模式不使用队列管理器，而是使用发布者订阅者。发布消息的就是发布者。JmsProducer就是发布者。订阅者是订阅消息者，即订阅某一主题的消息。
发布者需要的参数如下：
args = new String[]{"-m","QMTest", "-d","topic://zhuti","-h","localhost","-p","1414"};
其中主题的格式必须是topic://zhuti，在IBM MQ中需要事先创建好主题。如果主题不存在，会报如下异常：
（ 'MQCC_FAILED' ），原因为 '2058' （ 'MQRC_Q_MGR_NAME_ERROR' ）。
订阅者需要的参数和发布者一样。
另外isTopic这个参数需要设置为true。代码中就不创建队列管理器了。
if (isTopic) {
destination = session.createTopic(destinationName);
}
else {
destination = session.createQueue(destinationName);
}
在MQ资源管理器中，是实现不了这种模式的。创建完一个主题后，只能测试。之前不知道对于主题的发布测试是非模态的。其实可以打开两个窗口，一个发布一个测试。如下图所示：
如果想保留消息，那么在上图的“保留消息”复选框中选中，再打开发布预订窗口，也能接收到消息。
之前使用资源管理器的发布订阅模式，新建了主题，在“订阅”中也创建了订阅者。在主题的订阅者能够看到所有的订阅者，如下图所示：
但是，可能是由于刚开始不了解的缘故吧，始终无法查看发布者。
之前运行了代码，在“主题-发布者”中一直看不到发布者，运行订阅者也收不到消息，不知道哪出了问题。后来才知道确实无法看到通过代码发布消息的发布者。资源管理器的发布订阅者和代码的是两码事。
对于订阅者无法收到消息的问题，其实是这样的。之前我对代码做了修改。原来等待时间是15秒，而我设置成了1500毫秒。订阅者的消息只取一次，所以消息就那么错过了。
创建完队列管理器后，选中“侦听器”。在右面的“内容”中会有个默认的侦听器。监听1414端口。如下图所示：
如果没有侦听器侦听，那么会出现（ 'MQCC_FAILED' ），原因为 '2058' （ 'MQRC_Q_MGR_NAME_ERROR' ）。的异常。
为了侦听到消息，修改订阅者的代码如下：
if (message != null) {
System.err.println("Received message:\n" + message);
// System.out.println("Received message:\n" + message);
}
else {
System.out.println("No message received!\n");
recordFailure(null);
}
打印出来是红色。先启动订阅者，再启动发布者，结果如下：
Sent message:
JMSMessage class: jms_text
JMSType: null
JMSDeliveryMode: 2
JMSExpiration: 0
JMSPriority: 4
JMSMessageID: ID:414d5120616161612020202020202020b44e035120006702
JMSTimestamp: 1359289495451
JMSCorrelationID: null
JMSDestination: topic://zhuti
JMSReplyTo: null
JMSRedelivered: false
JMSXAppID: test.JmsProducer
JMSXDeliveryCount: 0
JMSXUserID: Administrato
JMS_IBM_ConnectionID: 414D5143616161612020202020202020B44E035120006601
JMS_IBM_PutApplType: 28
JMS_IBM_PutDate: 20130127
JMS_IBM_PutTime: 12245546
JmsProducer: Your lucky number today is 419
SUCCESS
Received message:
JMSMessage class: jms_text
JMSType: null
JMSDeliveryMode: 2
JMSExpiration: 0
JMSPriority: 4
JMSMessageID: ID:414d5120616161612020202020202020b44e035120006703
JMSTimestamp: 1359289495451
JMSCorrelationID: ID:414d5120616161612020202020202020b44e035120006504
JMSDestination: topic://zhuti
JMSReplyTo: null
JMSRedelivered: false
JMSXAppID: aaaa
JMSXDeliveryCount: 1
JMSXUserID: Administrato
JMS_IBM_Character_Set: UTF-8
JMS_IBM_ConnectionID: 414D5143616161612020202020202020B44E035120006601
JMS_IBM_Encoding: 273
JMS_IBM_Format: MQSTR
JMS_IBM_MsgType: 8
JMS_IBM_PutApplType: 26
JMS_IBM_PutDate: 20130127
JMS_IBM_PutTime: 12245546
JmsProducer: Your lucky number today is 419
SUCCESS
根据这套代码，必须先启动订阅者，再启动发布者，才会显示出结果。否则还真收不到消息。至于原因，我目前还没搞清楚。想想，其实也应该是这样。先订阅了，发布的时候才会收到消息。
这一篇就写这么多了。
页:
[1]