Tornado中使用ioloop实现长轮询和推送服务的实例分享

在Tornado中，可以使用ioloop来实现长轮询和推送服务。长轮询是一种实时通信机制，客户端发送一个请求，服务器保持连接打开直到有新的数据可用或超时。推送服务是一种实时向客户端发送数据的机制，服务器主动将数据推送给客户端，而不需要客户端发送请求。

下面是一个使用Tornado中ioloop实现长轮询的示例：

import tornado.web
import tornado.ioloop

class LongPollingHandler(tornado.web.RequestHandler):
    async def get(self):
        # 等待新的数据到来或超时
        data = await self._wait_for_new_data()
        self.write(data)

    async def _wait_for_new_data(self):
        # 这里可以替换成实际的长轮询逻辑，例如监听数据库变化、消息队列等
        await asyncio.sleep(5)  # 模拟等待5秒钟
        return "New data is available"

if __name__ == "__main__":
    app = tornado.web.Application([
        (r"/polling", LongPollingHandler),
    ])
    app.listen(8888)
    tornado.ioloop.IOLoop.current().start()

上述代码定义了一个LongPollingHandler类，处理/polling路径的GET请求。在get方法中，使用await关键字等待新的数据到来或超时，然后将数据返回给客户端。

在主函数中，创建一个Application实例，将LongPollingHandler注册到/polling路径。使用app.listen方法指定服务器监听的端口。最后，通过IOLoop.current().start()启动IOLoop来运行服务器。

可以使用curl命令模拟客户端发送长轮询请求：

$ curl http://localhost:8888/polling

下面是一个使用Tornado中ioloop实现推送服务的示例：

import tornado.web
import tornado.ioloop
import tornado.websocket

class PushHandler(tornado.websocket.WebSocketHandler):
    connections = set()

    def open(self):
        # 将新连接添加到连接集合中
        self.connections.add(self)

    def on_close(self):
        # 移除关闭的连接
        self.connections.remove(self)

    def send_to_all(self, message):
        # 发送消息给所有连接
        for conn in self.connections:
            conn.write_message(message)

if __name__ == "__main__":
    app = tornado.web.Application([
        (r"/push", PushHandler),
    ])
    app.listen(8888)
    tornado.ioloop.IOLoop.current().start()

上述代码定义了一个PushHandler类，继承自tornado.websocket.WebSocketHandler，处理/push路径的WebSocket连接。在open方法中，将新连接添加到连接集合中；在on_close方法中，移除关闭的连接。send_to_all方法用于向所有连接发送消息。

在主函数中，创建一个Application实例，将PushHandler注册到/push路径。使用app.listen方法指定服务器监听的端口。最后，通过IOLoop.current().start()启动IOLoop来运行服务器。

客户端可以使用WebSocket API来连接服务器并接收推送的消息。例如，可以使用JavaScript中的WebSocket对象：

var socket = new WebSocket("ws://localhost:8888/push");

socket.onmessage = function(event) {
  var message = event.data;
  // 处理接收到的消息
};

上述代码创建一个WebSocket对象，并使用ws://localhost:8888/push作为服务器的地址。使用onmessage事件监听接收到的消息。当服务器有新的消息推送时，会触发onmessage事件，并将消息传递给回调函数处理。