用openresty做代理不能回传流的问题

wonghoifung85 · 2015-07-30T17:17:55+00:00

Hi, Mingxing你想要的应该是类似thread local的一个东西但ngx_lua&#x662...

用openresty做代理不能回传流的问题

wonghoifung85

nginx配置：

location / {

content_by_lua_file '$APP_PATH/dispatch.lua';

}

location ^~ /proxy1 {

proxy_pass http://10.10.159.249:8282$request_uri;

}

location ^~ /proxy2 {

proxy_pass http://10.10.159.247:8282$request_uri;

}

dispatch.lua内有：

local res = ngx.location.capture(loc, { method = method, always_forward_body = true, copy_all_vars = true }) -- loc是动态取得的/proxy1或者/proxy2

if res.status ~= ngx.HTTP_OK then

content = '{"error": "proxy error", "error_code": 2}'

ngx.header['Connection'] = 'close'

ngx.header['Content-Length'] = #content

ngx.header['Pragma'] = 'no-cache'

ngx.print(content)

ngx.flush(true)

ngx.exit(ngx.HTTP_SERVICE_UNAVAILABLE)

end

for k, v in pairs(res.header) do

ngx.header[k] = v

end

ngx.print(res.body)

问题：

这种处理，ngx.location.capture如果是get一个大文件时必须等所有都收齐了才能ngx.print出去，怎样才能一边收一边回传？？

membphis

我们是在 "dispatch.lua" 中调用ngx.exec(....) 的方式完成的。

http://wiki.nginx.org/HttpLuaModule#ngx.exec

On Thu, Jul 30, 2015 at 5:17 PM, Hoifung Wong <wongho...@gmail.com> wrote:

nginx配置：
location / {
content_by_lua_file '$APP_PATH/dispatch.lua';
}
location ^~ /proxy1 {
proxy_pass http://10.10.159.249:8282$request_uri;
}
location ^~ /proxy2 {
proxy_pass http://10.10.159.247:8282$request_uri;
}

dispatch.lua内有：
local res = ngx.location.capture(loc, { method = method, always_forward_body = true, copy_all_vars = true }) -- loc是动态取得的/proxy1或者/proxy2
if res.status ~= ngx.HTTP_OK then
content = '{"error": "proxy error", "error_code": 2}'
ngx.header['Connection'] = 'close'
ngx.header['Content-Length'] = #content
ngx.header['Pragma'] = 'no-cache'
ngx.print(content)
ngx.flush(true)
ngx.exit(ngx.HTTP_SERVICE_UNAVAILABLE)
end

for k, v in pairs(res.header) do
ngx.header[k] = v
end

ngx.print(res.body)

问题：
这种处理，ngx.location.capture如果是get一个大文件时必须等所有都收齐了才能ngx.print出去，怎样才能一边收一边回传？？

--

Membhis

My github: https://github.com/membphis

Our Book: OpenResty Best Practices

wonghoifung85

具体是怎么做的？

On Thursday, July 30, 2015 at 5:44:49 PM UTC+8, YuanSheng Wang wrote:

我们是在 "dispatch.lua" 中调用ngx.exec(....) 的方式完成的。

http://wiki.nginx.org/HttpLuaModule#ngx.exec

On Thu, Jul 30, 2015 at 5:17 PM, Hoifung Wong <wongho...@gmail.com> wrote:
nginx配置：
location / {
content_by_lua_file '$APP_PATH/dispatch.lua';
}
location ^~ /proxy1 {
proxy_pass http://10.10.159.249:8282$request_uri;
}
location ^~ /proxy2 {
proxy_pass http://10.10.159.247:8282$request_uri;
}

dispatch.lua内有：
local res = ngx.location.capture(loc, { method = method, always_forward_body = true, copy_all_vars = true }) -- loc是动态取得的/proxy1或者/proxy2
if res.status ~= ngx.HTTP_OK then
content = '{"error": "proxy error", "error_code": 2}'
ngx.header['Connection'] = 'close'
ngx.header['Content-Length'] = #content
ngx.header['Pragma'] = 'no-cache'
ngx.print(content)
ngx.flush(true)
ngx.exit(ngx.HTTP_SERVICE_UNAVAILABLE)
end

for k, v in pairs(res.header) do
ngx.header[k] = v
end

ngx.print(res.body)

