ngx.worker.id()在cache manager进程也返回0的问题

xiaooolooong · 2016-01-05T16:13:09+00:00

感谢建议。学习了。在 2016年1月10日星期日 UTC+8上&#x5348...

ngx.worker.id()在cache manager进程也返回0的问题

xiaooolooong

意图将某个定时器只绑定到一个worker上，于是如下配置

nginx.conf中配置 init_worker_by_lua_file init_worker.lua

在init_worker.lua中：

if ngx.worker.id() ~= 0 then return end

--定义定时器--

local hander

hander = function (premature)

if premature then

log(ngx.ALERT, 'worker exiting. gooebye, timer.')

return

end

ngx.timer.at(5, hander)

log(ngx.ALERT, 'timer is running now at worker : ' .. ngx.worker.pid())

--调用定时器--

ngx.timer.at(0, hander)

结果发现同时运行了两个timer，分别位于第一个worker进程和cache manager进程

2016/01/05 16:07:07 [alert] 16823#0: [lua] init_master.lua:17: log(): timer is running now at worker : 16823, context: ngx.timer

2016/01/05 16:07:07 [alert] 16831#0: [lua] init_master.lua:17: log(): timer is running now at worker : 16831, context: ngx.timer

请教一下，在ngx.worker.id()相同的情况下，如何区分呢？

yuansheng

这是个已知问题， ngx.worker.id() 的 value 取自 nginx 的 CPU 亲缘性绑定 value 。而 cache manager 与 worker(0) 的值是一样的。

这样可以使用 ngx.worker.id() == 1 或其他大于 0 的 worker id 来做你需要的事情。

例如，绑定到 id() 为 1 的 worker 上面：

if ngx.worker.id() == 1 then

....

end

2016-01-05 16:13 GMT+08:00 xiaooloong <xiaoo...@gmail.com>:

意图将某个定时器只绑定到一个worker上，于是如下配置
nginx.conf中配置 init_worker_by_lua_file init_worker.lua

在init_worker.lua中：

if ngx.worker.id() ~= 0 then return end
--定义定时器--
local hander
hander = function (premature)
if premature then
log(ngx.ALERT, 'worker exiting. gooebye, timer.')
return
end
ngx.timer.at(5, hander)
log(ngx.ALERT, 'timer is running now at worker : ' .. ngx.worker.pid())
--调用定时器--
ngx.timer.at(0, hander)

结果发现同时运行了两个timer，分别位于第一个worker进程和cache manager进程
2016/01/05 16:07:07 [alert] 16823#0: [lua] init_master.lua:17: log(): timer is running now at worker : 16823, context: ngx.timer
2016/01/05 16:07:07 [alert] 16831#0: [lua] init_master.lua:17: log(): timer is running now at worker : 16831, context: ngx.timer

请教一下，在ngx.worker.id()相同的情况下，如何区分呢？

--

YuanSheng Wang

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

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

OpenResty lover ^_^

xiaooolooong

感谢

最开始是定义了一个lua_shared_dict timer_pid 64k;

在init_master_by_lua内ngx.shared.timer_pid:set('pid', nil)，

然后在init_worker_by_lua_file内开头，让worker去抢注timer_pid

local timer_pid = ngx.worker.pid()

local ok = ngx.shared.timer_pid:add('pid', timer_pid)

if ok then

judge.log('registed timer to worker '.. timer_pid)

else

judge.log('timer exists at worker ' .. ngx.shared.timer_pid:get('pid'))

return

end

的方法实现唯一的timer的。后来发现1.9提供了ngx.worker.id，就偷懒了，没想到还是有问题 :p

在 2016年1月5日星期二 UTC+8下午4:17:59，YuanSheng写道：

这是个已知问题， ngx.worker.id() 的 value 取自 nginx 的 CPU 亲缘性绑定 value 。而 cache manager 与 worker(0) 的值是一样的。

