Node.js客户端连接IBM MQ可发送消息但接收消息挂起（已授权）

我之前在使用ibmmq库对接Docker环境的IBM MQ时，也碰到过几乎一模一样的问题，结合你的代码和描述，帮你梳理几个关键问题点和修复方案：

可能的原因分析 #

1. 隐式消息匹配限制：虽然你每次都新建了MQMD对象，但有时候IBM MQ会隐式保留上一次的消息ID过滤规则，导致只匹配特定ID的消息；
2. GMO选项缺失关键配置：缺少消息格式转换、属性忽略等配置，可能导致MQ无法正确触发Get回调；
3. 资源释放逻辑不严谨：原代码中资源关闭和断开连接的时机不合理，不仅容易泄漏资源，还可能干扰回调的正常执行。

修复后的代码 #

function receiveFromMQ() {
  return new Promise((resolve, reject) => {
    const MQC = mq.MQC; // 显式引用MQC常量，避免隐式引用问题
    const cno = new mq.MQCNO();
    cno.Options = MQC.MQCNO_CLIENT_BINDING;
    const cd = new mq.MQCD();
    cd.ConnectionName = "localhost(1414)";
    cd.ChannelName = "DEV.APP.SVRCONN";
    cno.ClientConn = cd;

    mq.Connx("QM1", cno, (connErr, hConn) => {
      if (connErr) return reject(connErr);

      const od = new mq.MQOD();
      od.ObjectName = "MY.DEV.QUEUE.1";
      od.ObjectType = MQC.MQOT_Q;

      mq.Open(hConn, od, MQC.MQOO_INPUT_SHARED, (openErr, hObj) => {
        if (openErr) {
          mq.Disc(hConn); // Open失败时主动断开连接，避免资源泄漏
          return reject(openErr);
        }

        const md = new mq.MQMD();
        // 显式声明匹配所有消息，彻底避免ID过滤问题
        md.MsgId = MQC.MQMI_NONE;
        md.CorrelId = MQC.MQCI_NONE;

        const gmo = new mq.MQGMO();
        // 补充关键选项，解决静默挂起问题
        gmo.Options = MQC.MQGMO_NO_SYNCPOINT 
          | MQC.MQGMO_WAIT 
          | MQC.MQGMO_CONVERT // 自动转换消息格式为字符串
          | MQC.MQGMO_NO_PROPERTIES // 忽略消息属性，减少处理开销
          | MQC.MQGMO_FAIL_IF_QUIESCING; // 队列管理器停止时立即返回错误
        gmo.WaitInterval = 3000; // 3秒超时，避免无限等待

        mq.Get(hObj, md, gmo, (getErr, data) => {
          // 统一资源清理逻辑，确保无论成功失败都释放资源
          const cleanup = () => {
            mq.Close(hObj, 0, () => mq.Disc(hConn));
          };

          if (getErr) {
            cleanup();
            if (getErr.mqrc === MQC.MQRC_NO_MSG_AVAILABLE) {
              resolve(null);
            } else {
              reject(getErr);
            }
            return;
          }

          const message = data.toString();
          cleanup();
          resolve(message);
        });
      });
    });
  });
}

关键修改说明 #

• 显式设置消息匹配规则：通过md.MsgId = MQC.MQMI_NONE和md.CorrelId = MQC.MQCI_NONE，强制获取队列中任意消息，彻底解决隐式ID过滤导致的“找不到消息”问题；
• 增强GMO选项：
  • MQGMO_CONVERT：自动将MQ内部格式的消息转换为客户端可识别的字符串，避免因编码/格式不匹配导致的静默挂起；
  • MQGMO_NO_PROPERTIES：忽略消息的附加属性，减少不必要的处理逻辑，避免属性解析异常；
  • MQGMO_FAIL_IF_QUIESCING：当队列管理器正在停止时，立即返回错误，避免无意义的等待；
• 优化资源释放：将队列关闭和连接断开封装为统一的清理函数，确保无论Get操作成功或失败，都能正确释放资源；
• 补充Open失败的连接断开：原代码中Open失败时仅reject但未断开已建立的连接，容易导致连接池耗尽。

额外排查建议 #

1. 登录Docker MQ的Web控制台（默认端口9443），查看MY.DEV.QUEUE.1的队列深度和消息状态，确认消息确实处于“可获取”状态；
2. 进入Docker容器，查看队列管理器的错误日志（路径：/var/mqm/qmgrs/QM1/errors/），排查是否有Get操作的相关错误记录；
3. 使用MQ自带的工具手动获取消息：在容器内执行runmqsc QM1，然后输入GET(MY.DEV.QUEUE.1)，验证队列本身是否能正常返回消息。

内容来源于stack exchange