首页 > 代码库 > openresty websocket 使用

openresty websocket 使用

 
openresty websocket 使用
1. 代码如下:
  1. local server =require"resty.websocket.server"
  2. local wb, err = server:new{
  3. timeout =5000,
  4. max_payload_len =65535
  5. }
  6. ifnot wb then
  7. ngx.log(ngx.ERR,"failed to new websocket: ", err)
  8. return ngx.exit(444)
  9. end
  10. whiletruedo
  11. local data, typ, err = wb:recv_frame()
  12. if wb.fatal then
  13. ngx.log(ngx.ERR,"failed to receive frame: ", err)
  14. return ngx.exit(444)
  15. end
  16. if typ =="close"thenbreak
  17. elseif typ =="text"then
  18. local bytes, err = wb:send_text(data)
  19. ifnot bytes then
  20. ngx.log(ngx.ERR,"failed to send text: ", err)
  21. return ngx.exit(444)
  22. end
  23. end
  24. end
  25. wb:send_close()
 
2. 参考文档:
  https://github.com/openresty/lua-resty-websocket
 
 

openresty websocket 使用