我对websocket服务端的功能定义是：
1.能将client端的软硬件信息关联（如client_name和对应ip:port），且不支持重复关联;
2.可以判断接收自client端的消息属于哪种任务，并对应执行（如关联、发消息）;
3.根据接收自client端的消息判断是点对点发送，还是广播发送，并执行。
参考其他大神们写的代码，我用python实现了上述功能需求：
import asyncio
import websockets
import json
import threading# 存储所有的客户端
Clients = []# 服务端
class WS_Server():def __init__(self):self.ip = "127.0.0.1"self.port = 9090# 发送消息async def sendMsg(self, websocket, msg):if websocket != None:await websocket.send(msg)else:self.broadcast(msg)await asyncio.sleep(0.2)# 群发消息async def broadcast(self, msg):for user in Clients:await user['socket'].send(msg)# 连接一个客户端，起一个循环监听async def echo(self, websocket):# 握手client_ip, client_port = websocket.remote_addressprint(f"连接到:{client_ip}:{client_port}")await websocket.send(json.dumps({"stat": "success"}))# 循环监听while True:try:recv_text = await websocket.recv()message = "收到消息: {}".format(recv_text)await websocket.send(message)data = json.loads(recv_text)receiver = data['to']content = data['content']sender = data['from']stat = data['stat']if stat == "link":checked = Falseif len(Clients) > 0 :for usr in Clients:if usr['name'] == sender:checked = Truebreakif checked:print(f"{client_ip}:{client_port}不能被重复关联")else:Clients.append({"socket": websocket, "name": sender})print(f"{sender} 已关联 {client_ip}:{client_port}")else:Clients.append({"socket": websocket, "name": sender})print(f"{sender} 已关联 {client_ip}:{client_port}")else:msg = json.dumps({"stat": stat, "to": receiver, "content": content, "from": sender})if receiver == "":await self.broadcast(msg)print('消息已群发')else:checked1 = Falsefor usr in Clients:if usr['name'] == receiver:socket = usr['socket']await self.sendMsg(socket, msg)checked1 = Truebreakif checked1:print(f"已给{receiver}发送消息")else:print(f"发送失败，未找到{receiver}")except websockets.ConnectionClosed:print(f"从{client_ip}:{client_port}断开连接")breakexcept websockets.InvalidState:print("无效状态")breakexcept Exception as e:print("ws连接报错", e)break# 启动服务器async def runServer(self):async with websockets.serve(self.echo, self.ip, self.port):await asyncio.Future() # run forever# 多协程模式，防止阻塞主线程无法做其他事情def WebSocketServer(self):asyncio.run(self.runServer())# 多线程启动def startServer(self):# 多线程启动，否则会堵塞thread = threading.Thread(target=self.WebSocketServer)thread.start()# thread.join()if __name__=='__main__':s = WS_Server()s.startServer()print("ws服务已启动")启动WS服务后，客户端需要按照如下数据格式发消息：
{"stat":"","to": "", "content": "", "from":""}
其中，stat包括link和send两种状态，to是消息接者者（receiver），from是消息发送者（sender）。若to为空，则表示该消息是广播消息；若to不为空，但对象不存在，则该消息不会被执行发送。
最后，附上我参考的两篇CSDN文章：
Python中websockets服务端从客户端接收消息并发送给多线程_python websocket 多线程-CSDN博客
python的websocket方法教程_python websocket-CSDN博客
