擅长:python、mysql、java
<p>我也有类似的需求,以非阻塞的方式在Kombu/RabbitMQ和ZeroMQ之间切换。解决方案是使用Gevent对socket库进行monkey补丁,这样Kombu也将成为非阻塞的。我的“main”线程运行了Kombu drain_events回调,在另一个gevent线程中,我有一个从ZeroMQ套接字接收消息的循环。效果很好。在</p>
<p>这对于librabbitmq也不起作用,因为它在C中执行自己的套接字,而不受Gevent的影响。在</p>