Redis中使用Lua控制事務(wù)

業(yè)務(wù)場景

說明:object1對象存在很多key,如k1、k2...kn,且對象存在ttl時間,到期會被自動刪除
1、判斷object1 hash對象是否存在
2、若對象存在,則只更新k1字段
3、若對象不存在,則需要將其他字段同時寫入
4、重新更新object1的ttl時間
以上操作需要在同一個事務(wù)中操作,若進行第2步操作時,ttl剛好到期,則會出現(xiàn)只有k1字段的object1。

在這里,使用watch+multi做不到監(jiān)控對象到期,考慮了一下,決定使用lua進行原子操作。
當(dāng)然,不需要所有的邏輯都放到lua腳本里,只需要實現(xiàn)判斷object1對象是否存在,若存在則暫時清理ttl時間。

Lua腳本

local key = KEYS[1]
local isexist = redis.call("exists",key)
if(isexist == 1) then
    redis.call("persist",key)
end
return isexist

驗證

127.0.0.1:6379> expire bbb 100
(integer) 1
127.0.0.1:6379> ttl bbb
(integer) 98

執(zhí)行l(wèi)ua查詢
$redis-cli --eval t.lua bbb
(integer) 1

127.0.0.1:6379> ttl bbb
(integer) -1
127.0.0.1:6379> 

注冊腳本

$redis-cli script load "`cat t.lua`"
"c1540490eb505d23336f03189c9dd2876578b0bc"

使用SHA-1標識符查詢
$redis-cli evalsha c1540490eb505d23336f03189c9dd2876578b0bc 1 bbb
(integer) 1

判斷SHA-1是否存在
$redis-cli script exists c1540490eb505d23336f03189c9dd2876578b0bc
1) (integer) 1

調(diào)試腳本

$redis-cli --ldb --eval t.lua bbb
Lua debugging session started, please use:
quit    -- End the session.
restart -- Restart the script in debug mode again.
help    -- Show Lua script debugging commands.

* Stopped at 1, stop reason = step over
-> 1   local key = KEYS[1]
lua debugger> s
* Stopped at 2, stop reason = step over
-> 2   local isexist = redis.call("exists",key)
lua debugger> s
<redis> exists bbb
<reply> 1
* Stopped at 3, stop reason = step over
-> 3   if(isexist == 1) then
lua debugger> p isexist
<value> 1
lua debugger> s
* Stopped at 4, stop reason = step over
-> 4       redis.call("persist",key)
lua debugger> s
<redis> persist bbb
<reply> 0
* Stopped at 6, stop reason = step over
-> 6   return isexist
lua debugger> s

(integer) 1

(Lua debugging session ended -- dataset changes rolled back)

127.0.0.1:6379> 

使用邏輯

Lua腳本在Redis重啟后會自動消失,程序的處理流程為:
1、首次啟用時,若沒有Lua SHA-1,則將腳本注冊到Redis
由于腳本內(nèi)容相同時,重復(fù)注冊獲取到大SHA也是唯一的,可暫不考慮保存SHA-1
2、Redis重連時,將SHA置空,下次訪問時,重新注冊。
3、若Redis重連在公共包中,程序不知道是否重連的情況下,可在運行過程中判斷是否出現(xiàn)
“(error) NOSCRIPT No matching script. Please use EVAL.”報錯信息,出現(xiàn)時,重新注冊。

程序?qū)崿F(xiàn)邏輯不在此文實現(xiàn)。
說明:由于Lua中沒有sleep功能,不易呈現(xiàn)key到期時的查詢,只能簡單測試,只能通過業(yè)務(wù)場景中出現(xiàn)的幾率判斷。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容