我正在处理的应用程序需要与远程位置的 IBM MQ 服务器通信。我们目前有一个使用 Activity MQ 的工作系统，它使用代理和连接到此远程 IBM MQ 服务器的网桥，并且运行良好。

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

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

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

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

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

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

我的疑惑如下。

1. 为此，我所做的只是将 IBM MQ 客户端 jar 复制到应用程序中，并使用代码将消息发送到远程 MQ。我没有安装任何其他应用程序。这样的系统会工作吗？还是应该始终有一些中间程序，例如 Activity 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();
    }

}

最佳答案

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

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

    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(); 

没有更多信息，很难确定原因。您收集的信息越多越好。

关于java - 在应用程序中使用 IBM MQ 客户端 jar 连接到 IBM MQ 服务器时无响应，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/42370717/