必须用 properties.headers 取，不能从 body 解析，因 headers 是 AMQP 协议层元数据，与 body 物理分离；properties.headers 为 dict 或 None，需判空；auto_ack 必须为 False 以支持校验后手动 ack/nack；且须结合 vhost 隔离防伪造。
必须用 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
示例校验逻辑：
立即学习“Python免费学习笔记（深入）”；
Claw Code Suite (Python-Only Edition)
下载
仅使用 Python 将 Claw Code 虚拟化框架与 OpenClaw 集成，提供 184 种工具和 200 多条命令，用于安全分析和代码质量...
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
# 后续业务处理...
auto_ack=False 是 header 权限校验的前提
如果用了 auto_ack=True，消息一送达就自动确认，你根本来不及检查 headers 就已从队列移除。一旦校验失败，消息就丢了，无法重试或进死信队列。
- 必须设
auto_ack=False，并在回调里显式调用ch.basic_ack()或ch.basic_nack() -
basic_nack(..., requeue=False)才能确保非法消息不重入队列，避免无限循环消费 - 若需审计，可在
basic_nack前发一条日志，记录tenant_id、role、method.routing_key
权限字段命名和 vhost 隔离要配合使用
只靠 headers 校验不够，必须结合 RabbitMQ 的 vhost 和用户权限体系。否则攻击者只要连上 broker 就能伪造任意 headers。
- 每个租户分配独立 vhost，如
vhost="t-123"，并限制该 vhost 下用户只能 publish/consume 自己的 queue - header 中的
tenant_id必须与当前连接使用的 vhost 一致，否则拒绝 - 不要在 headers 里传密码、token 等敏感凭证，只传不可变标识（如 UUID、短 ID）
- 如果业务要求更细粒度控制（如按资源 ID 授权），应把校验逻辑下沉到业务代码，header 只做第一道门禁
真正容易被忽略的是：header 校验必须和 vhost 级隔离联动，单独用 headers 做权限等于裸奔。
