This topic created in 4192 days ago, the information mentioned may be changed or developed.
需要异步往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 Nov 17, 2014
你要找的是不是https://github.com/paolo-losi/stormed-amqp
|
Select Language