项目启动唯一的定时器，不知道在nginx负载高的时候，会不会时间上有延迟？

1loto9s · 2014-12-29T21:06:07+00:00

Hello! 2015-01-02 14:04 GMT-08:00 Yichun Zhang (agentzh): > 29s 的 redis 操作是毁灭性的，因&#...

项目启动唯一的定时器，不知道在nginx负载高的时候，会不会时间上有延迟？

1loto9s

-- nginx conf 配置

error_log  logs/error.log  notice;

lua_shared_dict config 1m;
init_worker_by_lua_file shark/worker.lua;

--- worker代码

local cronService = require "classes.service.cronService"
local ngx_shared = ngx.shared
local os_date = os.date
local tonumber = tonumber
local ngx = ngx
local ngx_timer_at = ngx.timer.at
local ngx_log = ngx.log

local function doRun()
    local ok, err = ngx_timer_at(60, doRun)

    if not ok then
        ngx_log(ngx.ERR, "doRun timer err:", err)
        return
    end

    cronService:exec()
end

if not ngx_shared.config:get('hasTimer') then
    ngx_shared.config:set('hasTimer', true)
    local diff = 60 - tonumber(os_date("%S"))
    local ok, err = ngx_timer_at(diff, doRun)

    if not ok then
        ngx_log(ngx.ERR, "first run timer err:", err)
        return
    else
        ngx_log(ngx.ERR, "first run timer diff:", diff)
    end
end


-- cronService 主逻辑

local function refreshRank(desc)
    ngx.log(ngx.ERR, "run timer", desc)
end

function CronService:exec()

    local nowTime = os_time()

    local currWeek = tonumber(os_date("%w", nowTime))
    local currHour = tonumber(os_date("%H", nowTime))
    local currMinute = tonumber(os_date("%M", nowTime))

    local function run(callback, execWeek, execHour, execMinute, ...)
        local execWeek = execWeek or nil
        local execHour = execHour or nil
        local execMinute = execMinute or nil

        if (execWeek == nil or currWeek == tonumber(execWeek)) and
                (execHour == nil or currHour == tonumber(execHour)) and
                (execMinute == nil or currMinute == tonumber(execMinute)) then

            local args = { ... } or {}
            local status, err = pcall(callback, unpack(args, 1, table_maxn(args)))

            if not status then
                ngx.log(ngx.ERR, "run timer error", err, "execWeek", execWeek, "execHour", execHour, "execMinute", execMinute, "debug_traces", debug_traceback())
            end
        end
    end

    -- 每分钟
    run(refreshRank, nil, nil, nil, "每分钟执行")

    -- 每小时
    run(refreshRank, nil, nil, 0, "每小时执行")

    -- 每天0点0分
    run(refreshRank, nil, 0, 0, "每天执行")
end

-- error.log

2014/12/29 20:57:00 [error] 18069#0: [lua] cronService.lua:14: run timer每分钟执行, context: ngx.timer
2014/12/29 20:58:00 [error] 18069#0: [lua] cronService.lua:14: run timer每分钟执行, context: ngx.timer
2014/12/29 20:59:00 [error] 18069#0: [lua] cronService.lua:14: run timer每分钟执行, context: ngx.timer
2014/12/29 21:00:00 [error] 18069#0: [lua] cronService.lua:14: run timer每分钟执行, context: ngx.timer
2014/12/29 21:00:00 [error] 18069#0: [lua] cronService.lua:14: run timer每小时执行, context: ngx.timer
2014/12/29 21:01:00 [error] 18069#0: [lua] cronService.lua:14: run timer每分钟执行, context: ngx.timer

agentzh

Hello!

只要你的 nginx worker 进程没有耗尽系统的 CPU 资源，同时没有进行延时较大的阻塞的文件 IO 操作，则定时器的精度是足够好的（毫秒级）。

值得一提的是，如果你创建 cronjob 似的循环定时器，则应当在每一个 timer handler
的开头就首先创建下一个定时器，否则的话你在 timer handler 里执行的其他任务会让下一个定时器的创建延后。

Regards,
-agentzh

P.S. 请不要把邮件标题用作正文，谢谢合作！

1loto9s

Hello！

我想问一下，如何才能确定只启动一个定时器，我现在用了shared存储一个临时变量，在reload时，shared不会重置

所以还必须要在init_by_lua里flush_all worker才能正常启动定时器

有没有打算在ngx.worker,xx提供一个子进程的序号而非pid，类似ngx.worker.index == 0

邮件标题的问题下次会注意的，不好意思

在 2014年12月30日星期二UTC+8上午4时22分06秒，agentzh写道：

Hello!

只要你的 nginx worker 进程没有耗尽系统的 CPU 资源，同时没有进行延时较大的阻塞的文件 IO 操作，则定时器的精度是足够好的（毫秒级）。

