C#对接IBM WMQ如何处理RFH2头并正确读取MessageId

你遇到的问题来自三个核心错误，和RFH2头本身没有直接关系：

• MessageId不属于文本编码存储字段：IBM WMQ的MessageId是固定24字节的二进制标识符，从来不是用UTF8/ASCII等文本编码存储的，直接用文本编码转换必然出现乱码。
• 扩展方法调用语法错误：你写的queueMessage.MessageId.ByteArrayToString没有加括号执行方法，C#中不加括号会直接返回方法委托对象，所以输出了System.Func'1[System.String]。
• RFH2头识别逻辑失效：你在调用Get方法前手动给queueMessage.Format赋值为MQC.MQFMT_STRING，会覆盖MQ返回的消息原生格式字段，永远无法识别到RFH2头。

1. MessageId正确读取方式 #

24字节的MessageId标准可读格式为十六进制字符串，修正调用语法即可：

// 必须加()执行扩展方法，不能直接写方法名
string messageIdHex = queueMessage.MessageId.ByteArrayToString();
_logger.LogInfo(LogStatus.InProgress, $"Message ID: {messageIdHex}");

// 扩展方法可保留，增加空判断更稳妥
public static string ByteArrayToString(this byte[] ba)
{
    if (ba == null || ba.Length == 0) return string.Empty;
    return BitConverter.ToString(ba).Replace("-", "");
}

如果需要和IBM MQ控制台显示格式对齐，可在生成的十六进制字符串前加AMQ 前缀，绝大多数业务场景直接使用无分隔十六进制串即可。

2. RFH2头正确处理逻辑 #

RFH2是MQ的标准规则头，当消息携带RFH2头时，MQ回填的queueMessage.Format值为MQC.MQFMT_RF_HEADER_2，你可以选择让MQ自动剥离头结构，也可以手动读取头内容后再取消息体，修正后的消费代码片段如下：

try
{
    MQMessage queueMessage;
    MQGetMessageOptions queueGetMessageOptions;
    string message = string.Empty;
    queueMessage = new MQMessage();
    // 删掉手动设置Format的代码，该字段由MQ在Get后回填，预设值会覆盖真实结果
    queueGetMessageOptions = new MQGetMessageOptions { WaitInterval = _appSettings.MqProperties.WaitIntervalMs };
    queueGetMessageOptions.Options |= MQC.MQGMO_WAIT;
    queueGetMessageOptions.Options |= MQC.MQGMO_SYNCPOINT;
    // 加该选项后MQ会自动解析RFH2头为消息属性，直接返回消息体，无需手动解析头
    queueGetMessageOptions.Options |= MQC.MQGMO_PROPERTIES_IN_HANDLE;

    queue.Get(queueMessage, queueGetMessageOptions);

    // 如果需要手动读取RFH2头内容，打开下面的注释即可
    // if (queueMessage.Format == MQC.MQFMT_RF_HEADER_2)
    // {
    //     MQRFH2 rfh2Header = new MQRFH2(queueMessage);
    //     // 可通过rfh2Header读取自定义文件夹、主题等头属性
    //     // 读取完成后指针会自动偏移到消息体起始位置
    // }

    // 读完头后再读取实际消息体
    if (queueMessage.DataLength > 0)
    {
        // 用DataLength读剩余的消息体长度，不要用原始MessageLength，避免把头内容读入正文
        message = queueMessage.ReadString(queueMessage.DataLength);
        _logger.LogInfo(LogStatus.InProgress, $"Message: {message}.");
        string msgId = queueMessage.MessageId.ByteArrayToString();
        _logger.LogInfo(LogStatus.InProgress, $"Message ID length: {queueMessage.MessageId.Length}, MessageId: {msgId}");

        await _messageConsumer.ConsumeMessage(message, msgId);
    }
    else
    {
        _logger.LogInfo(LogStatus.InProgress, $"INVALID MESSAGE. Message Length {queueMessage.MessageLength}");
    }
}
catch (MQException mqex)
{
    // 原有异常处理逻辑保持不变
    if (mqex.Reason == MQC.MQRC_NO_MSG_AVAILABLE)
    {
        _logConstants.InitializeCorrelationIdAndKeysForEachRun();
        _logConstants.InitializeLoggerKeys(null, null);
        _logger.LogInfo(LogStatus.InProgress, $"{mqex.ReasonCode} {mqex.Message} CurrentDepth: {queue.CurrentDepth}. MaximumDepth {queue.MaximumDepth}");
    }
    else if (mqex.Reason == MQC.MQRC_Q_MGR_STOPPING)
    {
        _logger.LogError(
            LogErrors.ErrorWhileConsumingMsgFromIBMMQ,
            LogStatus.Failed,
            "IBM MQ Consumer Error",
            $" Error in Consuming the message from MQ. Making the thread sleep for one minute");

        await Task.Delay(60000, cancellationToken);
    }
    else
    {
        _logger.LogError(
            LogErrors.ErrorWhileConsumingMsgFromIBMMQ,
            LogStatus.Failed,
            "IBM MQ Consumer Error",
            $" Error in Consuming the Message from MQ {mqex.Reason} {mqex.Message} {mqex.StackTrace}");

        await Task.Delay(60000, cancellationToken);
        queueManager = null;
        queue = null;
    }
}

• 所有MQ的Id类字段（MessageId、CorrelationId、GroupId等）都是二进制字节数组，永远不要用文本编码转换，统一转十六进制字符串才是标准可读格式。
• 读取带结构头（RFH1/RFH2、死信头、传输头）的消息时，必须先读取头结构，再读取消息体，直接读取全量MessageLength会把头的二进制内容当成正文，导致消息乱码。
• 如果不需要读取RFH2头内的自定义属性，保留MQC.MQGMO_PROPERTIES_IN_HANDLE选项即可，不需要手动处理头结构，能大幅简化代码。

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