IBMMQ消费TextMessage报JMSCMQ1049:1208(UTF-8)字符集转换错误

你的理解存在偏差：消息头的CodedCharSetId仅为生产端标注的字符集属性，不代表消息体实际字节完全符合该字符集的编码规范。你提供的amqsbcg输出中，消息体包含0xB3、0xDC这类不符合UTF-8编码规则的字节序列，IBM MQ JMS客户端调用TextMessage.getText()时，默认对不可映射/非法字节的处理策略为REPORT（直接抛出异常），因此触发你看到的JMSCMQ1049错误。
生产端的问题本质是错误地将包含非法文本字节的内容封装为TextMessage发送，还标注了CCSID=1208，但实际内容不符合UTF-8规范。

由于TextMessage和BytesMessage为JMS中平级的消息类型，不存在继承关系，直接强转必然抛出ClassCastException，可以采用以下两种方案解决：

方案1：修改MQ客户端转换策略，异常自动替换 #

在MQ连接工厂或目标队列的配置中添加以下两个属性，将非法字节的处理策略从抛出异常改为自动替换：

• clientReorderUnmappableAction 设置为 REPLACE
• clientUnmappableReplacement 设置为替换字符的ASCII值，默认可填63（对应问号?）
  修改后直接调用原有message.getText()方法即可，不需要改动其他业务逻辑，适合不需要保留原始非法字节的场景。

方案2：获取原始字节自行控制编码转换 #

IBM MQ的JMSTextMessage实现类原生支持获取原始消息字节，可以绕过客户端默认的严格转换逻辑，自行处理编码：

import java.nio.ByteBuffer;
import java.nio.charset.Charset;
import java.nio.charset.CodingErrorAction;
import com.ibm.jms.JMSTextMessage;
import com.ibm.msg.client.wmq.common.WMQConstants;

// 原有接收逻辑修改为不直接强转TextMessage
Message message = queueReceiver.receive(200);
if (message != null) {
    if (message instanceof JMSTextMessage) {
        JMSTextMessage textMsg = (JMSTextMessage) message;
        // 读取原始字节
        byte[] rawBytes = textMsg.getBytes();
        // 获取消息标注的字符集
        String codePage = textMsg.getStringProperty(WMQConstants.JMS_IBM_CHARACTER_SET);
        // 自定义编码转换规则，遇到非法字符自动替换
        String textString = Charset.forName(codePage)
                .newDecoder()
                .onMalformedInput(CodingErrorAction.REPLACE)
                .onUnmappableCharacter(CodingErrorAction.REPLACE)
                .decode(ByteBuffer.wrap(rawBytes))
                .toString();
        // 原有落盘逻辑不变
        messageFile = messageTypeToListenerMapping.get(type).generateMessageNameAndWriteToDisk(textString, source, saveDirectory);
    }
} else {
    break;
}

该方案灵活性更高，也可以选择直接将原始字节写入磁盘，适合需要完整保留消息内容的场景。

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