如果在balancer_by_lua中设置set_current_peer没成功时，直接返回自定义的651错误，该怎么做？

wangwei4514 · 2016-03-22T13:45:49+00:00

local function _from_length_coded_bin(data, pos) local first = strbyte(data, pos) --print("LCB: first: ", first) if not first th...

如果在balancer_by_lua中设置set_current_peer没成功时，直接返回自定义的651错误，该怎么做？

wangwei4514

有这样一个场景，

后端有很多机器，其中每个机器都与一个域名一一对应，如：

{
 {
   machine_name : A
   domain:www.123.com
 }
 {
   machine_name : B 
   domain:www.456.com
 }
 .......
}

每次转发时都会从request中提取host，如果能匹配具体的机器就进行转发，如果不能匹配就返回自定义的651错误。

请问应该怎么做？

yuansheng

2016-03-22 13:45 GMT+08:00 <wangw...@gmail.com>:

有这样一个场景，
后端有很多机器，其中每个机器都与一个域名一一对应，如：
{ { machine_name : A domain:www.123.com } { machine_name : B domain:www.456.com } ....... }

每次转发时都会从request中提取host，如果能匹配具体的机器就进行转发，如果不能匹配就返回自定义的651错误。
请问应该怎么做？

先把域名、机器信息加载到 resty-lrucache 当中（原理类似，也可以放在 share dict 或缓存数据库中），业务代码可以考虑挂载到 rewrite 阶段（例如：rewrite_by_lua_block）。

请求进入时，判断当前请求域名是否可以在 resty-lrucache 中命中。

* 如果命中：直接重定向或 proxy 代理

* 如果不命中：ngx.exit(651)

有个小问题，自定义错误 651 不是 HTTP 标准错误码，不推荐使用。有标准，尽量靠拢到标准上，4** 客户端问题，5** 服务端问题，可以在这里找一个更贴切的应答码。

--

YuanSheng Wang

---------------------------------------

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

OpenResty lover ^_^

wangwei4514

感谢回复。

我昨天试了一个版本，将业务代码挂载在access_by_lua_file中，这应该也是可以的吧？

首先在access_by_lua_file中通过host找到后端entities，后端的格式如下，然后在balancer_by_lua_file中从entities里面选择一个host：port执行

{
  {
   host:127.0.0.1,
   port:8000
  }
 {
   host:127.0.0.1,
   port:8001
 }
}

我现在的方案是在access_by_lua_file中将entities存在ngx.var中，然后再balancer_by_lua_file阶段将ngx.var.entities的数据取出处理？请问这个方案的效率怎么样？

access_by_lua_file中的数据要传到balancer_by_lua_file中有什么比较好的办法吗？

谢谢

在 2016年3月23日星期三 UTC+8上午9:58:09，YuanSheng写道：

2016-03-22 13:45 GMT+08:00 <wangw...@gmail.com>:
有这样一个场景，
后端有很多机器，其中每个机器都与一个域名一一对应，如：
{ { machine_name : A domain:www.123.com } { machine_name : B domain:www.456.com } ....... }

每次转发时都会从request中提取host，如果能匹配具体的机器就进行转发，如果不能匹配就返回自定义的651错误。
请问应该怎么做？

先把域名、机器信息加载到 resty-lrucache 当中（原理类似，也可以放在 share dict 或缓存数据库中），业务代码可以考虑挂载到 rewrite 阶段（例如：rewrite_by_lua_block）。

请求进入时，判断当前请求域名是否可以在 resty-lrucache 中命中。

* 如果命中：直接重定向或 proxy 代理
* 如果不命中：ngx.exit(651)

有个小问题，自定义错误 651 不是 HTTP 标准错误码，不推荐使用。有标准，尽量靠拢到标准上，4** 客户端问题，5** 服务端问题，可以在这里找一个更贴切的应答码。

--

--

YuanSheng Wang
---------------------------------------
My Github: https://github.com/membphis
OpenResty lover ^_^

doujiang24

Hello,

在 2016年3月23日下午4:06， <wangw...@gmail.com>写道：

access_by_lua_file中的数据要传到balancer_by_lua_file中有什么比较好的办法吗？

用 ngx.ctx 比较好

https://github.com/openresty/lua-nginx-module/#ngxctx

谢谢

在 2016年3月23日星期三 UTC+8上午9:58:09，YuanSheng写道：

