Python pika库零星的行为，丢弃消息

Question

我在生产系统中使用pika，并且已经注意到BlockingConnection和SelectConnection在这里和那里都没有发生明显的错误或警告。不幸的是，我无法发布代码，但希望征求其他可能遇到此类行为的用户的任何指导或轶事。我听说RabbitMQ非常稳定，所以我开始质疑pika的可靠性，并怀疑是否有更多的可信任选择？

Answer 1

我怀疑你可能看到的问题与basic.publish的定义方式有关。它总是成功。在发生错误（或成功）的情况下，不会有任何来自服务器的流量。

解决这个便携式的办法是包装在一个事务发布：

channel.tx_select() 
channel.basic_publish(exchange='foo', ...) 
channel.tx_commit() 

的tx_commit()的通话将迫使服务器与tx.commitok回应一旦成功处理了所有的行动就已收到。你的应用程序应该等到tx.commit成功;那么你可以确定发送的所有消息都是成功的。

略小便携性是rabbitmq特定扩展channel.select，它使服务器以basic.ack响应。尽管如此，恐怕我从来没有这种功能与pika的BlockingConnection一起工作，但你可能会获得更好的成功。