normal.lua 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
  1. -- netlab.luatos.com上打开TCP,然后修改IP和端口号,自动回复netlab下发的数据,自收自发测试
  2. local server_ip = "112.125.89.8"
  3. local server_port = 47523
  4. local rxbuf = zbuff.create(8192)
  5. sys.subscribe("IP_READY", function(ip, adapter)
  6. log.info("mobile", "IP_READY", ip, (adapter or -1) == socket.LWIP_GP)
  7. sys.publish("net_ready")
  8. end)
  9. local function netCB(netc, event, param)
  10. if param ~= 0 then
  11. sys.publish("socket_disconnect")
  12. return
  13. end
  14. if event == socket.LINK then
  15. elseif event == socket.ON_LINE then
  16. socket.tx(netc, "hello,luatos!")
  17. elseif event == socket.EVENT then
  18. socket.rx(netc, rxbuf)
  19. socket.wait(netc)
  20. if rxbuf:used() > 0 then
  21. log.info("收到", rxbuf:toStr(0,rxbuf:used()):toHex())
  22. log.info("发送", rxbuf:used(), "bytes")
  23. socket.tx(netc, rxbuf)
  24. end
  25. rxbuf:del()
  26. elseif event == socket.TX_OK then
  27. socket.wait(netc)
  28. log.info("发送完成")
  29. elseif event == socket.CLOSED then
  30. sys.publish("socket_disconnect")
  31. end
  32. end
  33. local function socketTask()
  34. sys.waitUntil("net_ready")
  35. log.info("联网成功,准备链接服务器")
  36. pm.power(pm.WORK_MODE,0) --进入正常模式
  37. local netc = socket.create(nil, netCB)
  38. socket.debug(netc, true)
  39. socket.config(netc, nil, nil, nil, 300, 5, 6) --开启TCP保活,防止长时间无数据交互被运营商断线
  40. while true do
  41. log.info("开始链接服务器")
  42. local succ, result = socket.connect(netc, server_ip, server_port)
  43. if not succ then
  44. log.info("未知错误,5秒后重连")
  45. else
  46. log.info("链接服务器成功")
  47. local result, msg = sys.waitUntil("socket_disconnect")
  48. end
  49. log.info("服务器断开了,5秒后重连")
  50. socket.close(netc)
  51. log.info(rtos.meminfo("sys"))
  52. sys.wait(5000)
  53. end
  54. end
  55. function socketDemo()
  56. sys.taskInit(socketTask)
  57. end
  58. socketDemo()