JMS调用IBM MQ发布订阅模式

zzl001

　　发布订阅模式使用的代码还是和上一篇的相同，但是需要改一些参数以及个别需要注意的地方。
　　首先发布订阅模式需要的参数不一样。
　　发布订阅模式不使用队列管理器，而是使用发布者订阅者。发布消息的就是发布者。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
　　根据这套代码，必须先启动订阅者，再启动发布者，才会显示出结果。否则还真收不到消息。至于原因，我目前还没搞清楚。想想，其实也应该是这样。先订阅了，发布的时候才会收到消息。
　　这一篇就写这么多了。