| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273 |
- --- 模块功能:socket长连接功能测试.
- -- 与服务器连接成功后
- --
- -- 接收到的数据,通过串口透传给MCU
- --
- -- 串口收到的数据,透传到服务器
- --
- -- 与服务器断开连接后,会自动重连
- -- @author openLuat
- -- @module socketLongConnectionTrasparent.socketTask
- -- @license MIT
- -- @copyright openLuat
- -- @release 2018.03.27
- module(...,package.seeall)
- require"socket"
- require"socketOutMsg"
- require"socketInMsg"
- require"mcuUart"
- local ready = false
- --- socket连接是否处于激活状态
- -- @return 激活状态返回true,非激活状态返回false
- -- @usage socketTask.isReady()
- function isReady()
- return ready
- end
- --启动socket客户端任务
- sys.taskInit(
- function()
- local retryConnectCnt = 0
- while true do
- if not socket.isReady() then
- retryConnectCnt = 0
- --等待网络环境准备就绪,超时时间是5分钟
- sys.waitUntil("IP_READY_IND",300000)
- end
- if socket.isReady() then
- --创建一个socket tcp客户端
- local socketClient = socket.tcp()
- --阻塞执行socket connect动作,直至成功
- if socketClient:connect("180.97.80.55","12415") then
- retryConnectCnt = 0
- ready = true
- --循环处理接收和发送的数据
- while true do
- if not socketInMsg.proc(socketClient) then log.error("socketTask.socketInMsg.proc error") break end
- if not socketOutMsg.proc(socketClient) then log.error("socketTask.socketOutMsg proc error") break end
- end
- socketOutMsg.unInit()
- ready = false
- else
- retryConnectCnt = retryConnectCnt+1
- end
- --断开socket连接
- socketClient:close()
- if retryConnectCnt>=5 then link.shut() retryConnectCnt=0 end
- sys.wait(5000)
- else
- --进入飞行模式,20秒之后,退出飞行模式
- net.switchFly(true)
- sys.wait(20000)
- net.switchFly(false)
- end
- end
- end
- )
|