Python 如何读取 RabbitMQ 消息头中的自定义参数进行业务权限校验？-Python教程-PHP中文网

必须用 properties.headers 取，不能从 body 解析，因 headers 是 AMQP 协议层元数据，与 body 物理分离；properties.headers 为 dict 或 None，需判空；auto_ack 必须为 False 以支持校验后手动 ack/nack；且须结合 vhost 隔离防伪造。

python 如何读取 rabbitmq 消息头中的自定义参数进行业务权限校验？

必须用 properties.headers 取，不能从 body 解析，也不能依赖 method.routing_key 或 method.exchange 做权限判断。

为什么不能从 body 里解析 header 信息

消息头（headers）是 AMQP 协议层的元数据，由生产者在发布时通过 pika.BasicProperties 显式设置，与消息体（body）物理分离。RabbitMQ 不会把 headers 写进 body，consumer 收到的 body 是纯字节流，里面不包含任何 header 字段。

常见错误：收到消息后对 body 做 json.loads()，再试图从中读 "tenant_id" 或 "role" —— 这类字段如果真在 body 里，是业务层自己塞的，不是 AMQP header，不可信
header 更安全：它无法被下游 consumer 伪造或篡改（除非有权限直接调用 basic_publish），适合做初始准入校验
性能更好：不用反序列化整个 body 就能拿到权限标识

`properties.headers` 的实际结构和空值处理

回调函数签名中的 properties 是 pika.spec.BasicProperties 实例，其 headers 属性是一个 dict 或 None。它不是 always-dict，必须显式判空。

生产者没设 headers → properties.headers 是 None，不是 {}
生产者设了空 dict → properties.headers 是 {}
header key 默认区分大小写，比如 "X-User-ID" 和 "x-user-id" 是两个键
建议统一用小写 key，消费端用 .get("user_id") 而非 ["user_id"] 防 KeyError

示例校验逻辑：

def callback(ch, method, properties, body):
    headers = properties.headers or {}
    tenant_id = headers.get("tenant_id")
    role = headers.get("role")
<pre class="brush:php;toolbar:false;">if not tenant_id or role not in ["admin", "viewer"]:
    ch.basic_nack(delivery_tag=method.delivery_tag, requeue=False)
    return

# 后续业务处理...