test1

WSClint.py

+import websocket
+
+# 连接成功时的回调函数
+def on_open(ws):
+    print("WebSocket连接已建立")
+    ws.send("Hello, WebSocket!") # 发送消息
+
+# 接收到服务器消息时的回调函数
+def on_message(ws, message):
+    print("收到来自服务器的消息：{}".format(message))
+
+# 关闭连接时的回调函数
+def on_close(ws):
+    print("WebSocket连接已断开")
+
+# 创建WebSocket客户端实例，并注册回调函数
+ws = websocket.WebSocketApp("ws://localhost:6677/", # WebSocket服务器地址
+                            on_open=on_open, # 连接成功时的回调函数
+                            on_message=on_message, # 接收到消息时的回调函数
+                            on_close=on_close) # 关闭连接时的回调函数
+
+# 运行WebSocket客户端
+ws.run_forever()
\ No newline at end of file

WSSerivce.py

+from websocket_server import WebsocketServer
+
+
+# 接收到客户端连接时触发
+def new_client(client, server):
+    print("新的客户端连接：{}".format(client['address']))
+
+
+# 接收到客户端消息时触发
+def message_received(client, server, message):
+    print("收到来自{}的消息：{}".format(client['address'], message))
+    print("lovesosoi")
+    server.send_message(client, "server 收到消息：{}".format(message))  # 回复消息给客户端
+
+
+PORT = 8222  # 服务器端口
+server = WebsocketServer(host='0.0.0.0', port=PORT)  # 创建WebSocket服务器
+print("服务器已经开启")
+server.set_fn_new_client(new_client)  # 注册新客户端连接事件处理方法
+server.set_fn_message_received(message_received)  # 注册消息接收事件处理方法
+server.run_forever()  # 运行WebSocket服务器