openresty跑定時任務配置、ngx.timer.every接口使用

openresty的定時任務是要跟worker綁定的。如果不綁定特定的worker，那么所有啟動的woker都會去執行定時任務。

一般情況下默認綁定worker_id=0的，這樣在nginx整個進程里面，就只執行一個timer。

在conf中具體的位置可以寫自己的任務邏輯。

具體的nginx.conf配置如下：

worker_processes  1;
error_log logs/error.log;
events {
    worker_connections 1024;
}


http {
    init_worker_by_lua_block { local delay = 2  -- in seconds local new_timer = ngx.timer.at local log = ngx.log local ERR = ngx.ERR local check check = function(premature) if not premature then -- do the health check or other routine work log(ERR, "mm test mm test") local ok, err = new_timer(delay, check) if not ok then log(ERR, "failed to create timer: ", err) return end end end if 0 == ngx.worker.id() then local ok, err = new_timer(delay, check) if not ok then log(ERR, "failed to create timer: ", err) return end end }

    server {
        listen 8081;
        location / {
            default_type text/html;
            content_by_lua '
                ngx.say("<p>hello, world</p>")
            ';
        }

        location = /app/test {
            content_by_lua_block {
                local res = ngx.location.capture(
                                "/sum", {args={a=3, b=8}}
                                )
                ngx.say("status:", res.status, " response:", res.body)
            }
        }
        location = /sum {
            internal;
            content_by_lua_block {
                ngx.sleep(0.1)
                local args = ngx.req.get_uri_args()
                ngx.print(tonumber(args.a) + tonumber(args.b))
            }
        }

        location = /subduction {
            internal;
            content_by_lua_block {
                ngx.sleep(0.1)
                local args = ngx.req.get_uri_args()
                ngx.print(tonumber(args.a) - tonumber(args.b))
            }
        }

        location = /app/test_parallels {
            content_by_lua_block {
                local start_time = ngx.now()
                local res1, res2 = ngx.location.capture_multi( {
                                {"/sum", {args={a=3, b=8}}},
                                {"/subduction", {args={a=3, b=8}}}
                            })
                ngx.say("status:", res1.status, " response:", res1.body)
                ngx.say("status:", res2.status, " response:", res2.body)
                ngx.say("time used:", ngx.now() - start_time)
            }
        }

        location = /app/test_queue {
            content_by_lua_block {
                local start_time = ngx.now()
                local res1 = ngx.location.capture_multi( {
                                {"/sum", {args={a=3, b=8}}}
                            })
                local res2 = ngx.location.capture_multi( {
                                {"/subduction", {args={a=3, b=8}}}
                            })
                ngx.say("status:", res1.status, " response:", res1.body)
                ngx.say("status:", res2.status, " response:", res2.body)
                ngx.say("time used:", ngx.now() - start_time)
            }
        }
}
}

 

注意init_worker_by_lua_block是放在http里面的。因為此處只配置了error.log，因此是打印的err級別的日志，方便觀察。

接下來啟動ngin：sudo nginx -p `pwd`/ -c conf/nginx.conf

然后tailf logs/error.log:

追日志會發現，每隔2s就會打印一條日志。

 二、使用ngx.timer.every接口

ngx提供了最新的ngx.timer.every接口，再來試一下：

    init_worker_by_lua_block {
         local delay = 2  -- in seconds
         -- local new_timer = ngx.timer.at
         local log = ngx.log
         local ERR = ngx.ERR
         local check

         check = function(premature)
             if not premature then
                 -- do the health check or other routine work
                 log(ERR, "mm test mm test")
                 -- local ok, err = new_timer(delay, check)
                 -- if not ok then
                 --     log(ERR, "failed to create timer: ", err)
                 --     return
                 --  end
             end
         end

         if 0 == ngx.worker.id() then
             local ok, err = ngx.timer.every(delay, check)
             if not ok then
                 log(ERR, "failed to create timer: ", err)
                 return
             end
         end
    }