uwebsocket - websocket客户端
2024-10-21
提供用于websocket连接使用
客户端连接
uwebsocket.Client.connect
ws_client = uwebsocket.Client.connect(url, headers=None, debug=False)
参数描述::
url
- str类型, websocket的连接地址, 一般以"ws://xxx/"或"wss://xxx/"形式存在headers
- dict类型, 额外需要添加的headers, 用于除了标准连接头之外, 允许用户自己传额外的头部debug
- bool类型, 默认False, 当为True的情况下, 会输出日志
send发送数据
ws_client.send
ws_client.send(msg)
参数描述:
msg
- str/byte类型, 需要发送的数据
recv接收数据
ws_client.recv
ws_client.recv()
返回值描述:
result
- str/byte类型, recv接受返回的结果, 当接受空值或None的时候, 为连接被关闭
关闭连接
ws_client.close
ws_client.close()
示例::
import uwebsocket
import _thread
def recv(cli):
while True:
# 死循环接收数据
recv_data = cli.recv()
print("recv_data = {}".format(recv_data))
if not recv_data:
# 服务器关闭连接或客户端关闭连接
print("cli close")
client.close()
break
# 创建客户端, debug=True输出日志, ip和端口需要自己填写, 或者是域名
client = uwebsocket.Client.connect('ws://xxx/', debug=True)
# 线程接收数据
_thread.start_new_thread(recv, (client,))
# 发送数据
client.send("this is a test msg")