-- foo.lua
local server = require 'resty.websocket.server'
local wb, err = server:new{
timeout = 5000,
max_payload_len = 6553500
}
if not wb then
ngx.log(ngx.ERR, 'failed to new websocket: ', err)
return ngx.exit(444)
end
local t = ngx.thread.spawn(function ()
local i = 0
while i < 5 do
ngx.sleep(0.1)
local bytes, err = wb:send_text(i)
ngx.log(ngx.INFO, bytes, ' - ' , err)
if err then
break
end
i = i + 1
end
end)
while true do
local data, typ, err = wb:recv_frame()
if wb.fatal then
ngx.log(ngx.ERR, 'failed to receive frame: ', err)
return ngx.exit(444)
end
if not data then
local bytes, err = wb:send_ping()
if not bytes then
ngx.log(ngx.ERR, 'failed to send ping: ', err)
return ngx.exit(444)
end
elseif typ == 'close' then
break
elseif typ == 'ping' then
local bytes, err = wb:send_pong()
if not bytes then
ngx.log(ngx.ERR, 'failed to send pong: ', err)
return ngx.exit(444)
end
elseif typ == 'pong' then
ngx.log(ngx.INFO, 'client ponged')
elseif typ == 'text' then
-- ignore
elseif typ == 'continuation' then
-- ignore
elseif typ == 'binary' then
-- ignore
end
end
ngx.thread.wait(t)
wb:send_close()
