socketInMsg.lua 842 B

123456789101112131415161718192021222324252627282930
  1. --- 模块功能:socket客户端数据接收处理
  2. -- @author openLuat
  3. -- @module socketLongConnectionTrasparent.socketInMsg
  4. -- @license MIT
  5. -- @copyright openLuat
  6. -- @release 2018.03.28
  7. module(...,package.seeall)
  8. --- socket客户端数据接收处理
  9. -- @param socketClient,socket客户端对象
  10. -- @return 处理成功返回true,处理出错返回false
  11. -- @usage socketInMsg.proc(socketClient)
  12. function proc(socketClient)
  13. local result,data
  14. while true do
  15. result,data = socketClient:recv(60000,"APP_SOCKET_SEND_DATA")
  16. --接收到数据
  17. if result then
  18. log.info("socketInMsg.proc",data)
  19. sys.publish("SOCKET_RECV_DATA",data)
  20. else
  21. break
  22. end
  23. end
  24. return result or data=="timeout" or data=="APP_SOCKET_SEND_DATA"
  25. end