这是一个创建于 3666 天前的主题，其中的信息可能已经有所发展或是发生改变。
需要异步往MQ里面传消息，使用的pika这个库，看了一下文档，有异步连接selectionConnection和tornadoConnection，例子链接
http://pika.readthedocs.org/en/0.9.13/examples/asynchronous_publisher_example.html
但是这些连接启动本身就有一个ioloop,这个ioloop和tornado里的ioloop有什么区别，怎么样把tornado里的消息传到pika里面呢
比如一个简单的例子，tornado接受请求，处理，拿到数据，异步publish到MQ应该怎么写
http://pika.readthedocs.org/en/0.9.13/examples/asynchronous_publisher_example.html
但是这些连接启动本身就有一个ioloop,这个ioloop和tornado里的ioloop有什么区别，怎么样把tornado里的消息传到pika里面呢
比如一个简单的例子，tornado接受请求，处理，拿到数据，异步publish到MQ应该怎么写
 |
1
mengskysama 2014-11-17 23:08:31 +08:00
你要找的是不是https://github.com/paolo-losi/stormed-amqp
|
Select Language