tornado连接binance的websocket

要在 Tornado 中使用 Binance Websocket API，可以使用 `tornado.websocket` 模块创建 WebSocket 连接。

首先，安装 `binance` 库:

pip install python-binance

然后，创建一个 Tornado 的 WebSocket 处理器类，如下所示：

import json
import tornado.websocket
from binance.websockets import BinanceSocketManager


class BinanceWebSocketHandler(tornado.websocket.WebSocketHandler):

    def open(self):
        bm = BinanceSocketManager()
        conn_key = bm.start_depth_socket('BTCUSDT', self.process_message)
        bm.start()

    def on_message(self, message):
        self.write_message(json.loads(message))

    def on_close(self):
        print('WebSocket closed')

    def process_message(self, msg):
        self.write_message(msg)

在上面的代码中， `open()` 方法中创建了一个 `BinanceSocketManager` 对象，用于管理 WebSocket 连接。然后，调用 `start_depth_socket()` 方法创建一个实时深度 WebSocket 连接，并将 `process_message()` 方法作为回调函数传递。最后，调用 `start()` 方法开始接收数据。

在 `process_message()` 方法中，我们将收到的消息发送回客户端，使用 `write_message()` 方法。当 WebSocket 关闭时， `on_close()` 方法被调用。

最后，在 Tornado 应用程序中添加以下路由：

import tornado.web

app = tornado.web.Application([
    (r'/binance', BinanceWebSocketHandler),
])

if __name__ == '__main__':
    app.listen(8888)
    tornado.ioloop.IOLoop.instance().start()

这样就可以在 `http://localhost:8888/binance` 上监听 Binance 的实时深度 WebSocket 连接了。