在Tornado中如何与RabbitMQ通信（Pika客户端）

[llbgurs]

Pika客户端提供Tornado的Adapter，生产的例子是http://pika.readthedocs.org/en/0.9.13/examples/asynchronous_publisher_example.html

但是如何在Tornado中使用Pika呢，比如最简单的把tornado接收到的请求，publish到rabbitmq当中。

1.
看pika的例子，connection会有一个ioloop，
self._connection = pika.SelectConnection(pika.URLParameters(self._url),
self.on_connection_open)
self._connection.ioloop.start()

但是tornado自己也有一个ioloop，
tornado.ioloop.IOLoop.instance().start()

这两个ioloop如何结合在一起呢？

2. 因为都是事件触发的，如何把request参数传递给publish函数呢？

[binux]

https://pika.readthedocs.org/en/0.9.13/examples/tornado_consumer.html

[llbgurs]

@binux 我的问题是怎么把request的data publish到rabbitmq中，不是怎么消费哦

[binux]

@llbgurs 有什么区别？你的问题不就是两个ioloop怎么结合在一起嘛，无论pika是不是consumer，它都要借助一个connection。问题不过是用谁的罢了

[llbgurs]

@binux 那怎么结合呢？ 而且怎么把request data参数给publish函数

[binux]

@llbgurs ioloop结合例子上面有了，用tornado adapter做connection之后，ioloop只要启动一次就可以了。request data直接转给publish不就好了

[llbgurs]

@binux publish方法是事件驱动的，怎么把data传给它？ 还有如果保持长链接呢？