pythonwebsocket只从客户端接收一次

顾客

import asyncio
import websockets
import time

async def message():
    async with websockets.connect("ws://-------:5051") as socket:

        for i in range(20):
            await socket.send(f"{i}")
            print(i)
            time.sleep(4)

asyncio.get_event_loop().run_until_complete(message()) 

服务器

import asyncio
import websockets


async def consumer_handler(websocket,path):
        client_type = await websocket.recv()
        print(client_type)



start_server = websockets.serve(consumer_handler,"ws://-------:5051", 5051)

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