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