这样可以使用 ngx.worker.id() == 1 或其他大于 0 的 worker id 来做你需要的事情。

例如，绑定到 id() 为 1 的 worker 上面：

if ngx.worker.id() == 1 then
....
end

2016-01-05 16:13 GMT+08:00 xiaooloong <xiaooo...@gmail.com>:
意图将某个定时器只绑定到一个worker上，于是如下配置
nginx.conf中配置 init_worker_by_lua_file init_worker.lua

在init_worker.lua中：

if ngx.worker.id() ~= 0 then return end
--定义定时器--
local hander
hander = function (premature)
if premature then
log(ngx.ALERT, 'worker exiting. gooebye, timer.')
return
end
ngx.timer.at(5, hander)
log(ngx.ALERT, 'timer is running now at worker : ' .. ngx.worker.pid())
--调用定时器--
ngx.timer.at(0, hander)

结果发现同时运行了两个timer，分别位于第一个worker进程和cache manager进程
2016/01/05 16:07:07 [alert] 16823#0: [lua] init_master.lua:17: log(): timer is running now at worker : 16823, context: ngx.timer
2016/01/05 16:07:07 [alert] 16831#0: [lua] init_master.lua:17: log(): timer is running now at worker : 16831, context: ngx.timer

请教一下，在ngx.worker.id()相同的情况下，如何区分呢？

--

--

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

zhengxiaochuan-3

开启 nginx cache 功能的话不只 cache manager，在启动时，还会有 cache load 进程，id 也是0哦。

zhengxi...@163.com

发件人： xiaooloong
发送时间： 2016-01-05 17:17
收件人： openresty
主题： Re: [openresty] ngx.worker.id()在cache manager进程也返回0的问题
感谢
最开始是定义了一个lua_shared_dict timer_pid 64k;
在init_master_by_lua内ngx.shared.timer_pid:set('pid', nil)，
然后在init_worker_by_lua_file内开头，让worker去抢注timer_pid
local timer_pid = ngx.worker.pid()
local ok = ngx.shared.timer_pid:add('pid', timer_pid)
if ok then
judge.log('registed timer to worker '.. timer_pid)
else
judge.log('timer exists at worker ' .. ngx.shared.timer_pid:get('pid'))
return
end
的方法实现唯一的timer的。后来发现1.9提供了ngx.worker.id，就偷懒了，没想到还是有问题 :p

在 2016年1月5日星期二 UTC+8下午4:17:59，YuanSheng写道：

这是个已知问题， ngx.worker.id() 的 value 取自 nginx 的 CPU 亲缘性绑定 value 。而 cache manager 与 worker(0) 的值是一样的。

这样可以使用 ngx.worker.id() == 1 或其他大于 0 的 worker id 来做你需要的事情。

例如，绑定到 id() 为 1 的 worker 上面：

if ngx.worker.id() == 1 then
....
end

2016-01-05 16:13 GMT+08:00 xiaooloong <xiaooo...@gmail.com>:
意图将某个定时器只绑定到一个worker上，于是如下配置
nginx.conf中配置 init_worker_by_lua_file init_worker.lua

在init_worker.lua中：

if ngx.worker.id() ~= 0 then return end
--定义定时器--
local hander
hander = function (premature)
if premature then
log(ngx.ALERT, 'worker exiting. gooebye, timer.')
return
end
ngx.timer.at(5, hander)
log(ngx.ALERT, 'timer is running now at worker : ' .. ngx.worker.pid())
--调用定时器--
ngx.timer.at(0, hander)

结果发现同时运行了两个timer，分别位于第一个worker进程和cache manager进程
2016/01/05 16:07:07 [alert] 16823#0: [lua] init_master.lua:17: log(): timer is running now at worker : 16823, context: ngx.timer
2016/01/05 16:07:07 [alert] 16831#0: [lua] init_master.lua:17: log(): timer is running now at worker : 16831, context: ngx.timer

