如何解决 - MQJE001：发生 MQException：完成代码 2，原因 2009

Question

连接到 MQQueueManager 时出现异常。异常读取 - MQException：MQJE001：发生 MQException：完成代码 2，原因 2009 MQJE016：MQ 队列管理器在连接期间立即关闭通道 关闭原因 = 2009。下面是我将消息推送到队列的代码。

@SuppressWarnings("unchecked")
public boolean postMessage(String mqMessage, String correlationId) throws TradeException, MQException {
    String logStr = TradeUtil.getLoggerPrefix(this.getClass().getSimpleName(),
            Thread.currentThread().getStackTrace()[1].getMethodName(), "");
    boolean result = false;

    MQQueueManager queueManager = null;

    try {
        
        MQEnvironment.hostname = ConfigFileLoader.getProperty("MQ_HOSTNAME");
        MQEnvironment.channel = ConfigFileLoader.getProperty("MQ_CHANNEL");
        MQEnvironment.port = Integer.parseInt(ConfigFileLoader.getProperty("MQ_PORT"));

        tradeLogger.info(logStr + "MQ HOST NAME : " + MQEnvironment.hostname + " MQ CHANNEL : "
                + MQEnvironment.channel + " MQ PORT : " + MQEnvironment.port);
        try {
            queueManager = new MQQueueManager(ConfigFileLoader.getProperty("MQ_QUEUE_MANAGER"));
        } catch (MQException e) {
            tradeLogger.info("queueManager is Busy, try after some time");
            Thread.sleep(1000 * 60);
            if(maxCount < 3) {
                maxCount += 1;
                postMessage(mqMessage, correlationId);  
            }
        }
        
        tradeLogger.info(logStr + "MQhostname : " + queueManager + ConfigFileLoader.getProperty("MQ_QUEUE_MANAGER"));

        int openOptions = MQC.MQOO_OUTPUT + MQC.MQOO_INPUT_AS_Q_DEF;
        MQQueue queue = queueManager.accessQueue(ConfigFileLoader.getProperty("MQ_INPUT_QUEUE_NAME"), openOptions);
        tradeLogger.info("INPUT QUEUE NAME : " + queue + ConfigFileLoader.getProperty("MQ_INPUT_QUEUE_NAME"));

        if (queueManager.isConnected()) {
            tradeLogger.info("queue manager is connected!");
            MQPutMessageOptions mqPutMessageOptions = new MQPutMessageOptions();
            MQMessage message = new MQMessage();
            message.format = MQC.MQFMT_STRING;
            message.correlationId = correlationId.getBytes();
            message.writeString(mqMessage);
            queue.put(message, mqPutMessageOptions);

            tradeLogger.info(logStr + "POSTED MESSAGE : " + mqMessage);
            result = true;

            queue.close();

            tradeLogger.info("queue is closed.");

        } else {
            tradeLogger.error("unable to connect to Queue");
            throw new TradeException("Unable to connect to Queue");
        }

    } catch (MQException e) {
        tradeLogger.error(logStr + " MQException : " + e.getMessage());
        JSONObject errorJSON = new JSONObject();
        errorJSON.put("errorDesc", e);
        throw new TradeException(ResponseStatus.failure, 404,
                "Unable to post message in MQ. Please try after sometime.", errorJSON);
    } catch (Exception e) {
        tradeLogger.error(logStr + " Exception : " + e.getMessage());
        JSONObject errorJSON = new JSONObject();
        errorJSON.put("errorDesc", e);
        throw new TradeException(ResponseStatus.failure, 404,
                "Unable to post message in MQ due to some techical error. Please contact administrator.",
                errorJSON);
    } finally {
        if (null != queueManager) {
            queueManager.disconnect();
            tradeLogger.info("queueManager is disconnected!");
        }
    }
    return result;
}

此问题在手动重新启动队列管理器后得到解决。另外，我在某处读到 MQQueueManager() 是同步的。是否有其他线程可能正在访问此队列管理器以建立导致此异常的连接？

Answer 1

这不是你得到的 2009 年的答案。我有你的代码的简化版本

@SuppressWarnings("unchecked")
public boolean postMessage(String mqMessage, String correlationId) throws MQException {
    boolean result = false;

    MQQueueManager queueManager = null;
    MQQueue queue = null;
    MQEnvironment.hostname = "localhost";
    MQEnvironment.channel = "SVRCONN_CHN";
    MQEnvironment.port = 1414;

    try {
        queueManager = new MQQueueManager("QM1");
        int openOptions = MQC.MQOO_OUTPUT; // Just open for putting message
        queue = queueManager.accessQueue("DESTQ", openOptions);
        MQPutMessageOptions mqPutMessageOptions = new MQPutMessageOptions();
        MQMessage message = new MQMessage();
        message.format = MQC.MQFMT_STRING;
        message.correlationId = correlationId.getBytes();
        message.writeString(mqMessage);
        queue.put(message, mqPutMessageOptions);
        result = true;
    } catch (MQException e) {
        e.printStackTrace();                
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    } finally {
        if (queue != null)
            queue.close();

        if (queueManager != null)
            queueManager.disconnect(); // Call disconnect
    }
    return result;
}

Answer 2

首先，不要使用 MQEnvironment 类，因为它不是线程安全的。我希望 IBM 会弃用该类。您应该将您的连接信息放在一个 Hashtable 中，并将 Hashtable 传递给 MQQueueManager 对象。

Java 示例：

Hashtable<String, Object> mqht = new Hashtable<String, Object>();

mqht.put(CMQC.CHANNEL_PROPERTY, ConfigFileLoader.getProperty("MQ_CHANNEL"));
mqht.put(CMQC.HOST_NAME_PROPERTY, ConfigFileLoader.getProperty("MQ_HOSTNAME"));
mqht.put(CMQC.PORT_PROPERTY, Integer.parseInt(ConfigFileLoader.getProperty("MQ_PORT"));
mqht.put(CMQC.USER_ID_PROPERTY, ConfigFileLoader.getProperty("MQ_USERID")));
mqht.put(CMQC.PASSWORD_PROPERTY, ConfigFileLoader.getProperty("MQ_PASSWORD")));

queueManager = new MQQueueManager(ConfigFileLoader.getProperty("MQ_QUEUE_MANAGER"), mqht);

C# .NET 示例：

Hashtable mqht = new Hashtable();

mqht.Add(MQC.CHANNEL_PROPERTY, ConfigFileLoader.getProperty("MQ_CHANNEL"));
mqht.Add(MQC.HOST_NAME_PROPERTY, ConfigFileLoader.getProperty("MQ_HOSTNAME"));
mqht.Add(MQC.PORT_PROPERTY, System.Int32.Parse(ConfigFileLoader.getProperty("MQ_PORT"));
mqht.Add(MQC.USER_ID_PROPERTY, ConfigFileLoader.getProperty("MQ_USERID")));
mqht.Add(MQC.PASSWORD_PROPERTY, ConfigFileLoader.getProperty("MQ_PASSWORD")));

mqht.Add(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES_MANAGED);

queueManager = new MQQueueManager(ConfigFileLoader.getProperty("MQ_QUEUE_MANAGER"), mqht);

此外，为了获得适当的安全性，您应该为与队列管理器的连接设置用户 ID 和密码。

最后，请确保按照 Shashi 在其代码示例中的说明关闭所有打开的队列。