RabbitMQ Headers绑定异常：消息误路由至所有绑定队列求助

核心错误1：Exchange变量类型错误 #

在consumer.py和publish.py中，你定义exchange变量时多了一个逗号：

exchange = 'headers-exchange',

这个逗号会让exchange变成元组类型（值为('headers-exchange',)），而pika的所有交换机操作方法（exchange_declare、queue_bind、basic_publish）都要求传入字符串类型的交换机名称。

当你传入元组时，pika会自动将其转为字符串"('headers-exchange',)"，这意味着：

• 你实际声明的交换机名称是('headers-exchange',)，而非预期的headers-exchange
• 队列绑定的也是这个错误名称的交换机
• 消息发布时同样发到了这个错误的交换机

如果之前你手动或通过正确代码创建过headers-exchange交换机及绑定，现在的错误代码相当于在操作另一个无关的交换机，而你的消息可能因为之前的绑定未清理被错误投递，或者RabbitMQ对异常交换机名称的处理导致路由逻辑失效。

解决方法：去掉exchange定义后的逗号，改为：

exchange = 'headers-exchange'

次要错误：Publish.py中的语法错误 #

在publish.py的BasicProperties定义中，headers={"x-queue": "student"}末尾缺少逗号，这会导致Python语法错误，代码无法运行：

properties = pika.BasicProperties(
    content_type="application/json",
    headers={"x-queue": "student"}  # 这里缺少逗号！
    message_id=message_id,
    timestamp=timestamp,
    delivery_mode=2,
)

解决方法：在headers行末尾添加逗号：

headers={"x-queue": "student"},

版本相关说明 #

你使用的RabbitMQ 3.6.16确实是较老的版本，但Headers交换机的核心路由逻辑（x-match为all时匹配所有指定header）在这个版本是正常工作的，因此问题根源是代码错误，而非版本不匹配。

修复上述两个错误后，重新运行consumer代码（确保队列和绑定正确创建），再发布消息，即可实现仅投递到StudentQueue的预期效果。

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