鍍金池/ 教程/ Java/ 定時任務(wù)
定時任務(wù)
函數(shù)的參數(shù)
超時
一個 openresty 內(nèi)存“泄漏”問題
獲取 uri 參數(shù)
局部變量
sleep
灰度發(fā)布
TIME_WAIT
代碼覆蓋率
連接池
CentOS 平臺安裝
稀疏數(shù)組
如何只啟動一個 timer 工作?
變量的共享范圍
break,return 關(guān)鍵字
Nginx
SQL 注入
如何引用第三方 resty 庫
不同階段共享變量
獲取請求 body
動態(tài)生成的 lua-resty-redis 模塊方法
動態(tài)加載證書和 OCSP stapling
repeat 控制結(jié)構(gòu)
編碼為 array 還是 object
Nginx 靜態(tài)文件服務(wù)
執(zhí)行階段概念
Lua 函數(shù)
日期時間函數(shù)
健康監(jiān)測
與其他 location 配合
for 控制結(jié)構(gòu)
函數(shù)定義
HTTPS 時代
點號與冒號操作符的區(qū)別
String 庫
文件操作
OpenResty 最佳實踐
<code>ngx.shared.DICT</code> 非隊列性質(zhì)
使用動態(tài) DNS 來完成 HTTP 請求
代碼規(guī)范
什么是 JIT?
Windows 平臺安裝
正確的記錄日志
LuaNginxModule
不用標(biāo)準(zhǔn)庫
C10K 編程
控制結(jié)構(gòu)
請求中斷后的處理
Lua 環(huán)境搭建
Test::Nginx 能指定現(xiàn)成的 nginx.conf,而不是自動生成一個嗎
Lua 基礎(chǔ)數(shù)據(jù)類型
動態(tài)限速
PostgresNginxModule
簡單API Server框架
API 測試
location 匹配規(guī)則
虛變量
單元測試
防止 SQL 注入
select + set_keepalive 組合操作引起的數(shù)據(jù)讀寫錯誤
阻塞操作
全動態(tài)函數(shù)調(diào)用
Web 服務(wù)
典型應(yīng)用場景
Nginx 新手起步
TLS session resumption
輸出響應(yīng)體
調(diào)用代碼前先定義函數(shù)
module 是邪惡的
怎樣理解 cosocket
模塊
Socket 編程發(fā)展
如何對 Nginx Lua module 添加新 api
如何在后臺開啟輕量級線程完成定時任務(wù)?
如何定位問題
table 庫
json 解析的異常捕獲
如何安裝火焰圖生成工具
lua 中如何 continue
if 是邪惡的
為什么我們的域名不能被解析
抵制使用 module() 定義模塊
測試
body 在 location 中的傳遞
Lua 入門
子查詢
pipeline 壓縮請求數(shù)量
如何發(fā)起新 HTTP 請求
Lua 簡介
緩存失效風(fēng)暴
Ubuntu 平臺安裝
日志輸出
緩存
Lua 面向?qū)ο缶幊?/span>
Nginx 陷阱和常見錯誤
Redis 接口的二次封裝(發(fā)布訂閱)
日志
訪問有授權(quán)驗證的 Redis
正則表達式
lock
熱裝載代碼
調(diào)用 FFI 出現(xiàn) &quot;table overflow&quot;
數(shù)據(jù)合法性檢測
禁止某些終端訪問
控制結(jié)構(gòu) if-else
調(diào)試
與 Docker 使用的網(wǎng)絡(luò)瓶頸
PostgresNginxModule 模塊的調(diào)用方式
用 do-end 整理你的代碼
FFI
什么時候使用
簡介
環(huán)境搭建
Mac OS X 平臺安裝
火焰圖
負載均衡
while 型控制結(jié)構(gòu)
如何定位 openresty 崩潰 bug
使用 Nginx 內(nèi)置綁定變量
判斷數(shù)組大小
請求返回后繼續(xù)執(zhí)行
Redis 接口的二次封裝
KeepAlive
反向代理
協(xié)議無痛升級
數(shù)學(xué)庫
元表
Vanilla 介紹
HelloWorld
LuaCjsonLibrary
持續(xù)集成
代碼靜態(tài)分析
網(wǎng)上有大量對 Lua 調(diào)優(yōu)的推薦,我們應(yīng)該如何看待?
script 壓縮復(fù)雜請求
非空判斷
性能測試
函數(shù)返回值
API 的設(shè)計
kong 介紹
表達式
不支持事務(wù)
LuaRestyDNSLibrary 簡介

