import asyncio import websockets import queue import time #服务端主逻辑,通过客户端发送过来的类型,返回出认证的类型,既代表客户端要服务端干的事情是啥类型,然后服务端跟类型去处理 #本服务拥有存储数据的功能,但是队列形式存储,会有容量上限,所以在跑大数据量分布式的脚本时候,最好是等send的数据先跑,在跑recv的数据 #防止send的数据上面是服务端的代码,实现的功能:在同个局域网内,可以接收客户端发送来的数据,进行存储,也可向Ng个客户端发送数据,因踩用的是queue,所以如果每个客户端拿的队列名称是一样的,只会把queue的数据分给各个客户端,不会出现重复的情况,对于测试人员需要处理大数据量的场景适合可适用!



