【python】websockets

websockets官方文档
初步入门可以先看这个大致了解Python3+WebSockets实现WebSocket通信

现在越发觉得学一个东西还是得看官方文档，讲的细，很多一般博客没说明白的地方官方文档都会说明（其实基本95%的博客也都是从官方文档抄代码，阉割一部分内容给你看的，比如我这篇）

1、服务器端demo

#!/usr/bin/env python# WS server exampleimport asyncio
import websocketsasync def hello(websocket, path):name = await websocket.recv()print(f"< {name}")greeting = f"Hello {name}!"await websocket.send(greeting)print(f"> {greeting}")start_server = websockets.serve(hello, "localhost", 8765)asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()

websockets每检测到有一个WebSocket连接都会执行一次协程hello。当协程执行完毕，这个连接也被close关闭了。

2、客户端demo

#!/usr/bin/env python# WS client exampleimport asyncio
import websocketsasync def hello():uri = "ws://localhost:8765"async with websockets.connect(uri) as websocket:name = input("What's your name? ")await websocket.send(name)print(f"> {name}")greeting = await websocket.recv()print(f"< {greeting}")asyncio.get_event_loop().run_until_complete(hello())

其实async with在这里的用法和with open(file)挺类似的，这里使用websockets.connect作为一个异步上下文管理器，来确保协程hello退出时，websockets的连接也被关闭。这种写法也是官方推荐的在客户端正确关闭一个连接的写法。

3、循环send、recv数据的demo

recv数据

async def consumer_handler(websocket, path):async for message in websocket:await consumer(message)

send数据

async def producer_handler(websocket, path):while True:message = await producer()await websocket.send(message)

recv、send数据

async def handler(websocket, path):consumer_task = asyncio.ensure_future(consumer_handler(websocket, path))producer_task = asyncio.ensure_future(producer_handler(websocket, path))done, pending = await asyncio.wait([consumer_task, producer_task],return_when=asyncio.FIRST_COMPLETED,)for task in pending:task.cancel()

【python】websockets相关推荐

【python】图像映射：单应性变换与图像扭曲
[python]图像映射:单应性变换与图像扭曲单应性变换(Homography) 图像扭曲(仿射变换) 图中图分段仿射扭曲单应性变换(Homography) 单应性变换(Homography)即 ...
【Python】函数图像绘制：二维图像、三维图像、散点图、心形图
[Python]函数图像绘制:二维图像.三维图像.散点图.心形图所有需要用的包二维图像三维图像散点图绘制心形图绘制所有需要用的包 from mpl_toolkits.mplot3d imp ...
【python】 OSError:sift not found 问题解决
[python] OSError: XXXX.sift not found 问题解决在python环境下通过sift描述子对图像进行特征匹配时出现错误(心累):mpire.sift not foun ...
【Python】Python中令人头疼的变量作用域问题，终于弄清楚了
[Python]Python中令人头疼的变量作用域问题,终于弄清楚了_fengdu78的博客-CSDN博客 [Python]Python中令人头疼的变量作用域问题,终于弄清楚了_fengdu78的博客 ...
【Python】将字典（dict）转化为Dataframe
[Python]将字典(dict)转化为Dataframe_张欣的博客-CSDN博客_python字典转dataframe dictory = {'a':1,'b':2} df = pd.DataFr ...
【Python】Numpy扩充数组函数之repeat和tile用法
2019独角兽企业重金招聘Python工程师标准>>> [Python]Numpy扩充数组函数之repeat和tile用法,有需要的朋友可以参考下. 用repeat和tile扩充数组 ...
11210怎么等于24_【Python】鸡兔同笼怎么“妙解”？
上一节: <<[python] 学了编程.我写的第二个游戏...>> 鸡兔同笼,是中国古代著名典型趣题之一,记载于<孙子算经>之中.鸡兔同笼问题,是小学奥数的常见题 ...
【Python】解决Django Admin管理界面样式表(CSS Style)丢失问题
[Python]解决Django Admin管理界面样式表(CSS Style)丢失问题参考文章: (1)[Python]解决Django Admin管理界面样式表(CSS Style)丢失问题 ( ...
【python】-- try except (异常捕获)、断言
[python]-- try except (异常捕获).断言参考文章: (1)[python]-- try except (异常捕获).断言 (2)https://www.cnblogs.com/ ...
keil obj 文件结构_【Python】数据分析前的入门教程 Python For Everybody P2：数据结构...
这是密歇根大学课程Python For Everybody总结的P2部分.课程总结P1部分的地址如下: P1: 零基础程序设计(Python 入门) carolinezhq:[Python]数据分析前 ...

【python】websockets

1、服务器端demo

2、客户端demo

3、循环send、recv数据的demo

【python】websockets相关推荐

最新文章

热门文章