在应用程序中使用 IBM MQ 客户端 jar 连接到 IBM MQ 服务器时没有响应

Question

我正在处理的应用程序需要与远程位置的 IBM MQ 服务器通信。我们目前有一个使用活动 MQ 的工作系统，该系统使用代理和一个桥来连接到这个远程 IBM MQ 服务器并且工作正常。

由于一些新的增强功能，我们现在尝试使用 IBM 客户端 jars 而不是 Active MQ 来实现相同的功能。

我面临的问题是我可以连接到远程服务器的 inboundQ 并发送消息。但是我总是从远程服务器的出站队列接收 null。但是我无法检查是否在远程位置收到了消息。但是如果通过旧的 ActiveMQ 系统发送相同的消息，则会得到远程 MQ 服务器的响应。

旧的 Active MQ 在内部使用网桥连接到远程 IBM MQ 服务器，该服务器的配置与我使用的新代码完全相同。

我尝试了来自互联网的多个代码和堆栈溢出本身，我总是能够连接但没有得到任何响应。

此外，在尝试从远程 IBM MQ 发送或接收数据时，我没有收到任何错误或异常。

我将粘贴我正在尝试开始工作的示例代码。我已经更改了代码中的一些配置值。

我的疑惑如下。

1. 为此，我所做的只是将 IBM MQ 客户端 jar 复制到应用程序中，并使用代码将消息发送到远程 MQ。我没有安装任何其他应用程序。这样的系统会工作吗？还是应该有一些中间程序，比如活动 MQ？

2. 相同的代码能够从我安装在本地网络中的 IBM MQ 服务器发送和接收，但无法从远程服务器获得响应？这让我相信如果我在配置中遗漏了什么？除了在代码中还应该配置什么？

3. 我没有看到任何错误或异常。始终发送消息，但响应为空。我还没有看到使用任何用户名-密码或公钥-私钥身份验证。是否有任何通常用于检查来源的身份验证。 ?

4. 我正在使用我知道旧的 IBM MQ 客户端 5.3 版本。但是使用它，因为他们工作的活动 MQ 设置使用相同并且工作正常。我无法知道远程机器上存在 IBM MQ 服务器上的哪个版本。如果我们使用与服务器 MQ 版本不同的客户端 MQ 版本，是否会出现问题。 ?

在本地环境中适用于我的示例代码，即能够从我安装在本地网络中另一台机器上的 IBM MQ 服务器发送和接收。当我尝试将它与远程 IBM MQ 服务器一起使用时，相同的代码将获取空响应。

import javax.jms.*;
import javax.jms.JMSException;
import com.ibm.mq.jms.*;
import com.ibm.jms.JMSMessage;
import javax.jms.TextMessage;

public class SendReceive {
    private MQQueueConnectionFactory connectionFactory;
    private MQQueueConnection connection;

    private void runTest() {
        try {
            connect();
            connection.start();
            MQQueueSession session = (MQQueueSession) connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
            MQQueue queue = (MQQueue) session.createQueue("INBOUND_QUEUE");     /* values  replaced with correct values in deployment server */
            MQQueue queue2 = (MQQueue) session.createQueue("OUTBOUND_QUEUE");   /* values  replaced with correct values in deployment server */
            MQQueueSender sender = (MQQueueSender) session.createSender(queue);     

            MQQueueReceiver receiver = (MQQueueReceiver) session.createReceiver(queue2);

            //TextMessage message = session.createTextMessage("yesyesyes");
            String stt = "Test Message";        //

            TextMessage message = session.createTextMessage(stt);
            message.setJMSReplyTo(queue2);
            sender.send(message);
            System.out.println("Sent: " + message);

            Message msg1 = receiver.receive(5000);
            if(msg1!=null){
                String responseMsg = ((TextMessage) msg1).getText();
                System.out.println("Received: " + responseMsg);
            }else{
                System.out.println("Message received is null");
            }
        }catch(Exception e){
            System.out.println("Exception caught in program : " + e);
            e.printStackTrace();
        }
    }

    public boolean connect() {
        boolean connected = false;
        try {
            /* values below are replaced with correct values in deployment server */

            connectionFactory = new MQQueueConnectionFactory();            
            connectionFactory.setPort(1515);
            connectionFactory.setHostName("192.168.1.23"); // 
            connectionFactory.setQueueManager("QCCMGR");
            connectionFactory.setChannel("QCHANNEL");            
            connectionFactory.setTransportType(JMSC.MQJMS_TP_CLIENT_MQ_TCPIP);

            connection = (MQQueueConnection) connectionFactory.createQueueConnection();
            connected = true;
        } catch (Exception e) {
            connected = false;
        }
        return connected;
    }

    public static void main(String[] args) {
        new SendReceive().runTest();
    }

}

Answer 1

MQ v5.3 于 2002 年 11 月 29 日发布，自 2007 年 9 月 28 日（将近 9 年）起已停止支持。该版本可能与您的问题无关，但我强烈建议您迁移到受支持的 MQ 客户端版本。较新的 MQ 客户端版本可以连接到较旧的 MQ 队列管理器。您可以通过以下链接下载仅 Java 安装的 MQ 8.0 或 MQ 9.0 jar 文件：

• IBM MQ v8.0 Client
• IBM MQ v9.0 Client

---

我在一些旧线程上读到，当指定超时时，发送者和接收者在同一个会话中会导致问题。尝试为接收者添加另一个会话。

    private void runTest() {
        try {
            connect();
            connection.start();
            MQQueueSession session = (MQQueueSession) connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
            MQQueueSession session2 = (MQQueueSession) connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
            MQQueue queue = (MQQueue) session.createQueue("INBOUND_QUEUE");     /* values  replaced with correct values in deployment server */
            MQQueue queue2 = (MQQueue) session2.createQueue("OUTBOUND_QUEUE");  /* values  replaced with correct values in deployment server */
            MQQueueSender sender = (MQQueueSender) session.createSender(queue);     

            MQQueueReceiver receiver = (MQQueueReceiver) session2.createReceiver(queue2);

            //TextMessage message = session.createTextMessage("yesyesyes");
            String stt = "Test Message";        //

            TextMessage message = session.createTextMessage(stt);
            message.setJMSReplyTo(queue2);
            sender.send(message);
            System.out.println("Sent: " + message);

            Message msg1 = receiver.receive(5000);
            if(msg1!=null){
                String responseMsg = ((TextMessage) msg1).getText();
                System.out.println("Received: " + responseMsg);
            }else{
                System.out.println("Message received is null");
            }
        }catch(Exception e){
            System.out.println("Exception caught in program : " + e);
            e.printStackTrace();
        }
    }

---

尝试通过将以下内容添加到 java 应用程序的执行来获取 JMS 跟踪：

-DMQJMS_TRACE_LEVEL=base
-DMQJMS_TRACE_DIR=/tracedirectory

例如：java -DMQJMS_TRACE_LEVEL=base -DMQJMS_TRACE_DIR=/tracedirectory JavaApp

这应该会在您指定的目录中生成一个我认为以 .trc 结尾的文件。

您可以查看此内容是否有错误，这些错误可能有助于为您指明正确的方向。

---

建议：

尝试更改您的程序以强制它发送空白用户名：

connection = (MQQueueConnection) connectionFactory.createQueueConnection("", "");

在调用sender.send 后尝试关闭发件人

sender.close(); 

---

如果没有进一步的信息，很难确定原因。收集的信息越多越好。

Answer 2

这可能是一些与网络相关的配置问题，或者可能是 Windows 消息配置不正确。您可以考虑由 IBM 提供WebSphere MQ - Message Test Utility 以确保不存在此类系统或网络配置问题。