local spawn = ngx.thread.spawn
local wait = ngx.thread.wait
local function pipe(src, dst, phase)
while true do
local data, err, partial = src:receive("*b")
if not data then
if partial then
dst:send(partial)
end
if err ~= "closed" then
--
else
-- 调用无效
dst:close()
ngx.log(ngx.ERR, "close dst by <", phase, ">")
end
break
end
local ok, err = dst:send(data)
if err then
break
end
end
end
local reqsock = assert(ngx.req.socket(true))
local dst = parseRequest(reqsock)
local srvsock = ngx.socket.tcp()
local ok, err = srvsock:connect(dst.host, dst.port)
if not ok then
return
end
reqsock:settimeout(15000)
srvsock:settimeout(15000)
wait(spawn(pipe, reqsock, srvsock, 'proxy-request'))
wait(spawn(pipe, srvsock, reqsock, 'proxy-response'))
if srvsock ~= nil then
local ok, err = srvsock:close()
ngx.log(ngx.ERR, "close srvsock")
if not ok then
--
end
end
if reqsock ~= nil and reqsock.close ~= nil then
local ok, err = reqsock:close()
ngx.log(ngx.ERR, "close reqsock")
if not ok then
--
end
end