2016-03-22 13:45 GMT+08:00 <wangw...@gmail.com>:
有这样一个场景，
后端有很多机器，其中每个机器都与一个域名一一对应，如：
{ { machine_name : A domain:www.123.com } { machine_name : B domain:www.456.com } ....... }

每次转发时都会从request中提取host，如果能匹配具体的机器就进行转发，如果不能匹配就返回自定义的651错误。
请问应该怎么做？

先把域名、机器信息加载到 resty-lrucache 当中（原理类似，也可以放在 share dict 或缓存数据库中），业务代码可以考虑挂载到 rewrite 阶段（例如：rewrite_by_lua_block）。

请求进入时，判断当前请求域名是否可以在 resty-lrucache 中命中。

* 如果命中：直接重定向或 proxy 代理
* 如果不命中：ngx.exit(651)

有个小问题，自定义错误 651 不是 HTTP 标准错误码，不推荐使用。有标准，尽量靠拢到标准上，4** 客户端问题，5** 服务端问题，可以在这里找一个更贴切的应答码。

--

--

YuanSheng Wang
---------------------------------------
My Github: https://github.com/membphis
OpenResty lover ^_^

--

wangwei4514

ok，感谢

还有个问题，我在header_filter_by_lua中加入了如下代码，如果upstream返回502，我就想把502变为654

{
      if ngx.status == 502 then
    ngx.status = 654
    ngx.log(ngx.ERR, "ngx.status : ", ngx.status)
  end
}

当我执行ngx.log(ngx.ERR, "ngx.status : ", ngx.status)的时候，为什么还是返回的502，而不是654？

在 2016年3月23日星期三 UTC+8下午8:20:40，doujiang写道：

Hello,

在 2016年3月23日下午4:06， <wangw...@gmail.com>写道：
access_by_lua_file中的数据要传到balancer_by_lua_file中有什么比较好的办法吗？

用 ngx.ctx 比较好

https://github.com/openresty/lua-nginx-module/#ngxctx

谢谢

在 2016年3月23日星期三 UTC+8上午9:58:09，YuanSheng写道：

2016-03-22 13:45 GMT+08:00 <wangw...@gmail.com>:
有这样一个场景，
后端有很多机器，其中每个机器都与一个域名一一对应，如：
{ { machine_name : A domain:www.123.com } { machine_name : B domain:www.456.com } ....... }

每次转发时都会从request中提取host，如果能匹配具体的机器就进行转发，如果不能匹配就返回自定义的651错误。
请问应该怎么做？

先把域名、机器信息加载到 resty-lrucache 当中（原理类似，也可以放在 share dict 或缓存数据库中），业务代码可以考虑挂载到 rewrite 阶段（例如：rewrite_by_lua_block）。

请求进入时，判断当前请求域名是否可以在 resty-lrucache 中命中。

* 如果命中：直接重定向或 proxy 代理
* 如果不命中：ngx.exit(651)

有个小问题，自定义错误 651 不是 HTTP 标准错误码，不推荐使用。有标准，尽量靠拢到标准上，4** 客户端问题，5** 服务端问题，可以在这里找一个更贴切的应答码。

--

--

YuanSheng Wang
---------------------------------------
My Github: https://github.com/membphis
OpenResty lover ^_^

--

agentzh

Hello!

2016-03-23 6:17 GMT-07:00  wangwei4514:
> 还有个问题，我在header_filter_by_lua中加入了如下代码，如果upstream返回502，我就想把502变为654
> {
>       if ngx.status == 502 then
>     ngx.status = 654
>     ngx.log(ngx.ERR, "ngx.status : ", ngx.status)
>   end
> }
>
> 当我执行ngx.log(ngx.ERR, "ngx.status : ", ngx.status)的时候，为什么还是返回的502，而不是654？

多谢报告！刚刚已经在 lua-nginx-module 的 git 仓库中修复了这个问题：

    https://github.com/openresty/lua-nginx-module/commit/93321acd

值得一提的是，你这里使用下面的配置貌似更合适一些：

    header_filter_by_lua_block {
        if ngx.status == 502 then
            return ngx.exit(654)
        end
    }

因为你原先的代码只修改了响应的状态码，而并没有影响到响应体。当然，如果响应体已经是你想要的了，那直接修改 ngx.status 也挺合适的。

Best regards,
-agentzh

wangwei4514

多谢春哥，我需要修改响应体，准备在body_filter_by_lua_block中修改

如果在header_filter_by_lua_block中返回了ngx.exit(654)，那body_filter_by_lua_block还会执行吗？

