在 Java 程序中在 IBM MQ 中创建主题

Posted

技术标签:

【中文标题】在 Java 程序中在 IBM MQ 中创建主题【英文标题】:Create a topic in IBM MQ in java program 【发布时间】:2015-06-28 17:56:04 【问题描述】:

我想在我的 Java 应用程序中创建一个名为“manipulation”的主题,但我收到此错误:

Exception in thread "main" com.ibm.mq.MQException: MQJE001: Completion Code '2', Reason '2085'

我的代码是:

MQTopic subscriber = new MQTopic(queueManager, null, "manipulation",CMQC.MQTOPIC_OPEN_AS_SUBSCRIPTION, CMQC.MQSO_CREATE);

如这里所说:

Accessing queues, topics, and processes in IBM MQ classes for Java

【问题讨论】:

【参考方案1】:

您用于创建主题订阅的代码需要稍作修改才能使其正常工作:

MQTopic subscriber = new MQTopic(queueManager, null, "manipulation",CMQC.MQTOPIC_OPEN_AS_SUBSCRIPTION, CMQC.MQSO_CREATE);

在上面的 sn-p 中你已经指定了第三个参数,即主题对象名称。当您指定主题对象名称时,该对象必须存在才能使用。在您的情况下,您已经以管理方式创建了一个名为 manipulation 的主题对象,然后使用上面的构造函数创建订阅。因为主题manipulation 不存在,所以抛出了MQRC 2085 异常。

你有两个选择:

1) 以管理方式创建主题对象“操作”。

2) 如果您不想创建主题对象,请在不使用主题对象名称的情况下即时创建订阅,如下所示

MQTopic subscriber = queueManager.accessTopic("manipulation", "", CMQC.MQTOPIC_OPEN_AS_SUBSCRIPTION, CMQC.MQSO_MANAGED | CMQC.MQSO_CREATE | CMQC.MQOO_FAIL_IF_QUIESCING);

【讨论】:

【参考方案2】:

MQ 异常 2085 表示 MQRC_UNKNOWN_OBJECT_NAME

您提供的队列对象名称无效。

示例代码:

try        
     MQTopicConnectionFactory cf = new MQTopicConnectionFactory();        
     // Config       
     cf.setHostName("<Destination-IP>");       
     cf.setPort(1414);
     cf.setTransportType(JMSC.MQJMS_TP_CLIENT_MQ_TCPIP);           
     cf.setQueueManager("<Queue-Manager-Name>");          
     cf.setChannel("SYSTEM.DEF.SVRCONN");        
     MQTopicConnection connection = (MQTopicConnection) cf.createTopicConnection();       
     MQTopicSession session = (MQTopicSession) connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);       
     MQTopic topic = (MQTopic) session.createTopic("topic://test");              
     MQTopicPublisher publisher =  (MQTopicPublisher) session.createPublisher(topic);       
     MQTopicSubscriber subscriber = (MQTopicSubscriber) session.createSubscriber(topic);              
     JMSTextMessage message = (JMSTextMessage) session.createTextMessage("Hello World");             
     // Start the connection      
     connection.start();        
     publisher.publish(message);       
     log.info("Sent message:" + message);        
     JMSMessage receivedMessage = (JMSMessage) subscriber.receive(10000);        
     log.info("Received message:" + receivedMessage);        
     publisher.close();       
     subscriber.close();       
     session.close();       
     connection.close();        
     log.info("SUCCESS");     
      catch (JMSException jex)        
       log.error(jex.getMessage());            
      catch (Exception ex)        
       log.error(ex.getMessage());       
      System.out.println("\\nFAILURE\\n");     
     

您也可以在命令提示符下执行相同操作

crtmqm QM_A //Create Queue-Manager
strmqm QM_A //Start Queue-Manager
runmqsc QM_A //Open Websphere MQ CLI
DEFINE LISTENER(A.LISTENER) TRPTYPE(TCP) CONTROL(QMGR) PORT(1414) //Define Listener
START LISTENER(A.LISTENER) //Start Listener
DEFINE CHANNEL(A.CHANNEL) CHLTYPE(SVRCONN) //Define Channel
START CHANNEL(A.CHANNEL) // Start Channel
DEFINE QLOCAL(A.QUEUE) MAXDEPTH(50000) //Define LocalQueue
DEFINE TOPIC(A.TOPIC) TOPICSTR('A') //Define Topic
DEFINE SUB(A.SUBQUEUE) DEST(A.QUEUE) TOPICOBJ(A.TOPIC) REPLACE; //Link Subscription Queue with Topic

访问http://bencane.com/2013/04/22/websphere-mq-cheat-sheet-for-system-administrators/

【讨论】:

以上是关于在 Java 程序中在 IBM MQ 中创建主题的主要内容,如果未能解决你的问题,请参考以下文章

连接IBM MQ原因码报2035的错误解决办法

IBM MQ通道

IBM MQ通道

IBM MQ通道

IBM MQ 从接收通道获取数据

提供对 IBM WebSphere MQ 的匿名访问