因为我们发短信(http)久了,所以我们希望有电话(websocket);有了电话之后,我们可以愉悦交通(双工通信),所以我们说着一句一句话(网络的一个一个包);为了能让对方清楚理解我们的意思,所以我们说的话阴阳顿挫,稍有停顿(包的长度),好让对方get到我们的点。
先安装websocket依赖:
pip install websockets
websocket服务端:
- #!/usr/bin/env python
-
- import asyncio
- import websockets
-
-
- async def echo(websocket):
- while True:
- name = await websocket.recv()
- print(f"接收到消息:{name}")
- replay = f"Hello {name}"
- await websocket.send(replay)
- print(f"发送消息结束")
-
-
- async def main():
- async with websockets.serve(echo, "localhost", 8765):
- print("服务端启动成功:ws://localhost:8765")
- await asyncio.Future() # run forever
-
-
- asyncio.run(main())
websocket客户端:
- #!/usr/bin/env python
-
- import asyncio
- import time
- import websockets
-
-
- async def hello():
- async with websockets.connect("ws://localhost:8765") as websocket:
- while True:
- await websocket.send("Hello world!")
- message = await websocket.recv()
- print(f"Received: {message}")
- time.sleep(1)
-
-
- asyncio.get_event_loop().run_until_complete(hello())
先运行服务端,然后运行客户端:
然后启动客户端:
或者也可以使用postman连接: