JMS调用IBM MQ公布订阅模式

JMS调用IBM MQ发布订阅模式

?

如果想保留消息，那么在上图的“保留消息”复选框中选中，再打开发布预订窗口，也能接收到消息。

之前使用资源管理器的发布订阅模式，新建了主题，在“订阅”中也创建了订阅者。在主题的订阅者能够看到所有的订阅者，如下图所示：

JMS调用IBM MQ公布订阅模式
?但是，可能是由于刚开始不了解的缘故吧，始终无法查看发布者。

之前运行了代码，在“主题-发布者”中一直看不到发布者，运行订阅者也收不到消息，不知道哪出了问题。后来才知道确实无法看到通过代码发布消息的发布者。资源管理器的发布订阅者和代码的是两码事。

对于订阅者无法收到消息的问题，其实是这样的。之前我对代码做了修改。原来等待时间是15秒，而我设置成了1500毫秒。订阅者的消息只取一次，所以消息就那么错过了。

创建完队列管理器后，选中“侦听器”。在右面的“内容”中会有个默认的侦听器。监听1414端口。如下图所示：

JMS调用IBM MQ公布订阅模式
?

?如果没有侦听器侦听，那么会出现（ 'MQCC_FAILED' ），原因为 '2058' （ 'MQRC_Q_MGR_NAME_ERROR' ）。的异常。

为了侦听到消息，修改订阅者的代码如下：

?打印出来是红色。先启动订阅者，再启动发布者，结果如下：

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

根据这套代码，必须先启动订阅者，再启动发布者，才会显示出结果。否则还真收不到消息。至于原因，我目前还没搞清楚。想想，其实也应该是这样。先订阅了，发布的时候才会收到消息。

这一篇就写这么多了。

JMS调用IBM MQ公布订阅模式

热点推荐