如何利用pymqi获取队列的连接IP地址及状态信息？

核心结论 #

pymqi本身没有直接提供获取连接到队列的IP地址的API，但可以通过MQ PCF（Programmable Command Format）命令结合pymqi实现。PCF是MQ的管理命令接口，能够查询队列的连接状态及关联的IP信息，完全可以满足你的监控需求。

实现步骤 #

1. 前置环境准备 #

确保目标队列管理器已开启命令服务器，且用于连接的用户拥有查询队列状态的权限（如inq权限）。

2. 用pymqi发送PCF查询请求 #

通过pymqi连接到MQ的管理命令队列，发送MQCMD_INQUIRE_Q_STATUS命令，指定查询队列的连接状态：

import pymqi

# 配置信息，替换为你的实际参数
QMGR_NAME = "YOUR_QMGR"
TARGET_QUEUE = "YOUR_TARGET_Q"
CMD_QUEUE = "SYSTEM.ADMIN.COMMAND.QUEUE"
REPLY_QUEUE = "SYSTEM.ADMIN.REPLY.QUEUE"

# 连接队列管理器
qmgr = pymqi.connect(QMGR_NAME, "", "")

# 初始化PCF执行器
pcf_exec = pymqi.PCFExecute(qmgr)

# 构造查询参数：指定目标队列、查询连接状态、返回连接名称字段
query_args = [
    (pymqi.MQC.MQCA_Q_NAME, TARGET_QUEUE),
    (pymqi.MQC.MQIACF_Q_STATUS_TYPE, pymqi.MQC.MQSTAT_CONNECTIONS),
    (pymqi.MQC.MQIACF_CONNECTION_ATTRS, pymqi.MQC.MQCA_CONNECTION_NAME)
]

try:
    # 发送查询并获取回复
    responses = pcf_exec.call(pymqi.CMFCMD_INQUIRE_Q_STATUS, query_args)
    
    # 解析回复中的IP地址
    connected_ips = []
    for resp in responses:
        conn_name = resp.get(pymqi.MQC.MQCA_CONNECTION_NAME)
        if conn_name:
            # 提取IP（格式通常为"TCP/IP(192.168.1.1)(12345)"，需根据实际格式调整）
            ip = conn_name.split('(')[1].split(')')[0]
            connected_ips.append(ip)
    
    print(f"当前连接到队列的IP列表: {connected_ips}")
finally:
    qmgr.disconnect()

3. 监控与切换逻辑实现 #

• 定期执行上述查询，记录有效消费者IP的最后在线时间
• 当某个预设的有效IP连续多次未出现在连接列表中，且断开时长达到阈值时，启动存根消费者（如建立空连接维持队列的消费者状态，或执行预设的消息处理逻辑）

注意事项 #

• 连接名称的格式可能因MQ版本、传输协议（TCP/IP、SSL等）略有差异，需根据实际返回值调整IP解析逻辑
• 控制查询频率，避免给队列管理器带来过多负载
• 存根消费者的切换逻辑需配合队列的消息处理策略，防止消息丢失或重复消费

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