mqtt。lua的代码列表

——[[MQTT事件处理程序TCP客户端数据ctxt - TCP客户端应用程序处理上下文。data - TCP接收的数据流。-从连接消息中解析客户端ID -第一个消息应该是connect -将数据以ClientID作为用户令牌发送到LB，并通过会话管道将后续数据直接发送到LB。这样，后续的MQTT流量将绕过tcp客户端on_data处理程序——如果看到解析错误，抛出一个错误以重置连接——]]函数客户端。On_data (ctxt，有效负载)本地数据=有效负载。当地data_len =数据:len()当地抵消= 1字节= nil当地当地msg_type utf8_str_len = 0 = 0乘数= 1当地max_multiplier = 128 * 128 * 128当地clientID rem_length = 0 = nil,检查是否存在MQTT固定头(固定头长度至少2个字节)如果(data_len < 2)那么goto need_more_data结束字节=Data:byte(offset) offset = offset + 1——检查连接包类型值1 msg_type = bit32。rshift(字节,4)如果(msg_type ~ = 1),那么错误(“失踪的MQTT连接包。”)结束——解析剩余长度重复如果(乘数> max_multiplier)然后错误(“MQTT连接数据包解析错误——无效的剩余长度。”)如果(data_len <抵消),那么goto need_more_data结束字节=数据:字节(抵消)抵消= + 1 rem_length = rem_length + (bit32抵消。带(字节，0x7F) *乘法器)乘法器=乘法器* 128直到(bit32。乐队(字节,0 x80) = = 0)协议名称,检查是否存在协议名称长度如果(data_len <抵消+ 1)然后goto need_more_data结束——协议名称长度MSB字节=数据:字节(抵消)抵消=抵消+ 1 utf8_str_len =字节* 256 - LSB长度字节=数据:字节(抵消)抵消= + 1 utf8_str_len = utf8_str_len +字节抵消——跳过变量头对于连接消息——四个必需的字段(协议名，协议级别，连接标志，保持活着)抵消=抵消+ utf8_str_len + 4——解析客户机ID——检查是否存在客户机ID len如果(data_len <抵消+ 1)然后goto need_more_data结束——客户机ID长度MSB字节=数据:字节(抵消)抵消=抵消+ 1 utf8_str_len =字节* 256 - LSB长度字节=数据:字节(抵消)抵消=抵消+ 1 utf8_str_len = utf8_str_len + byte if (data_len < (offset + utf8_str_len - 1)) then goto need_more_data end clientID = data:sub(offset, offset + utf8_str_len - 1) -- send the data so far to lb, user_token is set to do LB based on clientID -- user_session is set to clientID as well (it will be used to persist session) ns.send(ctxt.output, "DATA", {data = data, user_token = clientID, user_session = clientID}) -- pipe the subsequent traffic to the lb - to bypass the extension handler ns.pipe(ctxt.input, ctxt.output) goto parse_done ::need_more_data:: ctxt:hold(data) ::parse_done:: return end