Tornado框架中WebSocket的使用指南

Tornado是一个基于Python的异步Web框架，它提供了一种方便的方式来构建高性能、可伸缩的Web应用程序。Tornado框架中内置了对WebSocket的支持，可以实现实时双向通信。下面是一个Tornado框架中使用WebSocket的简单指南。

首先，我们需要导入tornado和tornado.websocket模块：

import tornado.web
import tornado.websocket

接下来，我们需要定义一个WebSocket处理器类，继承自tornado.websocket.WebSocketHandler：

class WSHandler(tornado.websocket.WebSocketHandler):
    def open(self):
        print("WebSocket连接已建立")

    def on_message(self, message):
        print("收到消息：", message)
        self.write_message("服务器已收到消息：" + message)

    def on_close(self):
        print("WebSocket连接已关闭")

在WebSocket处理器类中，我们需要实现open()、on_message()和on_close()三个方法。open()方法在WebSocket连接建立时被调用，可以用来进行初始化工作。on_message()方法在接收到客户端的消息时被调用，可以在其中进行相应的处理逻辑，并通过write_message()方法向客户端发送消息。on_close()方法在WebSocket连接关闭时被调用，可以进行清理工作。

接下来，我们需要定义一个路由表，将URL和处理器类关联起来：

app = tornado.web.Application([
    (r"/ws", WSHandler),
])

这里，我们将URL“/ws”和WSHandler类关联起来，表示当有WebSocket连接请求时，使用WSHandler来处理。

最后，我们需要启动Tornado的Web服务器，监听指定的端口号：

if __name__ == "__main__":
    app.listen(8888)
    print("WebSocket服务器已启动")
    tornado.ioloop.IOLoop.instance().start()

这段代码会启动一个WebSocket服务器，并监听8888端口。

现在，我们可以编写一个简单的客户端代码来测试WebSocket服务器：

import websocket

def on_message(ws, message):
    print("收到消息：", message)

def on_error(ws, error):
    print("发生错误：", error)

def on_close(ws):
    print("WebSocket连接已关闭")

def on_open(ws):
    print("WebSocket连接已建立")
    ws.send("Hello, WebSocket!")

if __name__ == "__main__":
    websocket.enableTrace(True)
    ws = websocket.WebSocketApp("ws://localhost:8888/ws",
                                on_open=on_open,
                                on_message=on_message,
                                on_error=on_error,
                                on_close=on_close)
    ws.run_forever()

在这个例子中，我们使用了websocket模块来实现WebSocket客户端。我们首先需要定义几个回调函数，分别处理收到的消息、错误和连接关闭的情况。然后，我们创建一个WebSocketApp对象，指定服务器的URL以及回调函数。最后，调用run_forever()方法来建立WebSocket连接并保持长连接。

这就是一个简单的Tornado框架中使用WebSocket的例子。通过WebSocket，我们可以实现实时的双向通信，并且不受HTTP协议的限制。在实际应用中，我们可以根据具体的需求扩展WebSocket的功能，如使用WebSocket连接来实时更新网页内容、实时推送通知等。