ngx_lua 能否在支持长连接的，情况进行异步处理

kobe00712 · 2013-09-16T11:41:15+00:00

Congratulations! 2013/9/16 Yichun Zhang (agentzh) <age...@gmail.com>: > Hello folks! > > I am happy to announce that the new mainline version...

ngx_lua 能否在支持长连接的，情况进行异步处理

kobe00712

hi all

ngx.eof 需要把keeplive 设置0 ，但是很多情况下，需要在在长连接下，发送异步请求，或者进行其他的异步处理请问，有没有什么办法解决这个问题

agentzh

Hello!

2013/9/15 kobe zhang:
>            ngx.eof 需要把keeplive 设置0

调用 ngx.eof() 并不会自动禁用当前下游连接的 HTTP keepalive.

> ，但是很多情况下，需要在在长连接下，发送异步请求，或者进行其他的异步处理请问，有没有什么办法解决这个问题
>

对于在 HTTP keepalive 的场景下脱离当前请求进行后台异步处理，调用 ngx.eof() 并不是正确的做法；正确的做法是使用
ngx.timer.at():

    http://wiki.nginx.org/HttpLuaModule#ngx.timer.at

这里你应当使用 0 延时的 timer.

Regards,
-agentzh

kobe00712

hi 春哥：

ngx,time.at 中的无法使用ngx.capture.location 那么如何这样不就是无法发送异步请求

在 2013年9月16日上午11:46，Yichun Zhang (agentzh) <age...@gmail.com>写道：

Hello!

2013/9/15 kobe zhang:
> ngx.eof 需要把keeplive 设置0

调用 ngx.eof() 并不会自动禁用当前下游连接的 HTTP keepalive.

> ，但是很多情况下，需要在在长连接下，发送异步请求，或者进行其他的异步处理请问，有没有什么办法解决这个问题
>

对于在 HTTP keepalive 的场景下脱离当前请求进行后台异步处理，调用 ngx.eof() 并不是正确的做法；正确的做法是使用
ngx.timer.at():

http://wiki.nginx.org/HttpLuaModule#ngx.timer.at

这里你应当使用 0 延时的 timer.

Regards,
-agentzh

--

kobe00712

我这边需要异步的使用ngx.capture.location 发送新的请求，但是ngx_lua的文档中说，在ngx.time.at 中无法使用ngx.capture.location 类似的指令，请问春哥这样的问题如何解决

在 2013年9月16日下午3:07，kobe zhang <kobe...@gmail.com>写道：

hi 春哥：

ngx,time.at 中的无法使用ngx.capture.location 那么如何这样不就是无法发送异步请求

在 2013年9月16日上午11:46，Yichun Zhang (agentzh) <age...@gmail.com>写道：

Hello!

2013/9/15 kobe zhang:
> ngx.eof 需要把keeplive 设置0

调用 ngx.eof() 并不会自动禁用当前下游连接的 HTTP keepalive.

> ，但是很多情况下，需要在在长连接下，发送异步请求，或者进行其他的异步处理请问，有没有什么办法解决这个问题
>

对于在 HTTP keepalive 的场景下脱离当前请求进行后台异步处理，调用 ngx.eof() 并不是正确的做法；正确的做法是使用
ngx.timer.at():

http://wiki.nginx.org/HttpLuaModule#ngx.timer.at

这里你应当使用 0 延时的 timer.

Regards,
-agentzh

--

agentzh

Hello!

2013/9/16 kobe zhang:
>    我这边需要异步的使用ngx.capture.location 发送新的请求，但是ngx_lua的文档中说，在ngx.time.at
> 中无法使用ngx.capture.location 类似的指令，请问春哥这样的问题如何解决
>

很简单：避免在 timer 回调中使用 nginx 子请求进行后端访问，而使用那些基于 cosocket API 的 lua-resty-*
库，比如 lua-resty-redis 和 lua-resty-mysql.

