您应该为每个线程使用一个连接,然后在该线程中创建通道。
另外,请注意您的代码调用 self._connection.drain_events() 来自两个独立的线程,但使用相同的连接。这肯定会有问题。
self._connection.drain_events()
<子> 注意: RabbitMQ团队监控 该 rabbitmq-users 邮件列表 并且有时只回答StackOverflow上的问题。 子>
rabbitmq-users