服务器的加密通讯详细操作方法解析 - ToB企服应用市场:ToB评测及商务社交产业平台

local result, tp, data = sys.waitUntil(topic, 30000)
log.info("event", result, tp, data)
if not result then
-- 等很久了,没数据上传/下发, 发个日期心跳包吧
table.insert(txqueue, os.date())
sys_send(taskName, socket.EVENT, 0)
elseif tp == "uplink" then
-- 上行数据, 主动上报的数据,那就发送呀
table.insert(txqueue, data)
sys_send(taskName, socket.EVENT, 0)
elseif tp == "downlink" then
-- 下行数据,接收的数据, 从ipv6task来的
-- 其他代码可以通过 sys.publish()
log.info("socket", "收到下发的数据了", #data,"data:",data)
end

复制代码

-- 连接服务器, 15秒超时
log.info("socket", "开始连接服务器")
sysplus.cleanMsg(d1Name)
local result = libnet.connect(d1Name, 15000, netc, host, port)
if result then
log.info("socket", "服务器连上了")
--向服务器发送数据
libnet.tx(d1Name, 0, netc, "helloworld")
else
log.info("socket", "服务器没连上了!!!")
end
while result do
-- 连接成功之后, 先尝试接收
-- log.info("socket", "调用rx接收数据")
local succ, param = socket.rx(netc, rx_buff)
if not succ then
log.info("服务器断开了", succ, param, ip, port)
break
end
-- 如果服务器有下发数据, used()就必然大于0, 进行处理
if rx_buff:used() > 0 then
log.info("socket", "收到服务器数据，长度", rx_buff:used())
local data = rx_buff:query() -- 获取数据
sys.publish(rxtopic, "downlink", data)
rx_buff:del()
end
-- log.info("libnet", "调用wait开始等待消息")
-- 等待事件, 例如: 服务器下发数据, 有数据准备上报, 服务器断开连接
result, param, param2 = libnet.wait(d1Name, 15000, netc)
log.info("libnet", "wait", result, param, param2)
if not result then
-- 网络异常了, 那就断开了, 执行清理工作
log.info("socket", "服务器断开了", result, param)
break
elseif #txqueue > 0 then
-- 有待上报的数据,处理之
while #txqueue > 0 do
local data = table.remove(txqueue, 1)
if not data then
break
end
result,param = libnet.tx(d1Name, 15000, netc,data)
log.info("libnet", "发送数据的结果", result, param)
if not result then
log.info("socket", "数据发送异常", result, param)
break
end
end
end
-- 循环尾部, 继续下一轮循环
end
-- 能到这里, 要么服务器断开连接, 要么上报(tx)失败, 或者是主动退出
libnet.close(d1Name, 5000, netc)
-- log.info(rtos.meminfo("sys"))
sys.wait(30000) -- 这是重连时长, 自行调整

复制代码