JMS无法连接到WebSphere MQ

Question

这是我的java类代码

---

package com.ibm.point_A_point; 

import javax.jms.Connection; 
import javax.jms.Destination; 
import javax.jms.JMSException; 
import javax.jms.Message; 
import javax.jms.MessageConsumer; 
import javax.jms.MessageProducer; 
import javax.jms.Session; 
import javax.jms.TextMessage; 

import com.ibm.msg.client.jms.JmsConnectionFactory; 
import com.ibm.msg.client.jms.JmsFactoryFactory; 
import com.ibm.msg.client.wmq.WMQConstants; 

/** 
* A minimal and simple application for Point-to-point messaging. 
* 
* Application makes use of fixed literals, any customisations will require re-compilation of this 
* source file. Application assumes that the named queue is empty prior to a run. 
* 
* Notes: 
* 
* API type: JMS API (v1.1, unified domain) 
* 
* Messaging domain: Point-to-point 
* 
* Provider type: WebSphere MQ 
* 
* Connection mode: Client connection 
* 
* JNDI in use: No 
* 
*/ 
public class SimplePTP { 

    // System exit status value (assume unset value to be 1) 
    private static int status = 1; 

    /** 
    * Main method 
    * 
    * @param args 
    */ 
    public static void main(String[] args) { 

    // Variables 
    Connection connection = null; 
    Session session = null; 
    Destination destination = null; 
    MessageProducer producer = null; 
    MessageConsumer consumer = null; 

    try { 
     // Create a connection factory 
     JmsFactoryFactory ff = JmsFactoryFactory.getInstance(WMQConstants.WMQ_PROVIDER); 
     JmsConnectionFactory cf = ff.createConnectionFactory(); 

     // Set the properties 
     cf.setStringProperty(WMQConstants.WMQ_HOST_NAME, "localhost"); 
     cf.setIntProperty(WMQConstants.WMQ_PORT, 1414); 
     cf.setStringProperty(WMQConstants.WMQ_CHANNEL, "SYSTEM.DEF.SVRCONN"); 
     cf.setIntProperty(WMQConstants.WMQ_CONNECTION_MODE, WMQConstants.WMQ_CM_CLIENT); 
     cf.setStringProperty(WMQConstants.WMQ_QUEUE_MANAGER, "QM1"); 
     cf.setStringProperty(WMQConstants.WMQ_APPLICATIONNAME, "SimplePTP (JMS)"); 

     // Create JMS objects 
     connection = cf.createConnection(); 
     session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 
     destination = session.createQueue("queue:///Q1"); 
     producer = session.createProducer(destination); 
     consumer = session.createConsumer(destination); 

     long uniqueNumber = System.currentTimeMillis() % 1000; 
     TextMessage message = session.createTextMessage("SimplePTP: Your lucky number today is " 
                 + uniqueNumber); 

     // Start the connection 
     connection.start(); 

     // And, send the message 
     producer.send(message); 
     System.out.println("Sent message:\n" + message); 

     Message receivedMessage = consumer.receive(15000); // in ms or 15 seconds 
     System.out.println("\nReceived message:\n" + receivedMessage); 

     recordSuccess(); 
    } 
    catch (JMSException jmsex) { 
     recordFailure(jmsex); 
    } 
    finally { 
     if (producer != null) { 
     try { 
      producer.close(); 
     } 
     catch (JMSException jmsex) { 
      System.out.println("Producer could not be closed."); 
      recordFailure(jmsex); 
     } 
     } 
     if (consumer != null) { 
     try { 
      consumer.close(); 
     } 
     catch (JMSException jmsex) { 
      System.out.println("Consumer could not be closed."); 
      recordFailure(jmsex); 
     } 
     } 

     if (session != null) { 
     try { 
      session.close(); 
     } 
     catch (JMSException jmsex) { 
      System.out.println("Session could not be closed."); 
      recordFailure(jmsex); 
     } 
     } 

     if (connection != null) { 
     try { 
      connection.close(); 
     } 
     catch (JMSException jmsex) { 
      System.out.println("Connection could not be closed."); 
      recordFailure(jmsex); 
     } 
     } 
    } 
    System.exit(status); 
    return; 
    } // end main() 

    /** 
    * Process a JMSException and any associated inner exceptions. 
    * 
    * @param jmsex 
    */ 
    private static void processJMSException(JMSException jmsex) { 
    System.out.println(jmsex); 
    Throwable innerException = jmsex.getLinkedException(); 
    if (innerException != null) { 
     System.out.println("Inner exception(s):"); 
    } 
    while (innerException != null) { 
     System.out.println(innerException); 
     innerException = innerException.getCause(); 
    } 
    return; 
    } 

    /** 
    * Record this run as successful. 
    */ 
    private static void recordSuccess() { 
    System.out.println("SUCCESS"); 
    status = 0; 
    return; 
    } 

    /** 
    * Record this run as failure. 
    * 
    * @param ex 
    */ 
    private static void recordFailure(Exception ex) { 
    if (ex != null) { 
     if (ex instanceof JMSException) { 
     processJMSException((JMSException) ex); 
     } 
     else { 
     System.out.println(ex); 
     } 
    } 
    System.out.println("FAILURE"); 
    status = -1; 
    return; 
    } 

} 

---

我一直这个错误（异常） com.ibm.msg.client.jms.DetailedJMSSecurityException ：JMSWMQ2013：通过连接模式'Client'和主机名'localhost（1414）'提供给队列管理器'QM1'的身份验证安全性无效。 检查提供的用户名和密码在连接的等待队列管理器中是否正确。 WebSphere MQ调用失败，并显示完成代码'2'（'MQCC_FAILED'）;模式'2035'（'MQRC_NOT_AUTHORIZED'）。

Answer 1

您需要用户标识和密码（取决于MQ的版本）才能连接到队列管理器。该用户标识通常存在于队列管理器正在运行的计算机上。

您需要在代码中传递用户标识和密码，如下所示。用您的用户和密码替换。

cf.setStringProperty(WMQConstants.USERID,"userid"); 
cf.setStringProperty(WMQConstants.PASSWORD, "password"); 

除此之外，用户必须被赋予权力来连接到队列管理器，把/获取有关应用程序正在使用的队列。

我建议您与您的MQ管理员联系以提供用户标识/密码信息以及必需的权限。

Answer 2

cf.setStringProperty(WMQConstants.WMQ_CHANNEL, "SYSTEM.DEF.SVRCONN"); 

您不应该使用SYSTEM通道。让您的MQAdmin为您的应用程序创建一个。

connection = cf.createConnection(); 

将其更改为：

connection = cf.createConnection("myUser","myPswd"); 

提出您MQADMIN如果认证是针对为本地操作系统或LDAP，然后使用适当的用户名和密码。