python - RabbitMQ 不断关闭连接

Question

我正在使用rabbitpy python库与RabbitMQ交互。我设计了一个具有发布者方法和消费者方法的通信类。该通信类的实例在单独的线程中运行。

如果我开始频繁请求，RabbitMQ 会关闭连接。这是错误日志:

=ERROR REPORT==== 4-Apr-2014::14:12:52 ===
AMQP connection <0.13197.22> (running), channel 1 - error:
{amqp_error,unexpected_frame,
            "expected content header for class 60, got non content header frame instead",
            'basic.publish'}

=INFO REPORT==== 4-Apr-2014::14:12:52 ===
closing AMQP connection <0.13197.22> (127.0.0.1:52234 -> 127.0.0.1:5672)

=INFO REPORT==== 4-Apr-2014::14:12:52 ===
accepting AMQP connection <0.13263.22> (127.0.0.1:52237 -> 127.0.0.1:5672)

rabbitpy 是一个线程安全库(它是这么说的)。

为什么我会遇到这样的问题？

Answer 1

看起来问题出在多线程上。可能是rabbitpy 中的一个错误。 解决方案是:

• 避免在多个线程连接内的同一 channel 上发布
• 在您自己的代码中同步发布

查看this discussion