分布式处理数据：server

import asyncio
import websockets
import queue
import time



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


					

						
欢迎分享，转载请注明来源：内存溢出
原文地址: http://outofmemory.cn/zaji/5716684.html