Redis进阶-lua脚本
文章目錄
- Pre
- 語法
- jedis操作lua
- 好處
- lua實戰(zhàn)
- 注意事項
Pre
Redis在2.6推出了腳本功能,允許開發(fā)者使用Lua語言編寫腳本傳到Redis中執(zhí)行。
語法
從Redis2.6.0版本開始,通過內(nèi)置的Lua解釋器,可以使用EVAL命令對Lua腳本進行求值。
EVAL命令的格式如下:
EVAL script numkeys key [key ...] arg [arg ...]-
script參數(shù)是一段Lua腳本程序,它會被運行在Redis服務(wù)器上下文中,這段腳本不必(也不應(yīng)該)定義為一個Lua函數(shù)。
-
numkeys參數(shù)用于指定鍵名參數(shù)的個數(shù)
-
鍵名參數(shù) key [key …] 從EVAL的第三個參數(shù)開始算起,表示在腳本中所用到的那些Redis鍵(key),這些鍵名參數(shù)可以在 Lua中通過全局變量KEYS數(shù)組,用1為基址的形式訪問( KEYS[1] , KEYS[2] ,以此類推)
-
在命令的最后,那些不是鍵名參數(shù)的附加參數(shù) arg [arg …] ,可以在Lua中通過全局變量ARGV數(shù)組訪問訪問的形式和KEYS變量類似( ARGV[1] 、 ARGV[2] ,諸如此類)
舉例
127.0.0.1:6379> EVAL "return {KEYS[1],KEYS[2],ARGV[1],ARGV[2]}" 2 key1 key2 value1 value2 1) "key1" 2) "key2" 3) "value1" 4) "value2" 127.0.0.1:6379>必須是大寫哈,小寫報錯 。
127.0.0.1:6379> EVAL "return {keys[1],keys[2],argv[1],argv[2]}" 2 key1 key2 value1 value2 (error) ERR Error running script (call to f_8cfd66635a33779a52579a216e55263704ce398a): @enable_strict_lua:15: user_script:1: Script attempted to access nonexistent global variable 'keys' 127.0.0.1:6379>其中 “return {KEYS[1],KEYS[2],ARGV[1],ARGV[2]}” 是被求值的Lua腳本,數(shù)字2指定了鍵名參數(shù)的數(shù)量, key1和key2是鍵名參數(shù),分別使用 KEYS[1] 和 KEYS[2] 訪問,而最后的 value1和 value2則是附加參數(shù),可以通過 ARGV[1] 和 ARGV[2] 訪問它們。
jedis操作lua
在 Lua 腳本中,可以使用redis.call()函數(shù)來執(zhí)行Redis命令
public class JedisSingleTest {public static void main(String[] args) throws IOException {JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();jedisPoolConfig.setMaxTotal(20);jedisPoolConfig.setMaxIdle(10);jedisPoolConfig.setMinIdle(5);// timeout,這里既是連接超時又是讀寫超時,從Jedis 2.8開始有區(qū)分connectionTimeout和soTimeout的構(gòu)造函數(shù)JedisPool jedisPool = new JedisPool(jedisPoolConfig, "192.168.18.130", 6379, 3000, null);Jedis jedis = null;try {//從redis連接池里拿出一個連接執(zhí)行命令jedis = jedisPool.getResource();//******* lua腳本示例 ********//模擬一個商品減庫存的原子操作//lua腳本命令執(zhí)行方式:redis-cli --eval /tmp/test.lua , 10jedis.set("product_stock_10016", "15"); //初始化商品10016的庫存// lua腳本String script = " local count = redis.call('get', KEYS[1]) " +" local a = tonumber(count) " +" local b = tonumber(ARGV[1]) " +" if a >= b then " +" redis.call('set', KEYS[1], count-b) " +//模擬語法報錯回滾操作" bb == 0 " +" return 1 " +" end " +" return 0 ";// eval調(diào)用, 第一個參數(shù)為 KEYS[1]) , 第二個參數(shù)為ARGV[1]Object obj = jedis.eval(script, Arrays.asList("product_stock_10016"), Arrays.asList("10"));System.out.println(obj);} catch (Exception e) {e.printStackTrace();} finally {//注意這里不是關(guān)閉連接,在JedisPool模式下,Jedis會被歸還給資源池。if (jedis != null)jedis.close();}} }
好處
-
減少網(wǎng)絡(luò)開銷
假設(shè)你有3條命令要執(zhí)行,本來3次的網(wǎng)絡(luò)開銷,使用lua可以用一個請求完成,原先3次請求的邏輯放在redis服務(wù)器上完成。使用腳本,減少了網(wǎng)絡(luò)往返時延。這點跟管道類似。
-
原子操作
redis會將整個腳本作為一個整體執(zhí)行,中間不會被其他命令插入。管道不是原子的,不過redis的批量操作命令(類似mset)是原子的。
-
替代redis的事務(wù)功能
redis自帶的事務(wù)功能很雞肋,報錯不支持回滾,而redis的lua腳本幾乎實現(xiàn)了常規(guī)的事務(wù)功能,支持報錯回滾操作,官方推薦如果要使用redis的事務(wù)功能可以用redis lua替代。
lua實戰(zhàn)
高并發(fā)-【搶紅包案例】之四:使用Redis+Lua腳本實現(xiàn)搶紅包并異步持久化到數(shù)據(jù)庫
注意事項
注意,不要在Lua腳本中出現(xiàn)死循環(huán)和耗時的運算,否則redis會阻塞,將不接受其他的命令, 所以使用時要注意不能出現(xiàn)死循環(huán)、耗時的運算。
redis是單進程、單線程執(zhí)行腳本。管道不會阻塞redis。
總結(jié)
以上是生活随笔為你收集整理的Redis进阶-lua脚本的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Redis进阶-细说分布式锁
- 下一篇: Redis进阶- Redisson分布式