nginx 子请求本来就有很多的限制。

Regards,
-agentzh

kobe00712

hi 春哥：那么如果发送http 请求的话，是不是只能使用http_resty_http ，这个包在生产环境中可以使用么。另外能不能在tima.at 下使用ngx.thread.spawn，包装一个ngx.location.capture_multi 来解决的这个问题

在 2013年9月17日上午2:02，Yichun Zhang (agentzh) <age...@gmail.com>写道：

Hello!

2013/9/16 kobe zhang:

> 我这边需要异步的使用ngx.capture.location 发送新的请求，但是ngx_lua的文档中说，在ngx.time.at
> 中无法使用ngx.capture.location 类似的指令，请问春哥这样的问题如何解决
>

很简单：避免在 timer 回调中使用 nginx 子请求进行后端访问，而使用那些基于 cosocket API 的 lua-resty-*
库，比如 lua-resty-redis 和 lua-resty-mysql.

nginx 子请求本来就有很多的限制。

Regards,
-agentzh

--

agentzh

Hello!

2013/9/16 kobe zhang:
> 春哥：那么如果发送http 请求的话，是不是只能使用http_resty_http ，这个包在生产环境中可以使用么。

眼下我推荐使用 Brian Akins 的 lua-resty-http-simple 库：

    https://github.com/bakins/lua-resty-http-simple

或者 bsm 的实现：

    https://github.com/bsm/lua-resty-http

如果你遇到问题，你也可以直接和它们的作者联系。

未来我可能会添加一个官方版的 lua-resty-http 库的实现，但不是现在 :)

> 另外能不能在tima.at
> 下使用ngx.thread.spawn，包装一个ngx.location.capture_multi 来解决的这个问题
>

你可以在 ngx.timer.at 回调的上下文中使用 ngx.thread
API，但不能使用子请求。因为在这种上下文中并不存在“请求”，所以“子请求”在逻辑上也没有意义。从实现的角度讲，在这种上下文中摸似一个假的主请求以便使用“子请求”也是无法做到足够可靠的。

Regards,
-agentzh

kobe00712

Hi 能否使用thread api 包装 lua-resty-http-simple 或bsm ，这样方便并发处理

在 2013年9月18日上午2:54，Yichun Zhang (agentzh) <age...@gmail.com>写道：

Hello!

2013/9/16 kobe zhang:

> 春哥：那么如果发送http 请求的话，是不是只能使用http_resty_http ，这个包在生产环境中可以使用么。

眼下我推荐使用 Brian Akins 的 lua-resty-http-simple 库：

https://github.com/bakins/lua-resty-http-simple

或者 bsm 的实现：

https://github.com/bsm/lua-resty-http

如果你遇到问题，你也可以直接和它们的作者联系。

未来我可能会添加一个官方版的 lua-resty-http 库的实现，但不是现在 :)

> 另外能不能在tima.at
> 下使用ngx.thread.spawn，包装一个ngx.location.capture_multi 来解决的这个问题
>

你可以在 ngx.timer.at 回调的上下文中使用 ngx.thread
API，但不能使用子请求。因为在这种上下文中并不存在“请求”，所以“子请求”在逻辑上也没有意义。从实现的角度讲，在这种上下文中摸似一个假的主请求以便使用“子请求”也是无法做到足够可靠的。

Regards,
-agentzh

--

agentzh

Hello!

2013/9/17 kobe zhang:
> Hi 能否使用thread api 包装 lua-resty-http-simple 或bsm ，这样方便并发处理
>

nginx 的 ngx.thread API 可以直接和这些库一起工作，无需对这些库进行任何修改。你只需要在各个 ngx.thread
里面创建自己的 resty.* 对象，各请求各的即可以了。

切记，不要在多个 ngx.thread 之间共享 resty.* 对象，否则在并发请求时会得到 socket busy 的错误。

Regards,
-agentzh