请教一下，在ngx.worker.id()相同的情况下，如何区分呢？

--

--

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

--

yuansheng

> 最开始是定义了一个lua_shared_dict timer_pid 64k;

> 在init_master_by_lua内ngx.shared.timer_pid:set('pid', nil)，

> 然后在init_worker_by_lua_file内开头，让worker去抢注timer_pid

这种方式的缺点是如果当前 worker 崩溃掉了，其他 worker 无法把运行权限抢回来。长时间运行会比较悲剧。需要写很多代码来避免这种情况。

目前 ngx-lua-module 只是 nginx 的一个模块，以目前nginx暴露的变量，的确没有更合适的变量来唯一标识的完成这个目的。

你可以看下内部实现源码。

2016-01-05 17:17 GMT+08:00 xiaooloong <xiaoo...@gmail.com>:

感谢
最开始是定义了一个lua_shared_dict timer_pid 64k;
在init_master_by_lua内ngx.shared.timer_pid:set('pid', nil)，
然后在init_worker_by_lua_file内开头，让worker去抢注timer_pid
local timer_pid = ngx.worker.pid()
local ok = ngx.shared.timer_pid:add('pid', timer_pid)
if ok then
judge.log('registed timer to worker '.. timer_pid)
else
judge.log('timer exists at worker ' .. ngx.shared.timer_pid:get('pid'))
return
end
的方法实现唯一的timer的。后来发现1.9提供了ngx.worker.id，就偷懒了，没想到还是有问题 :p

在 2016年1月5日星期二 UTC+8下午4:17:59，YuanSheng写道：

这是个已知问题， ngx.worker.id() 的 value 取自 nginx 的 CPU 亲缘性绑定 value 。而 cache manager 与 worker(0) 的值是一样的。

这样可以使用 ngx.worker.id() == 1 或其他大于 0 的 worker id 来做你需要的事情。

例如，绑定到 id() 为 1 的 worker 上面：

if ngx.worker.id() == 1 then
....
end

2016-01-05 16:13 GMT+08:00 xiaooloong <xiaooo...@gmail.com>:
意图将某个定时器只绑定到一个worker上，于是如下配置
nginx.conf中配置 init_worker_by_lua_file init_worker.lua

在init_worker.lua中：

if ngx.worker.id() ~= 0 then return end
--定义定时器--
local hander
hander = function (premature)
if premature then
log(ngx.ALERT, 'worker exiting. gooebye, timer.')
return
end
ngx.timer.at(5, hander)
log(ngx.ALERT, 'timer is running now at worker : ' .. ngx.worker.pid())
--调用定时器--
ngx.timer.at(0, hander)

结果发现同时运行了两个timer，分别位于第一个worker进程和cache manager进程
2016/01/05 16:07:07 [alert] 16823#0: [lua] init_master.lua:17: log(): timer is running now at worker : 16823, context: ngx.timer
2016/01/05 16:07:07 [alert] 16831#0: [lua] init_master.lua:17: log(): timer is running now at worker : 16831, context: ngx.timer

请教一下，在ngx.worker.id()相同的情况下，如何区分呢？

--

--

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

--

YuanSheng Wang

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

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

OpenResty lover ^_^

zx68555

@春哥，各位openresty大神

又对redis 分布式做操作的库或者包没？最近调研想用openresty,线上服务器有四组redis,所以问下大家

zx6...@163.com

doujiang24

Hello,

2016-01-05 17:44 GMT+08:00 zx6...@163.com <zx6...@163.com>:

@春哥，各位openresty大神
又对redis 分布式做操作的库或者包没？最近调研想用openresty,线上服务器有四组redis,所以问下大家

首先，你的 redis 是如何部署的

简单的搞法，你可以直接基于 lua-resty-redis，再把你的 hash 规则实现了就行

如果是 redis-cluster 的话，那么最好基于 lua-resty-redis 实现 lua-resty-redis-cluster

zx6...@163.com

--