我看wiki中写到ngx.exit(status)，当status >=200时，会中断当前的请求，而status=0，则是退出当前阶段(如header_filter_by_lua_file)

我之前是这样写的

header_filter_by_lua_block {

if ngx.status == 502 then

ngx.status = 654

ngx.header.content_length = nil (如果这里不将content_length置为空，那么在body_filter_by_lua_block中修改响应体后，就一直处于转圈中，无法输出结果，感觉是不是破坏了body的结构)

ngx.exit(ngx.OK)

end

}

body_filter_by_lua_block {

if ngx.status == 502 then

ngx.arg[1] = "123456"

end

}

在 2016年3月28日星期一 UTC+8上午11:23:10，agentzh写道：

Hello!

2016-03-23 6:17 GMT-07:00 wangwei4514:
> 还有个问题，我在header_filter_by_lua中加入了如下代码，如果upstream返回502，我就想把502变为654
> {
> if ngx.status == 502 then
> ngx.status = 654
> ngx.log(ngx.ERR, "ngx.status : ", ngx.status)
> end
> }
>
> 当我执行ngx.log(ngx.ERR, "ngx.status : ", ngx.status)的时候，为什么还是返回的502，而不是654？

多谢报告！刚刚已经在 lua-nginx-module 的 git 仓库中修复了这个问题：

https://github.com/openresty/lua-nginx-module/commit/93321acd

值得一提的是，你这里使用下面的配置貌似更合适一些：

header_filter_by_lua_block {
if ngx.status == 502 then
return ngx.exit(654)
end
}

因为你原先的代码只修改了响应的状态码，而并没有影响到响应体。当然，如果响应体已经是你想要的了，那直接修改 ngx.status 也挺合适的。

Best regards,
-agentzh

guanglinlv

你讲content_length置为空是正确的做法，也是必须的，当你要修改响应体大小时；

详细看：https://github.com/openresty/lua-nginx-module#body_filter_by_lua

When the Lua code may change the length of the response body, then it is required to always clear out the Content-Lengthresponse header (if any) in a header filter to enforce streaming output, as in

不改的话，响应体就会定界失败了。

在 2016年3月28日星期一 UTC+8下午1:52:37，wangw...@gmail.com写道：

多谢春哥，我需要修改响应体，准备在body_filter_by_lua_block中修改
如果在header_filter_by_lua_block中返回了ngx.exit(654)，那body_filter_by_lua_block还会执行吗？
我看wiki中写到ngx.exit(status)，当status >=200时，会中断当前的请求，而status=0，则是退出当前阶段(如header_filter_by_lua_file)

我之前是这样写的
header_filter_by_lua_block {
if ngx.status == 502 then
ngx.status = 654
ngx.header.content_length = nil (如果这里不将content_length置为空，那么在body_filter_by_lua_block中修改响应体后，就一直处于转圈中，无法输出结果，感觉是不是破坏了body的结构)
ngx.exit(ngx.OK)
end
}
body_filter_by_lua_block {
if ngx.status == 502 then
ngx.arg[1] = "123456"
end
}

在 2016年3月28日星期一 UTC+8上午11:23:10，agentzh写道：
Hello!

2016-03-23 6:17 GMT-07:00 wangwei4514:
> 还有个问题，我在header_filter_by_lua中加入了如下代码，如果upstream返回502，我就想把502变为654
> {
> if ngx.status == 502 then
> ngx.status = 654
> ngx.log(ngx.ERR, "ngx.status : ", ngx.status)
> end
> }
>
> 当我执行ngx.log(ngx.ERR, "ngx.status : ", ngx.status)的时候，为什么还是返回的502，而不是654？

多谢报告！刚刚已经在 lua-nginx-module 的 git 仓库中修复了这个问题：

https://github.com/openresty/lua-nginx-module/commit/93321acd

值得一提的是，你这里使用下面的配置貌似更合适一些：

header_filter_by_lua_block {
if ngx.status == 502 then
return ngx.exit(654)
end
}

因为你原先的代码只修改了响应的状态码，而并没有影响到响应体。当然，如果响应体已经是你想要的了，那直接修改 ngx.status 也挺合适的。

Best regards,
-agentzh

wangwei4514

嗯，谢谢解惑

在 2016年3月28日星期一 UTC+8下午3:38:50，Guanglin Lv写道：

你讲content_length置为空是正确的做法，也是必须的，当你要修改响应体大小时；

详细看：https://github.com/openresty/lua-nginx-module#body_filter_by_lua