问题：
这种处理，ngx.location.capture如果是get一个大文件时必须等所有都收齐了才能ngx.print出去，怎样才能一边收一边回传？？

--

--

Membhis
My github: https://github.com/membphis
Our Book: OpenResty Best Practices

membphis

看这里api说明：

http://wiki.nginx.org/HttpLuaModule#ngx.exec

On Thu, Jul 30, 2015 at 7:22 PM, Hoifung Wong <wongho...@gmail.com> wrote:

具体是怎么做的？

On Thursday, July 30, 2015 at 5:44:49 PM UTC+8, YuanSheng Wang wrote:
我们是在 "dispatch.lua" 中调用ngx.exec(....) 的方式完成的。

http://wiki.nginx.org/HttpLuaModule#ngx.exec

On Thu, Jul 30, 2015 at 5:17 PM, Hoifung Wong <wongho...@gmail.com> wrote:
nginx配置：
location / {
content_by_lua_file '$APP_PATH/dispatch.lua';
}
location ^~ /proxy1 {
proxy_pass http://10.10.159.249:8282$request_uri;
}
location ^~ /proxy2 {
proxy_pass http://10.10.159.247:8282$request_uri;
}

dispatch.lua内有：
local res = ngx.location.capture(loc, { method = method, always_forward_body = true, copy_all_vars = true }) -- loc是动态取得的/proxy1或者/proxy2
if res.status ~= ngx.HTTP_OK then
content = '{"error": "proxy error", "error_code": 2}'
ngx.header['Connection'] = 'close'
ngx.header['Content-Length'] = #content
ngx.header['Pragma'] = 'no-cache'
ngx.print(content)
ngx.flush(true)
ngx.exit(ngx.HTTP_SERVICE_UNAVAILABLE)
end

for k, v in pairs(res.header) do
ngx.header[k] = v
end

ngx.print(res.body)

问题：
这种处理，ngx.location.capture如果是get一个大文件时必须等所有都收齐了才能ngx.print出去，怎样才能一边收一边回传？？

--

--

Membhis
My github: https://github.com/membphis
Our Book: OpenResty Best Practices

Membhis

My github: https://github.com/membphis

Our Book: OpenResty Best Practices

wonghoifung85

搞定了，晕，直接替换capture就行，比想象中简单。。。

On Thursday, July 30, 2015 at 9:44:44 PM UTC+8, YuanSheng Wang wrote:

看这里api说明：
http://wiki.nginx.org/HttpLuaModule#ngx.exec

On Thu, Jul 30, 2015 at 7:22 PM, Hoifung Wong <wongho...@gmail.com> wrote:
具体是怎么做的？

On Thursday, July 30, 2015 at 5:44:49 PM UTC+8, YuanSheng Wang wrote:
我们是在 "dispatch.lua" 中调用ngx.exec(....) 的方式完成的。

http://wiki.nginx.org/HttpLuaModule#ngx.exec

On Thu, Jul 30, 2015 at 5:17 PM, Hoifung Wong <wongho...@gmail.com> wrote:
nginx配置：
location / {
content_by_lua_file '$APP_PATH/dispatch.lua';
}
location ^~ /proxy1 {
proxy_pass http://10.10.159.249:8282$request_uri;
}
location ^~ /proxy2 {
proxy_pass http://10.10.159.247:8282$request_uri;
}

dispatch.lua内有：
local res = ngx.location.capture(loc, { method = method, always_forward_body = true, copy_all_vars = true }) -- loc是动态取得的/proxy1或者/proxy2
if res.status ~= ngx.HTTP_OK then
content = '{"error": "proxy error", "error_code": 2}'
ngx.header['Connection'] = 'close'
ngx.header['Content-Length'] = #content
ngx.header['Pragma'] = 'no-cache'
ngx.print(content)
ngx.flush(true)
ngx.exit(ngx.HTTP_SERVICE_UNAVAILABLE)
end

for k, v in pairs(res.header) do
ngx.header[k] = v
end

ngx.print(res.body)

问题：
这种处理，ngx.location.capture如果是get一个大文件时必须等所有都收齐了才能ngx.print出去，怎样才能一边收一边回传？？

--

--

Membhis
My github: https://github.com/membphis
Our Book: OpenResty Best Practices

--

Membhis
My github: https://github.com/membphis
Our Book: OpenResty Best Practices