如何使用MessageID从ActiveMQ队列获取消息？（Python实现）

你的原代码失败的核心原因是：STOMP协议的SUBSCRIBE操作不支持通过指定message-id来过滤或检索特定消息，你传入的conf={'message-id': MsgID}参数不符合STOMP规范，服务器无法识别该参数，因此无法达到预期效果。

以下是两种可行的替代方案：

方案一：订阅后过滤目标MessageID #

正常订阅目标队列，在消息回调中检查每一条消息的message-id，匹配目标ID再处理，不匹配则确认后忽略：

import stomp

class TargetMessageListener(stomp.ConnectionListener):
    def __init__(self, target_msg_id):
        self.target_msg_id = target_msg_id

    def on_message(self, headers, message):
        current_msg_id = headers.get('message-id')
        if current_msg_id == self.target_msg_id:
            # 找到目标消息，执行处理逻辑
            print(f"匹配到目标消息，内容：{message}")
            # 手动确认消息（对应ack='client'模式）
            conn.ack(current_msg_id, '1')
            # 完成后可取消订阅
            conn.unsubscribe('1')
        else:
            # 非目标消息直接确认，避免队列堆积
            conn.ack(current_msg_id, '1')

# 初始化连接
conn = stomp.Connection([('你的STOMP服务器地址', 端口号)])
conn.connect('用户名', '密码', wait=True)

# 初始化监听器并绑定
target_listener = TargetMessageListener(MsgID)
conn.set_listener('', target_listener)

# 正常订阅队列，无需额外conf参数
conn.subscribe(destination=Qname, id='1', ack='client')

# 保持连接等待消息（实际项目可根据需求调整）
while True:
    pass

方案二：请求-响应模式（主动触发场景） #

如果是你主动发送请求后需要获取对应响应，更推荐用correlation-id+临时队列的方式，而非直接按message-id检索：

import stomp
import uuid
import time

class ResponseListener(stomp.ConnectionListener):
    def __init__(self, target_corr_id):
        self.target_corr_id = target_corr_id
        self.response = None

    def on_message(self, headers, message):
        if headers.get('correlation-id') == self.target_corr_id:
            self.response = message
            # 确认响应消息
            conn.ack(headers['message-id'], '2')
            conn.unsubscribe('2')

# 初始化连接
conn = stomp.Connection([('你的STOMP服务器地址', 端口号)])
conn.connect('用户名', '密码', wait=True)

# 创建临时队列用于接收响应
reply_queue = '/temp-queue/unique-response-queue'
conn.subscribe(destination=reply_queue, id='2', ack='client')

# 生成唯一关联ID
correlation_id = str(uuid.uuid4())

# 发送请求，指定回复队列和关联ID
conn.send(
    destination=Qname,
    body="你的请求内容",
    headers={
        'reply-to': reply_queue,
        'correlation-id': correlation_id
    }
)

# 绑定监听器等待响应
response_listener = ResponseListener(correlation_id)
conn.set_listener('response', response_listener)

# 等待响应（实际可使用事件锁替代循环）
while response_listener.response is None:
    time.sleep(0.1)

print(f"收到对应响应：{response_listener.response}")
conn.disconnect()

注意：如果你的队列是持久化队列，且目标消息已经存在于队列中，方案一可以正常获取；如果是临时消息或需要精准关联请求响应，方案二更合适。

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