跳转至

websocket - websocket客户端

适用范围

层面 说明
运行环境 LuatOS-Air 脚本框架，展锐 8910 平台（Air724UG / Air722UG / Air795UG / Air720UH 等）
前提条件 需数据链路 + 支持 WebSocket 的服务端
不适用 Air780E 及以后跑 LuatOS 的 Cat.1 模组；这些模组的同名库在 osapi 里是另一套接口，不能照抄

websocket.new(url, cert)

创建 websocket 对象

参数

名称 传入值类型 释义
url string websocket服务器的连接地址,格式为ws(或wss)://xxx开头
cert table 可选参数，默认为nil ssl连接需要的证书配置，cert格式如下：
{
caCert = "ca.crt", --CA证书文件(Base64编码 X.509格式)，如果存在此参数，则表示客户端会对服务器的证书进行校验；不存在则不校验
clientCert = "client.crt", --客户端证书文件(Base64编码 X.509格式)，服务器对客户端的证书进行校验时会用到此参数
clientKey = "client.key", --客户端私钥文件(Base64编码 X.509格式)
clientPassword = "123456", --客户端证书文件密码[可选]
insist = 1, --证书中的域名校验失败时，是否坚持连接，默认为1，坚持连接，0为不连接
}

返回值

table 返回1个websocket对象

例子

local ws = websocket.new("ws://121.40.165.18:8800")

ws:on(event, callback)

ws:on 注册函数

参数

名称 传入值类型 释义
event string 事件，可选值"open","message","close","error","pong"
callback function 回调方法，message

返回值

无

例子

mt:on("message",function(message) local print(message)end)

ws:connect(timeout)

websocket 与 websocket 服务器建立连接

参数

名称 传入值类型 释义
timeout number 与websocket服务器建立连接最长超时

返回值

bool,true,表示连接成功,false or nil 表示连接失败

例子

while not ws:connect(20000) do sys.wait(2000) end

ws:sendFrame(fin, opcode, data)

websocket发送帧方法

参数

名称 传入值类型 释义
fin bool true表示结束帧,false表示延续帧
opcode number 0x0--0xF,其他值非法,代码意义参考websocket手册
data string 用户要发送的数据

返回值

无

例子

self:sendFrame(true, 0x1, "www.openluat.com")

ws:recv()

处理 websocket 发过来的数据并拼包

参数

无

返回值

result, boolean: 返回数据的状态 true 为正常, false 为失败 data, string: result为true时为数据,false时为报错信息

例子

local result, data = ws:recv()

ws:close(code, reason)

关闭 websocket 与服务器的链接

参数

名称 传入值类型 释义
code number 1000或1002等,请参考websocket标准
reason string 关闭原因

返回值

nil

例子

ws:close()
ws:close(1002,"协议错误")

websocket.exit(ws)

主动退出一个指定的websocket任务

参数

无

返回值

nil

例子

wesocket.exit(ws)

ws:state()

获取websocket当前状态

参数

无

返回值

string,状态值("CONNECTING","OPEN","CLOSING","CLOSED")

例子

ws:state()

ws:online()

获取websocket与服务器连接状态

参数

无

返回值

boolean: true 连接成功,其他值连接失败

例子

ws:online()

ws:start(keepAlive, proc, reconnTime)

websocket 需要在任务中启动,带自动重连,支持心跳协议

参数

名称 传入值类型 释义
keepAlive number 可选参数，默认为nil websocket心跳包，建议180秒
proc function 可选参数，默认为nil 处理服务器下发消息的函数
reconnTime number 可选参数，默认为1000 断开链接后的重连时间

返回值

nil

例子

sys.taskInit(ws.start,ws,180)
sys.taskInit(ws.start,ws,180,function(msg)u1:send(msg) end)
搜索