When the Lua code may change the length of the response body, then it is required to always clear out the Content-Lengthresponse header (if any) in a header filter to enforce streaming output, as in

不改的话，响应体就会定界失败了。

在 2016年3月28日星期一 UTC+8下午1:52:37，wangw...@gmail.com写道：
多谢春哥，我需要修改响应体，准备在body_filter_by_lua_block中修改
如果在header_filter_by_lua_block中返回了ngx.exit(654)，那body_filter_by_lua_block还会执行吗？
我看wiki中写到ngx.exit(status)，当status >=200时，会中断当前的请求，而status=0，则是退出当前阶段(如header_filter_by_lua_file)

我之前是这样写的
header_filter_by_lua_block {
if ngx.status == 502 then
ngx.status = 654
ngx.header.content_length = nil (如果这里不将content_length置为空，那么在body_filter_by_lua_block中修改响应体后，就一直处于转圈中，无法输出结果，感觉是不是破坏了body的结构)
ngx.exit(ngx.OK)
end
}
body_filter_by_lua_block {
if ngx.status == 502 then
ngx.arg[1] = "123456"
end
}

在 2016年3月28日星期一 UTC+8上午11:23:10，agentzh写道：
Hello!

2016-03-23 6:17 GMT-07:00 wangwei4514:
> 还有个问题，我在header_filter_by_lua中加入了如下代码，如果upstream返回502，我就想把502变为654
> {
> if ngx.status == 502 then
> ngx.status = 654
> ngx.log(ngx.ERR, "ngx.status : ", ngx.status)
> end
> }
>
> 当我执行ngx.log(ngx.ERR, "ngx.status : ", ngx.status)的时候，为什么还是返回的502，而不是654？

多谢报告！刚刚已经在 lua-nginx-module 的 git 仓库中修复了这个问题：

https://github.com/openresty/lua-nginx-module/commit/93321acd

值得一提的是，你这里使用下面的配置貌似更合适一些：

header_filter_by_lua_block {
if ngx.status == 502 then
return ngx.exit(654)
end
}

因为你原先的代码只修改了响应的状态码，而并没有影响到响应体。当然，如果响应体已经是你想要的了，那直接修改 ngx.status 也挺合适的。

Best regards,
-agentzh

382482175

有个疑问，为啥要在rewrite/access阶段找节点而不是直接在balancer_by_lua_file中找呢？这样也没有数据的传递啥的。

在 2016年3月23日星期三 UTC+8下午4:06:34，wangw...@gmail.com写道：

感谢回复。
我昨天试了一个版本，将业务代码挂载在access_by_lua_file中，这应该也是可以的吧？
首先在access_by_lua_file中通过host找到后端entities，后端的格式如下，然后在balancer_by_lua_file中从entities里面选择一个host：port执行
{ { host:127.0.0.1, port:8000 } { host:127.0.0.1, port:8001 } }

我现在的方案是在access_by_lua_file中将entities存在ngx.var中，然后再balancer_by_lua_file阶段将ngx.var.entities的数据取出处理？请问这个方案的效率怎么样？
access_by_lua_file中的数据要传到balancer_by_lua_file中有什么比较好的办法吗？
谢谢

在 2016年3月23日星期三 UTC+8上午9:58:09，YuanSheng写道：

2016-03-22 13:45 GMT+08:00 <wangw...@gmail.com>:
有这样一个场景，
后端有很多机器，其中每个机器都与一个域名一一对应，如：
{ { machine_name : A domain:www.123.com } { machine_name : B domain:www.456.com } ....... }

每次转发时都会从request中提取host，如果能匹配具体的机器就进行转发，如果不能匹配就返回自定义的651错误。
请问应该怎么做？

先把域名、机器信息加载到 resty-lrucache 当中（原理类似，也可以放在 share dict 或缓存数据库中），业务代码可以考虑挂载到 rewrite 阶段（例如：rewrite_by_lua_block）。

请求进入时，判断当前请求域名是否可以在 resty-lrucache 中命中。

* 如果命中：直接重定向或 proxy 代理
* 如果不命中：ngx.exit(651)

有个小问题，自定义错误 651 不是 HTTP 标准错误码，不推荐使用。有标准，尽量靠拢到标准上，4** 客户端问题，5** 服务端问题，可以在这里找一个更贴切的应答码。

--

--

YuanSheng Wang
---------------------------------------
My Github: https://github.com/membphis
OpenResty lover ^_^