如何使用pymqi配置MQ队列管理器的CCSID以解决编码问题

这个问题的核心是你的MQ客户端默认使用了CCSID 850（西欧DOS编码），但你发送的是UTF-8编码的消息，两者不匹配导致特殊字符（比如"Ó"）被错误解码。要修复这个问题，我们需要在pymqi的连接配置和消息描述符中明确指定UTF-8对应的CCSID值1208。

具体修改步骤 #

1. 在通道定义（CD）中设置客户端CCSID #

在初始化MQManager类时，给pymqi.CD对象添加CCSID配置，告诉MQ管理器你的客户端使用UTF-8编码：

def __init__(self):
    self.queue_manager = config.queue_manager
    self.channel = config.channel
    self.port = config.port
    self.host = config.host
    self.conn_info = config.conn_info

    self.queue_request_name = config.queue_request_name
    self.queue_response_name = config.queue_response_name
    cd = pymqi.CD()
    cd.ChannelName = self.channel
    cd.ConnectionName = self.conn_info
    cd.ChannelType = pymqi.CMQC.MQCHT_CLNTCONN
    cd.TransportType = pymqi.CMQC.MQXPT_TCP
    # 添加这一行：指定客户端CCSID为UTF-8对应的1208
    cd.CCSID = 1208
    self.qmgr = pymqi.QueueManager(None)
    self.qmgr.connect_with_options(self.queue_manager, opts=pymqi.CMQC.MQCNO_HANDLE_SHARE_NO_BLOCK, cd=cd)

2. 在发送/接收消息的描述符（MD）中指定消息CCSID #

发送消息时，需要在request_md中明确设置消息的CCSID为1208，确保MQ正确识别消息的编码格式；接收消息时同样配置，避免响应消息乱码：

def send_message(self, str_xml_message):
    # set message descriptor
    request_md = pymqi.MD()
    request_md.ReplyToQ = self.queue_response_name
    request_md.Format = pymqi.CMQC.MQFMT_STRING
    # 添加这一行：指定消息使用UTF-8编码（CCSID 1208）
    request_md.CCSID = 1208
    queue_request = pymqi.Queue(self.qmgr, self.queue_request_name)
    # 保持UTF-8编码的发送逻辑不变
    queue_request.put(str_xml_message.encode("UTF-8"), request_md)
    queue_request.close()
    
    # Set up message descriptor for get.
    response_md = pymqi.MD()
    response_md['CorrelId'] = request_md['MsgId']
    # 接收消息时也指定CCSID，确保解码正确
    response_md.CCSID = 1208
    gmo = pymqi.GMO()
    gmo.Options = pymqi.CMQC.MQGMO_WAIT | pymqi.CMQC.MQGMO_FAIL_IF_QUIESCING
    gmo.WaitInterval = 5000 # 5 seconds
    queue_response = pymqi.Queue(self.qmgr, self.queue_response_name)
    message = queue_response.get_no_rfh2(None, response_md, gmo)
    queue_response.close()
    # 显式用UTF-8解码bytes类型的消息，避免依赖系统默认编码
    return message.decode("UTF-8")

额外注意事项 #

• 确保MQ管理器端的队列或通道没有强制指定CCSID值，如果服务器端配置了固定CCSID，客户端的设置可能会被覆盖，需要联系MQ管理员确认配置。
• 验证服务端处理消息时也使用CCSID 1208（UTF-8）进行解码和编码，否则返回的响应消息也可能出现乱码。
• 之前用str(message)转换接收消息的方式不够严谨，因为message是bytes类型，直接转字符串会依赖系统默认编码，显式用message.decode("UTF-8")能确保解码逻辑统一。

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