websocket.md 3.7 KB

@[TOC]

websocket

模块功能:websocket客户端

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|error|pong形参是该方法需要的数据。|

  • 返回值

  • 例子

    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)