如何在Redis中執(zhí)行Lua腳本?
Redis中需要執(zhí)行Lua腳本的場(chǎng)景
Redis中每條命令都是原子性的,即執(zhí)行結(jié)果要么全部成功要么全部失敗。在某些業(yè)務(wù)場(chǎng)景下,需要執(zhí)行多條命令,并且要保證多條命令的原子性。這時(shí),如果命令逐條執(zhí)行,顯然是不能保證原子性的。有同學(xué)可能會(huì)想到使用Redis的事務(wù)功能,事務(wù)是可以保證原子性,但是受限于命令的功能,有些場(chǎng)景下并不能實(shí)現(xiàn)想要的功能。
使用執(zhí)行Lua腳本的方式可以解決以上問(wèn)題,Lua腳本整體上在Redis中是原子性的。
在Redis中執(zhí)行Lua腳本
在Redis中通過(guò)EVAL命令來(lái)執(zhí)行Lua腳本,基本語(yǔ)法如下:
參數(shù)說(shuō)明:
- script: 參數(shù)是一段Lua腳本程序。腳本不必(也不應(yīng)該)定義為一個(gè) Lua 函數(shù)。
- numkeys: 用于指定鍵名參數(shù)的個(gè)數(shù)。
- key [key ...]: 從 EVAL 的第三個(gè)參數(shù)開(kāi)始算起,表示在腳本中所用到的那些 Redis 鍵(key),這些鍵名參數(shù)可以在 Lua 中通過(guò)全局變量 KEYS 數(shù)組,用 1 為基址的形式訪(fǎng)問(wèn)( KEYS[1] , KEYS[2] ,以此類(lèi)推)。
- arg [arg ...]: 附加參數(shù),在 Lua 中通過(guò)全局變量 ARGV 數(shù)組訪(fǎng)問(wèn),訪(fǎng)問(wèn)的形式和 KEYS 變量類(lèi)似( ARGV[1] 、 ARGV[2] ,諸如此類(lèi))。
獲取指定key的值,相當(dāng)于于 GET somekey
再看一個(gè)LPUSH的例子,相當(dāng)于 LPUSH somelist 1 2 3
簡(jiǎn)單說(shuō)下Redis執(zhí)行l(wèi)ua腳本相關(guān)的其他幾個(gè)命令:
- EVALSHA命令根據(jù)給定的SHA1,執(zhí)行緩存在服務(wù)器中的腳本。
- SCRIPT EXISTS命令用于檢查指定SHA1值對(duì)應(yīng)的腳本是否在Redis緩存中。
- SCRIPT FLUSH命令用于清除所有的緩存腳本。
- SCRIPT KILL命令用于殺死當(dāng)前正在運(yùn)行的 Lua 腳本,當(dāng)且僅當(dāng)這個(gè)腳本沒(méi)有執(zhí)行過(guò)任何寫(xiě)操作時(shí),這個(gè)命令才生效。這個(gè)命令主要用于終止運(yùn)行時(shí)間過(guò)長(zhǎng)的腳本,比如一個(gè)因?yàn)?BUG 而發(fā)生無(wú)限循環(huán)的腳本。SCRIPT KILL 執(zhí)行之后,當(dāng)前正在運(yùn)行的腳本會(huì)被殺死,執(zhí)行這個(gè)腳本的客戶(hù)端會(huì)從 EVAL 命令的阻塞當(dāng)中退出,并收到一個(gè)錯(cuò)誤作為返回值。
Lua腳本中調(diào)用Reids命令
調(diào)用Redis命令,當(dāng)執(zhí)行出錯(cuò)時(shí),該方法會(huì)直接返回錯(cuò)誤,并退出。
調(diào)用Redis命令,當(dāng)執(zhí)行出錯(cuò)時(shí),記錄錯(cuò)誤信息,并繼續(xù)執(zhí)行。
記錄日志,寫(xiě)入到Redis配置的日志文件中,日志級(jí)別有四種,分別是redis.LOG_DEBUG、redis.LOG_VERBOS、redis.LOG_NOTICE和redis.LOG_WARNING。
計(jì)算輸入字符串的sha1哈希值。
Lua與Redis類(lèi)型轉(zhuǎn)換
Redis調(diào)用Lua腳本,腳本執(zhí)行完成后將結(jié)果返回給Redis,Redis再將結(jié)果返回給客戶(hù)端。這個(gè)過(guò)程中會(huì)出現(xiàn)Redis執(zhí)行結(jié)果類(lèi)型到Lua數(shù)據(jù)類(lèi)型的轉(zhuǎn)換,然后Lua類(lèi)型到Redis類(lèi)型的轉(zhuǎn)換。Redis類(lèi)型到Lua類(lèi)型轉(zhuǎn)換關(guān)系如下:
Redis返回的數(shù)據(jù)類(lèi)型 | Lua數(shù)據(jù)類(lèi)型 |
integer(整數(shù)回復(fù)) | number(數(shù)字類(lèi)型) |
bulk replay(字符串) | string(字符串類(lèi)型) |
多行字符串 | table(數(shù)組形式) |
status(狀態(tài)回復(fù)) | table(只有一個(gè)ok字段的數(shù)組) |
error(錯(cuò)誤回復(fù)) | table(只有一個(gè)err字段的數(shù)組) |
Lua類(lèi)型到Redis類(lèi)型轉(zhuǎn)換關(guān)系如下:
Lua數(shù)據(jù)類(lèi)型 | Redis返回?cái)?shù)據(jù)類(lèi)型 |
number(數(shù)字類(lèi)型) | integer(整數(shù)回復(fù)) |
string(字符串類(lèi)型) | bulk replay(字符串) |
table(數(shù)組形式) | 多行字符串 |
table(只有一個(gè)ok字段的數(shù)組) | status(狀態(tài)回復(fù)) |
table(只有一個(gè)err字段的數(shù)組) | error(錯(cuò)誤回復(fù)) |