Java版IBM MQ请求端接收动态队列消息内容全为0的问题

问题场景 #

请求端通过普通队列向响应端发送消息，指定自身创建的动态队列作为回复队列。响应端能正常接收消息并写入回复队列，且响应端读取该队列消息内容正常，但请求端从回复队列取消息时，消息体全为0。使用Java的com.ibm.mq.allclient-9.2.2.0.jar开发出现此问题，Node.js的ibmmq库实现相同逻辑则无异常。

可能的故障原因 #

• 消息读取时未处理有效字节长度：请求端读取消息时，若初始化了固定长度的字节数组，调用MQMessage.readBytes(byte[] b)后直接使用整个数组，未根据方法返回的实际读取字节数截取有效内容，导致数组未被覆盖的部分保留初始的0值。
• 消息属性配置不匹配：响应端发送回复消息时，未显式设置与请求端一致的字符集、消息格式或消息类型属性，Java客户端对这些属性的默认处理与Node.js库不同，导致解析时消息体异常。
• 动态队列属性/打开选项不兼容：请求端创建动态队列时的MQOD参数、队列打开选项（如MQOO_INPUT_SHARED等）与响应端写入时的配置不匹配，导致消息存储时出现异常，Node.js库可能自动兼容了这些配置差异。
• 响应端消息写入流操作错误：响应端写入消息体时，存在流位置未重置、写入后未刷新/关闭流等问题，导致实际写入内容为空，仅填充了0字节占位。
• Java客户端版本bug：com.ibm.mq.allclient-9.2.2.0.jar在动态队列消息传递场景下存在字节处理bug，而Node.js的ibmmq库使用了不同的底层实现或已修复该问题。

排查修复建议 #

• 修正请求端消息读取逻辑：根据readBytes返回的实际长度截取有效内容，示例代码：

  byte[] buffer = new byte[1024];
  int actualLen = message.readBytes(buffer);
  if (actualLen > 0) {
      byte[] validMsgBody = Arrays.copyOf(buffer, actualLen);
      // 处理有效消息体
  }
  

• 统一消息属性设置：响应端发送回复时显式配置匹配的属性，示例：

  MQMessage replyMsg = new MQMessage();
  replyMsg.characterSet = 1208; // UTF-8编码
  replyMsg.format = MQC.MQFMT_STRING;
  replyMsg.messageType = MQC.MQMT_REPLY;
  

• 对齐动态队列配置：检查请求端创建动态队列的MQOD参数（如DynamicQName、ObjectType），以及响应端打开队列的选项，确保读写配置兼容。
• 排查响应端写入逻辑：确认消息体写入操作无异常，比如使用writeString/writeBytes后，消息体长度与实际内容一致，流操作已正确完成。

内容的提问来源于stack exchange，提问作者hellerim