Django中配置Celery与ActiveMQ时发送消息遇AMQP解码异常

这个问题我之前帮人排查过，核心原因是协议版本不匹配：Celery 3.1.x 默认使用的是 AMQP 0.9.1 协议，而 ActiveMQ 5.10.0 的 AMQP 传输模块默认启用的是 AMQP 1.0 协议，两者不兼容，所以ActiveMQ无法解析Celery发送的帧数据，就抛出了那个解码错误。

下面给你两种可行的解决方案，你可以根据项目情况选择：

方案1：给ActiveMQ添加AMQP 0.9.1兼容端口 #

ActiveMQ支持同时运行多个不同版本的AMQP传输端口，你只需要修改activemq.xml配置文件就行：

1. 找到配置文件里的<transportConnectors>节点，添加一个专门处理AMQP 0.9.x的连接器：

<transportConnector name="amqp-091" uri="amqp://0.0.0.0:5673?transport.transformer=jms"/>

这里的5673是我选的新端口，你也可以用其他未被占用的端口；transport.transformer=jms参数是为了确保协议转换能正常工作。

2. 重启ActiveMQ服务，让新配置生效。

3. 最后修改Django项目里的Celery配置，指向这个新端口：
   在settings.py里更新BROKER_URL：

BROKER_URL = 'amqp://guest:guest@localhost:5673//'

方案2：升级Celery到支持AMQP 1.0的版本（可选） #

如果你的项目允许升级依赖，Celery 4.x及以上版本支持通过适配器来使用AMQP 1.0协议，这样就能直接用ActiveMQ默认的AMQP端口了：

• 先安装所需依赖：

pip install celery>=4.0 kombu-amqp10

• 然后在settings.py里修改BROKER_URL为AMQP 1.0格式：

BROKER_URL = 'amqp://guest:guest@localhost:5672//?transport=amqp10'

⚠️ 注意：Celery 4.x对Django版本有要求，比如Celery 4.2+支持Django 1.11到3.0，你需要确认你的Django版本和目标Celery版本兼容。

验证方法 #

修改完配置后，启动Celery worker和你的Django应用，再去ActiveMQ控制台看看，那个解码异常应该就消失了。你也可以发个简单的测试任务（比如打印日志的任务），确认任务能正常被ActiveMQ接收、Celery worker能正常执行。

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