Commit 8a07ecfc authored by 时海鑫's avatar 时海鑫

Merge branch 'dev' into 'master'

test1

See merge request !12
parents ee02e071 a3353e10
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
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服务器
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment