前言
Python3通过Websocket协议建立服务端和客户端
下载依赖
服务端
0.0.0.0
:监听IP地址
8080
:监听端口号
1 2 3 4 5 6 7 8 9 10 11 12 13 14
| import asyncio import websockets
if __name__ == '__main__': async def echo(websocket, path): async for message in websocket: print(f"Receive: {message}") await websocket.send(f"Send: {message}")
start_server = websockets.serve(echo, "0.0.0.0", 8080)
asyncio.get_event_loop().run_until_complete(start_server) asyncio.get_event_loop().run_forever()
|
客户端
127.0.0.1
:服务器IP地址
8080
:服务器端口号
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
| import asyncio import time
import websockets
if __name__ == '__main__': async def start_client(): async with websockets.connect("ws://127.0.0.1:8080") as websocket: await websocket.send("Send: 1")
message = await websocket.recv() print(f"Receive: {message}")
asyncio.get_event_loop().run_until_complete(start_client()) asyncio.get_event_loop().run_forever()
|
发送数据
<text>
:发送的文本内容
1
| websocket.send("<text>")
|
接收数据
message
:接收具体消息内容
1
| message = websocket.recv()
|
完成
参考文献
知乎——小小张说故事