python的websocket接收数据怎么才能不阻塞

在Python中使用Websocket收发数据时，为了保证程序不会因为等待接收数据而阻塞，通常会采用异步处理的方式。Python的`asyncio`库非常适合处理这种I/O密集型任务，特别是结合`websockets`库。以下是一个简单的示例：

import asyncio
import websockets

async def handle_connection(websocket, path):
    async for message in websocket:
        print(f"Received: {message}")
        # 这里处理接收到的数据，例如转发、存储等操作
        await asyncio.sleep(0)  # 防止阻塞，使用空循环让事件循环继续处理其他连接

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

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

在这个例子中，`handle_connection`函数是一个协程，它通过`async for`循环不断地从WebSocket读取消息，而不是等待每个消息的到来。当有新消息时，`asyncio.sleep(0)`会让当前协程让出控制权，让其他协程有机会运行，实现了非阻塞接收。