定時任務(wù)

請求返回后繼續(xù)執(zhí)行章節(jié)中,我們介紹了一種實現(xiàn)的方法,這里我們 介紹一種更優(yōu)雅更通用的方法:ngx.timer.at()。 ngx.timer.at 會創(chuàng)建一個 Nginx timer。在事件循環(huán)中,Nginx 會找出到期的 timer,并在一個獨立的協(xié)程中執(zhí)行對應(yīng)的 Lua 回調(diào)函數(shù)。 有了這種機制,ngx_lua 的功能得到了非常大的擴展,我們有機會做一些更有想象力的功能出來。比如 批量提交和 cron 任務(wù)。隨便一提,官方的 resty-cli 工具,也是基于 ngx.timer.at 來運行指定的代碼塊。

比較典型的用法,如下示例:

local delay = 5
local handler
-- do some routine job in Lua just like a cron job
handler = function (premature)
    if premature then
        return
    end
    local ok, err = ngx.timer.at(delay, handler)
    if not ok then
        ngx.log(ngx.ERR, "failed to create the timer: ", err)
        return
    end
end

local ok, err = ngx.timer.at(delay, handler)
if not ok then
    ngx.log(ngx.ERR, "failed to create the timer: ", err)
    return
end

從示例代碼中我們可以看到,ngx.timer.at 創(chuàng)建的回調(diào)是一次性的。如果要實現(xiàn)“定期”運行,需要在回調(diào)函數(shù)中重新創(chuàng)建 timer 才行。不過當(dāng)前主線上的 OpenResty 已經(jīng)引入了新的 ngx.timer.every 接口,允許直接創(chuàng)建定期執(zhí)行的 timer。

ngx.timer.at 的 delay 參數(shù),指定的是以秒為單位的延遲觸發(fā)時間。跟 OpenResty 的其他函數(shù)一樣,指定的時間最多精確到毫秒。如果你想要的是一個當(dāng)前階段結(jié)束后立刻執(zhí)行的回調(diào),可以直接設(shè)置 delay 為 0。 handler 回調(diào)第一個參數(shù) premature,則是用于標(biāo)識觸發(fā)該回調(diào)的原因是否由于 timer 的到期。Nginx worker 的退出,也會觸發(fā)當(dāng)前所有有效的 timer。這時候 premature 會被設(shè)置為 true。回調(diào)函數(shù)需要正確處理這一參數(shù)(通常直接返回即可)。

需要特別注意的是:有一些 ngx_lua 的 API 不能在這里調(diào)用,比如子請求、ngx.req.*和向下游輸出的 API(ngx.print、ngx.flush 之類),原因是這些調(diào)用需要依賴具體的請求。但是 ngx.timer.at 自身的運行,與當(dāng)前的請求并沒有關(guān)系的。

再說一遍,ngx.timer.at 的執(zhí)行是在獨立的協(xié)程里完成的。千萬不能忽略這一點。有人可能會犯這樣的錯誤:

local tcpsock = create_tcp_client() -- 創(chuàng)建一個 cosocket 連接
local ok, err = ngx.timer.at(delay, function()
    tcpsock:send() -- bad request!
end)

cosocket 跟某個特定的 ngx_http_request_t* 綁定在一起的。雖然由于閉包,在回調(diào)函數(shù)中我們依舊可以訪問 tcpsock,但整個上下文已經(jīng)不一樣了。