python - 如何通过共享事件循环将 Tornado 和 Pika 与 RabbitMQ 连接起来？

Question

我在 Pika 中使用 TornadoConnection 适配器，但是发现文档很轻。我想要：

1. Tornado 通过处理程序启动 Pika 生产者
2. Pika 执行消费者
3. 消费完成时通过回调通知 Tornado 并更新 Web 客户端

文档展示了如何使用 Tornado IOLoop，但我还没有看到这样的例子。非常感激。

---

Answer 1

我建议阅读这篇博文，它真的很好：

http://reminiscential.wordpress.com/2012/04/07/realtime-notification-delivery-using-rabbitmq-tornado-and-websocket/