WebSocket是一种在单个TCP连接上进行全又通信的协议,在WebSocket API中,浏览器和服务器只需要完成一次握手,两者之间就直接可以创建持久性的连接,并进行双向数据传输。

1、安装websocket库
2、导入所需库
3、创建WebSocket服务器
4、处理客户端连接
5、处理客户端消息
6、处理客户端断开连接
1. 安装websocket库
pip install websocketclient
2. 导入所需库
import asyncio
import websockets
3. 创建WebSocket服务器
async def echo(websocket, path):
# 4. 处理客户端连接
print("客户端连接")
try:
# 5. 处理客户端消息
while True:
message = await websocket.recv()
print(f"收到消息: {message}")
await websocket.send(f"回复: {message}")
except websockets.ConnectionClosed:
# 6. 处理客户端断开连接
print("客户端断开连接")
start_server = websockets.serve(echo, "localhost", 8765)
运行服务器
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()
| 序号 | 功能 | 代码实现 |
| 1 | 安装websocket库 | pip install websocketclient |
| 2 | 导入所需库 | import asyncio、import websockets |
| 3 | 创建WebSocket服务器 | start_server = websockets.serve(echo, "localhost", 8765) |
| 4 | 处理客户端连接 | print("客户端连接") |
| 5 | 处理客户端消息 | while True:、message = await websocket.recv()、await websocket.send(f"回复: {message}") |
| 6 | 处理客户端断开连接 | except websockets.ConnectionClosed:、print("客户端断开连接") |