值得一提的是，如果你创建 cronjob 似的循环定时器，则应当在每一个 timer handler
的开头就首先创建下一个定时器，否则的话你在 timer handler 里执行的其他任务会让下一个定时器的创建延后。

Regards,
-agentzh

P.S. 请不要把邮件标题用作正文，谢谢合作！

membphis

> 我想问一下，如何才能确定只启动一个定时器，。。。。。。

如果你需要的是在多worker的场景下只启动一个定时器，可以使用这个api：

http://wiki.nginx.org/HttpLuaModule#ngx.shared.DICT.add

返回成功的，就可以启动定时器，否则退出即可。

On Tuesday, December 30, 2014 9:57:35 AM UTC+8, Xiaohui Sun wrote:

Hello！

我想问一下，如何才能确定只启动一个定时器，我现在用了shared存储一个临时变量，在reload时，shared不会重置

所以还必须要在init_by_lua里flush_all worker才能正常启动定时器

有没有打算在ngx.worker,xx提供一个子进程的序号而非pid，类似ngx.worker.index == 0

邮件标题的问题下次会注意的，不好意思

在 2014年12月30日星期二UTC+8上午4时22分06秒，agentzh写道：
Hello!

只要你的 nginx worker 进程没有耗尽系统的 CPU 资源，同时没有进行延时较大的阻塞的文件 IO 操作，则定时器的精度是足够好的（毫秒级）。

值得一提的是，如果你创建 cronjob 似的循环定时器，则应当在每一个 timer handler
的开头就首先创建下一个定时器，否则的话你在 timer handler 里执行的其他任务会让下一个定时器的创建延后。

Regards,
-agentzh

P.S. 请不要把邮件标题用作正文，谢谢合作！

pumulu

院生，

你提供了这个API，是想表明全局存储是否创建定时器的标志？还是我没看懂？

在 2014年12月31日星期三 UTC+8下午1:32:21，YuanSheng Wang写道：

> 我想问一下，如何才能确定只启动一个定时器，。。。。。。

如果你需要的是在多worker的场景下只启动一个定时器，可以使用这个api：
http://wiki.nginx.org/HttpLuaModule#ngx.shared.DICT.add

返回成功的，就可以启动定时器，否则退出即可。

On Tuesday, December 30, 2014 9:57:35 AM UTC+8, Xiaohui Sun wrote:
Hello！

我想问一下，如何才能确定只启动一个定时器，我现在用了shared存储一个临时变量，在reload时，shared不会重置

所以还必须要在init_by_lua里flush_all worker才能正常启动定时器

有没有打算在ngx.worker,xx提供一个子进程的序号而非pid，类似ngx.worker.index == 0

邮件标题的问题下次会注意的，不好意思

在 2014年12月30日星期二UTC+8上午4时22分06秒，agentzh写道：
Hello!

只要你的 nginx worker 进程没有耗尽系统的 CPU 资源，同时没有进行延时较大的阻塞的文件 IO 操作，则定时器的精度是足够好的（毫秒级）。

值得一提的是，如果你创建 cronjob 似的循环定时器，则应当在每一个 timer handler
的开头就首先创建下一个定时器，否则的话你在 timer handler 里执行的其他任务会让下一个定时器的创建延后。

Regards,
-agentzh

P.S. 请不要把邮件标题用作正文，谢谢合作！

anymaybe

在 2014年12月30日星期二 UTC+8上午9:57:35，Xiaohui Sun写道：

Hello！

我想问一下，如何才能确定只启动一个定时器，我现在用了shared存储一个临时变量，在reload时，shared不会重置

所以还必须要在init_by_lua里flush_all worker才能正常启动定时器

是的，reload时共享内存不会清理的，若需要，需要自己主动flush。

另外，建议你对自己的timer做保活，这样就不用关心这些了。

保活方法可以是，每个worker启动一个守护定时器. 通过shared dict检查时间戳。过期则守护定时器抢占标记并升级为业务定时器。

有没有打算在ngx.worker,xx提供一个子进程的序号而非pid，类似ngx.worker.index == 0

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

邮件标题的问题下次会注意的，不好意思

在 2014年12月30日星期二UTC+8上午4时22分06秒，agentzh写道：
Hello!

只要你的 nginx worker 进程没有耗尽系统的 CPU 资源，同时没有进行延时较大的阻塞的文件 IO 操作，则定时器的精度是足够好的（毫秒级）。

值得一提的是，如果你创建 cronjob 似的循环定时器，则应当在每一个 timer handler
的开头就首先创建下一个定时器，否则的话你在 timer handler 里执行的其他任务会让下一个定时器的创建延后。

Regards,
-agentzh

P.S. 请不要把邮件标题用作正文，谢谢合作！