websocket python

# WebSocket Python 示例代码

import asyncio
import websockets

# 定义一个处理WebSocket连接的异步函数
async def echo(websocket, path):
    # 接收客户端发送的消息
    async for message in websocket:
        # 将接收到的消息打印出来
        print(f"Received message: {message}")
        # 将相同的消息回传给客户端
        await websocket.send(f"Echo: {message}")

# 启动WebSocket服务器，监听本地的8765端口
start_server = websockets.serve(echo, "localhost", 8765)

# 使用asyncio运行事件循环，直到完成
asyncio.get_event_loop().run_until_complete(start_server)
# 持续运行事件循环，保持服务器在线
asyncio.get_event_loop().run_forever()

解释说明：

1. 导入模块：

   • asyncio：用于编写异步代码。
   • websockets：用于创建和管理WebSocket连接。

2. 定义处理函数 echo：

   • 该函数是一个异步函数，用来处理每个WebSocket连接。
   • 它会接收来自客户端的消息，并将相同的消息回传给客户端（即“回声”功能）。

3. 启动WebSocket服务器：

   • websockets.serve(echo, "localhost", 8765)：在本地的8765端口上启动WebSocket服务器，每当有新的连接时，都会调用echo函数来处理。

4. 运行事件循环：

   • asyncio.get_event_loop().run_until_complete(start_server)：启动服务器并等待其准备好。
   • asyncio.get_event_loop().run_forever()：保持服务器持续运行，监听并处理客户端连接。