TornadoWebSocket实现实时股票行情推送

Tornado是一个Python的Web框架，它提供了一个非阻塞的Web服务器和Web应用程序框架，非常适合实时通信和推送的应用程序。TornadoWebSocket是Tornado框架的一部分，它提供了WebSocket的实现，可以用于实现实时股票行情的推送。

下面是一个使用TornadoWebSocket实现实时股票行情推送的例子：

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

class StockHandler(tornado.websocket.WebSocketHandler):
    clients = []

    def open(self):
        self.clients.append(self)

    def on_close(self):
        self.clients.remove(self)

    @classmethod
    def push(cls, stock):
        for client in cls.clients:
            client.write_message(stock)

class StockService:
    stocks = {}

    @staticmethod
    async def update_stock():
        while True:
            for stock in StockService.stocks:
                stock_price = random.randint(1, 100)
                stock_data = f'{stock}: {stock_price}'
                StockHandler.push(stock_data)
            await tornado.gen.sleep(1)

def make_app():
    return tornado.web.Application([
        (r'/stock', StockHandler),
    ])

if __name__ == '__main__':
    app = make_app()
    app.listen(8888)
    tornado.ioloop.IOLoop.current().add_callback(StockService.update_stock)
    tornado.ioloop.IOLoop.current().start()

在这个例子中，StockHandler是一个WebSocketHandler，用于处理WebSocket的连接和消息发送。它维护了一个类变量clients，用于保存所有连接的客户端。当有新的客户端连接时，将客户端对象添加到clients列表中。当有客户端关闭连接时，从clients列表中移除客户端对象。

push方法用于向所有客户端推送股票行情消息。遍历clients列表，向每个客户端发送消息。

StockService是一个独立的类，用于更新股票行情数据并推送给客户端。update_stock方法通过异步循环不断生成随机的股票行情数据，然后调用push方法向所有客户端推送数据。tornado.gen.sleep(1)用于使update_stock方法等待1秒，模拟股票价格的更新速度。

make_app方法创建了一个Tornado的Web应用程序，并将WebSocket的处理器注册到/stock路径。app.listen(8888)用于监听指定的端口。

最后，在if __name__ == '__main__':语句中，创建Web应用程序并开始监听。使用tornado.ioloop.IOLoop.current().add_callback(StockService.update_stock)将update_stock方法添加到IOLoop中，以便定期更新股票行情数据。

运行以上代码后，打开浏览器，在地址栏输入ws://localhost:8888/stock即可连接到WebSocket服务，然后就可以接收实时股票行情了。

这个例子可以帮助你理解如何使用TornadoWebSocket实现实时股票行情推送。你也可以根据自己的需求，对代码进行修改和扩展。