openresty跑定时任务配置&启动

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)
		    }
		}
}
}