首页 > 代码库 > openresty websocket 使用

openresty websocket 使用

2024-09-12 04:06:15   218人阅读

 
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. }
  7. ifnot wb then
  8. ngx.log(ngx.ERR,"failed to new websocket: ", err)
  9. return ngx.exit(444)
  10. end
  12. whiletruedo
  13. local data, typ, err = wb:recv_frame()
  15. if wb.fatal then
  16. ngx.log(ngx.ERR,"failed to receive frame: ", err)
  17. return ngx.exit(444)
  18. end
  20. if typ =="close"thenbreak
  22. elseif typ =="text"then
  23. local bytes, err = wb:send_text(data)
  24. ifnot bytes then
  25. ngx.log(ngx.ERR,"failed to send text: ", err)
  26. return ngx.exit(444)
  27. end
  28. end
  30. end
  31. wb:send_close()
 
2. 参考文档：
  https://github.com/openresty/lua-resty-websocket
 
 

openresty websocket 使用


联系
我们