Re: 答复: lua-nginx-module请教

agentzh · 2014-04-17T07:03:32+00:00

Hi:你可以 patch 一下这个 commit：https://github.com/openresty/lua-nginx-module/commit/f64ec8c9056437bb1b822fc...

Re: 答复: lua-nginx-module请教

agentzh

Hello!

2014-04-16 4:30 GMT-07:00 Miaochuanjie:
> Coroutine.running()应该就是当前协程，但是调yield方法不起作用。
>
> location /redis-sub {
>             content_by_lua '
>                ngx.say(“before yield”)
> coroutine.yield()--或者coroutine.yield(coroutine.running())
> ngx.say(“after yield”)

你的 content_by_lua 里的 Lua 代码默认运行在一个“轻量级线程”中。直接对轻量级线程作 coroutine.yield
会很快被轻量级线程调度器重新 resume，即它不会跨越一个协程调度周期，更不可能跨越当前的 epoll 事件调度周期。

> 我想在收到请求的时候用lua挂住连接，等某个异步事件发生的时候再response回去，请教一下用法。
>
> 比如：
>
> location /redis-sub {
>             content_by_lua '
>                hold request…
>             ';
>         }
> content_by_lua对应的执行体是在一个协程里面运行，假如我能获取这个协程本身，然后调用yeild方法然后在异步事件发生时再resume就应该能解决，
>
> 但是不知道怎样获取这个协程对象，用self、this都不行。

对于你这里的场景，需要提醒的是，轻量级线程的作用域是当前的请求处理程序，所以更不可能跨请求对轻线程直接进行操作。当然，你还要小心 nginx
一般会配置多个 worker 进程，而每个 worker 进程的 Lua VM 自然是彼此隔离的（你只能通过共享内存或者远方的 socket
服务来共享数据和状态）。

同时抄送给 openresty 中文邮件列表：https://groups.google.com/group/openresty

建议你也加入此列表并在那里讨论这样的问题。谢谢合作！

Regards,
-agentzh

mchuanjie

谢谢你的提醒，那有没有其他办法可以在lua层面或者nginx层面挂住连接，然后在需要的时候恢复呢？

谢谢！

在 2014年4月17日星期四UTC+8上午7时03分32秒，agentzh写道：

Hello!

2014-04-16 4:30 GMT-07:00 Miaochuanjie:
> Coroutine.running()应该就是当前协程，但是调yield方法不起作用。
>
> location /redis-sub {
> content_by_lua '
> ngx.say(“before yield”)
> coroutine.yield()--或者coroutine.yield(coroutine.running())
> ngx.say(“after yield”)

你的 content_by_lua 里的 Lua 代码默认运行在一个“轻量级线程”中。直接对轻量级线程作 coroutine.yield
会很快被轻量级线程调度器重新 resume，即它不会跨越一个协程调度周期，更不可能跨越当前的 epoll 事件调度周期。

> 我想在收到请求的时候用lua挂住连接，等某个异步事件发生的时候再response回去，请教一下用法。
>
> 比如：
>
> location /redis-sub {
> content_by_lua '
> hold request…
> ';
> }
> content_by_lua对应的执行体是在一个协程里面运行，假如我能获取这个协程本身，然后调用yeild方法然后在异步事件发生时再resume就应该能解决，
>
> 但是不知道怎样获取这个协程对象，用self、this都不行。

对于你这里的场景，需要提醒的是，轻量级线程的作用域是当前的请求处理程序，所以更不可能跨请求对轻线程直接进行操作。当然，你还要小心 nginx
一般会配置多个 worker 进程，而每个 worker 进程的 Lua VM 自然是彼此隔离的（你只能通过共享内存或者远方的 socket
服务来共享数据和状态）。

同时抄送给 openresty 中文邮件列表：https://groups.google.com/group/openresty

建议你也加入此列表并在那里讨论这样的问题。谢谢合作！

Regards,
-agentzh

agentzh

Hello!

2014-04-16 18:12 GMT-07:00  mchuanjie:
> 谢谢你的提醒，那有没有其他办法可以在lua层面或者nginx层面挂住连接，然后在需要的时候恢复呢？
>

可以通过下面两种方法之一来实现同步等待。

1. 等在 cosocket 的 receive 调用上，比如结合 redis 的 pubsub API.
2. 使用 ngx.sleep() 自己按一定步长休眠，定时检查当前状态（比如 lua-resty-lock 库就采取的这种策略实现跨
nginx worker 进程的全局锁）。

Regards,
-agentzh