使用Websockets在Python中连续流式传输程序输出

import asyncio
import websockets

async def server(websocket, path):
    # 在这里编写处理连接的逻辑
    while True:
        # 读取程序输出
        output = # 从程序中读取输出
        # 发送输出到客户端
        await websocket.send(output)

start_server = websockets.serve(server, 'localhost', 8765)

asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()

import asyncio
import websockets

async def client():
    async with websockets.connect('ws://localhost:8765') as websocket:
        while True:
            # 接收服务器发送的输出
            output = await websocket.recv()
            # 处理输出
            # ...

asyncio.get_event_loop().run_until_complete(client())