如何在pymqi中基于MsgId或CorrelId浏览队列消息

你之前的匹配方案失效核心原因是MsgId赋值方式错误：直接将十六进制字符串转为字节对象（b'414d51...'），但IBM MQ的MsgId是24字节二进制数据，需将十六进制字符串解码为对应二进制字节，而非把字符串本身转成字节。同时循环遍历的方式会在消息量大时性能极差，因为完全依赖本地逐条匹配，浪费了MQ服务器的原生匹配能力。

解决方案核心要点 #

• 将十六进制格式的MsgId/CorrelId通过bytes.fromhex()解码为二进制字节数组，赋值给md.MsgId/md.CorrelId
• 正确设置gmo.MatchOptions为对应规则（MQMO_MATCH_MSG_ID或MQMO_MATCH_CORREL_ID）
• 确保gmo.Version和md.Version设置为支持匹配选项的版本（如MQGMO_VERSION_2）
• 队列打开时使用MQOO_BROWSE选项保持浏览模式，不删除消息

按MsgId匹配的完整代码 #

import pymqi

queue_manager = 'QM1'
channel = 'DEV.APP.SVRCONN'
host = '127.0.0.1'
port = '1414'
queue_name = 'TEST.1'
conn_info = '%s(%s)' % (host, port)

# 连接队列管理器
qmgr = pymqi.connect(queue_manager, channel, conn_info)

# 以浏览模式打开队列
queue = pymqi.Queue(qmgr, queue_name, pymqi.CMQC.MQOO_BROWSE)

# 初始化获取消息选项（GMO）
gmo = pymqi.GMO()
gmo.Version = pymqi.CMQC.MQGMO_VERSION_2  # 必须设置支持MatchOptions的版本
gmo.MatchOptions = pymqi.CMQC.MQMO_MATCH_MSG_ID  # 指定按MsgId匹配
gmo.Options = pymqi.CMQC.MQGMO_WAIT | pymqi.CMQC.MQGMO_NO_PROPERTIES
gmo.WaitInterval = 5000  # 无匹配消息时等待5秒

# 初始化消息描述符（MD）
md = pymqi.MD()
md.Version = pymqi.CMQC.MQMD_VERSION_2  # 对应GMO版本
md.Format = pymqi.CMQC.MQFMT_STRING
# 将十六进制MsgId解码为二进制字节数组
target_msg_id_hex = '414d51204e41544d333030202020202817d9ff650a742f22'
md.MsgId = bytes.fromhex(target_msg_id_hex)

try:
    # 由MQ服务器直接返回匹配的消息，无需本地遍历
    message = queue.get(None, md, gmo)
    print(f"匹配到的消息内容: {message}")
    print(f"消息MsgId（十六进制）: {md.MsgId.hex()}")
except pymqi.MQMIError as e:
    if e.comp == pymqi.CMQC.MQCC_FAILED and e.reason == pymqi.CMQC.MQRC_NO_MSG_AVAILABLE:
        print("未找到匹配MsgId的消息")
    else:
        raise e

# 关闭资源
queue.close()
qmgr.disconnect()

按CorrelId匹配的代码示例 #

只需调整匹配规则和赋值字段即可：

# ... 连接队列管理器、打开队列的代码同上 ...

# 修改匹配规则为CorrelId
gmo.MatchOptions = pymqi.CMQC.MQMO_MATCH_CORREL_ID

# 将十六进制CorrelId解码为二进制字节数组
target_correl_id_hex = "你的CorrelId十六进制字符串"
md.CorrelId = bytes.fromhex(target_correl_id_hex)

try:
    message = queue.get(None, md, gmo)
    print(f"匹配到的消息内容: {message}")
    print(f"消息CorrelId（十六进制）: {md.CorrelId.hex()}")
except pymqi.MQMIError as e:
    if e.comp == pymqi.CMQC.MQCC_FAILED and e.reason == pymqi.CMQC.MQRC_NO_MSG_AVAILABLE:
        print("未找到匹配CorrelId的消息")
    else:
        raise e

# ... 关闭资源的代码同上 ...

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