使用Lua腳本的好處
一、減小網絡開銷:能夠將多個請求經過腳本的形式一次發送,減小網絡時延和請求次數。
二、原子性的操做: Redis會將整個腳本做爲一個總體執行,中間不會被其餘命令插入。所以在編寫腳本的過程當中無需擔憂會出現競態條件,無需使用事務。
三、代碼複用:客戶端發送的腳步會永久存在redis中,這樣,其餘客戶端能夠複用這一腳原本完成相同的邏輯。
四、速度快:見 與其它語言的性能比較, 還有一個 JIT編譯器能夠顯著地提升多數任務的性能; 對於那些仍然對性能不滿意的人, 能夠把關鍵部分使用C實現, 而後與其集成, 這樣還能夠享受其它方面的好處。
五、能夠移植:只要是有ANSI C 編譯器的平臺均可以編譯,你能夠看到它能夠在幾乎全部的平臺上運行:從 Windows 到Linux,一樣Mac平臺也沒問題, 再到移動平臺、遊戲主機,甚至瀏覽器也能夠完美使用 (翻譯成JavaScript).
六、源碼小巧:20000行C代碼,能夠編譯進182K的可執行文件,加載快,運行快。
二、原子性的操做: Redis會將整個腳本做爲一個總體執行,中間不會被其餘命令插入。所以在編寫腳本的過程當中無需擔憂會出現競態條件,無需使用事務。
三、代碼複用:客戶端發送的腳步會永久存在redis中,這樣,其餘客戶端能夠複用這一腳原本完成相同的邏輯。
四、速度快:見 與其它語言的性能比較, 還有一個 JIT編譯器能夠顯著地提升多數任務的性能; 對於那些仍然對性能不滿意的人, 能夠把關鍵部分使用C實現, 而後與其集成, 這樣還能夠享受其它方面的好處。
五、能夠移植:只要是有ANSI C 編譯器的平臺均可以編譯,你能夠看到它能夠在幾乎全部的平臺上運行:從 Windows 到Linux,一樣Mac平臺也沒問題, 再到移動平臺、遊戲主機,甚至瀏覽器也能夠完美使用 (翻譯成JavaScript).
六、源碼小巧:20000行C代碼,能夠編譯進182K的可執行文件,加載快,運行快。
eval 命令
(1)首先須要瞭解Redis eval 命令:
eval 命令也會將腳本添加到腳本緩存中,可是它會當即對輸入的腳本進行求值。
eg
EVAL script numkeys key [key ...] arg [arg ...]
script參數是一段Lua腳本程序,它會被運行在Redis服務器上下文中,這段腳本沒必要(也不該該)定義爲一個Lua函數。
numkeys參數用於指定鍵名參數的個數。
鍵名參數 key [key ...] 從EVAL的第三個參數開始算起,表示在腳本中所用到的那些Redis鍵(key),這些鍵名參數能夠在 Lua中經過全局變量KEYS數組,用1爲基址的形式訪問( KEYS[1] , KEYS[2] ,以此類推)。
在命令的最後,那些不是鍵名參數的附加參數 arg [arg ...] ,能夠在Lua中經過全局變量ARGV數組訪問,訪問的形式和KEYS變量相似( ARGV[1] 、 ARGV[2] ,諸如此類)
如:
eval "return {KEYS[1],KEYS[2],ARGV[1],ARGV[2]}" 2 username age jack 20
![](http://static.javashuo.com/static/loading.gif)
![](http://static.javashuo.com/static/loading.gif)
![](http://static.javashuo.com/static/loading.gif)
通常java運行lua腳本,採用的也是相似上述表達式,後面描述java
(2)對於一段長的lua腳本,能夠將腳本放在一個文件中,經過以下命令執行lua腳本redis
$ redis-cli --eval path/to/redis.lua KEYS[1] KEYS[2] , ARGV[1] ARGV[2] ...apache
--eval,告訴redis-cli讀取並運行後面的lua腳本
path/to/redis.lua,是lua腳本的位置
KEYS[1] KEYS[2],是要操做的鍵,能夠指定多個,在lua腳本中經過KEYS[1], KEYS[2]獲取
ARGV[1] ARGV[2],參數,在lua腳本中經過ARGV[1], ARGV[2]獲取。數組
注意: KEYS和ARGV中間的 ',' 兩邊的空格,不能省略。瀏覽器
看下面例子:緩存
在以下文件夾中以一個lua腳本 jedisCallLuaTest.lua服務器
local key=KEYS[1] local args=ARGV
//說明:設置一個key = userName,value=Jack,20s過時時間 return redis.call("setex",key,unpack(args))
去客戶端獲取:網絡
![](http://static.javashuo.com/static/loading.gif)
過時了。。。。ide
EVALSHA命令
將腳本 script 添加到腳本緩存中,但並不當即執行這個腳本。
語法以下:
redis 127.0.0.1:6379> EVALSHA sha1 numkeys key [key ...] arg [arg ...]
參數說明:函數
- sha1 : 經過 SCRIPT LOAD 生成的 sha1 校驗碼。
- numkeys: 用於指定鍵名參數的個數。
- key [key ...]: 從 EVAL 的第三個參數開始算起,表示在腳本中所用到的那些 Redis 鍵(key),這些鍵名參數能夠在 Lua 中經過全局變量 KEYS 數組,用 1 爲基址的形式訪問( KEYS[1] , KEYS[2] ,以此類推)。
- arg [arg ...]: 附加參數,在 Lua 中經過全局變量 ARGV 數組訪問,訪問的形式和 KEYS 變量相似( ARGV[1] 、 ARGV[2] ,諸如此類)。
eg:
整合Jedis + lua
(1)Jedis的使用
建立Jedis對象,主要是用於單個redis
public class RedisClient { private static JedisPool jedisPool = null; private static String addr = "127.0.0.1"; private static int port = 6379; static { try { JedisPoolConfig config = new JedisPoolConfig(); // 鏈接耗盡時是否阻塞, false報異常,ture阻塞直到超時, 默認true config.setBlockWhenExhausted(true); // 設置的逐出策略類名, 默認DefaultEvictionPolicy(當鏈接超過最大空閒時間,或鏈接數超過最 大空閒鏈接數) config.setEvictionPolicyClassName("org.apache.commons.pool2.impl.DefaultEvictionPolicy"); // 是否啓用pool的jmx管理功能, 默認true config.setJmxEnabled(true); // MBean ObjectName = new // ObjectName("org.apache.commons.pool2:type=GenericObjectPool,name=" // + "pool" + i); 默認爲"pool", JMX不熟,具體不知道是幹啥的...默認就好. config.setJmxNamePrefix("pool"); // 是否啓用後進先出, 默認true config.setLifo(true); // 最大空閒鏈接數, 默認8個 config.setMaxIdle(8); // 最大鏈接數, 默認8個 config.setMaxTotal(8); // 獲取鏈接時的最大等待毫秒數(若是設置爲阻塞時BlockWhenExhausted),若是超時就拋異常, 小於零:阻塞不肯定的時間, // 默認-1 config.setMaxWaitMillis(-1); // 逐出鏈接的最小空閒時間 默認1800000毫秒(30分鐘) config.setMinEvictableIdleTimeMillis(1800000); // 最小空閒鏈接數, 默認0 config.setMinIdle(0); // 每次逐出檢查時 逐出的最大數目 若是爲負數就是 : 1/abs(n), 默認3 config.setNumTestsPerEvictionRun(3); // 對象空閒多久後逐出, 當空閒時間>該值 且 空閒鏈接>最大空閒數 // 時直接逐出,再也不根據MinEvictableIdleTimeMillis判斷 (默認逐出策略) config.setSoftMinEvictableIdleTimeMillis(1800000); // 在獲取鏈接的時候檢查有效性, 默認false config.setTestOnBorrow(false); // 在空閒時檢查有效性, 默認false config.setTestWhileIdle(false); // 逐出掃描的時間間隔(毫秒) 若是爲負數,則不運行逐出線程, 默認-1 config.setTimeBetweenEvictionRunsMillis(-1); jedisPool = new JedisPool(config, addr, port, 3000); } catch (Exception e) { e.printStackTrace(); } } public synchronized static Jedis getJedis() { try { if (jedisPool != null) { Jedis resource = jedisPool.getResource(); return resource; } else { return null; } } catch (Exception e) { e.printStackTrace(); return null; } } public static void close(final Jedis jedis) { if (jedis != null) { jedis.close(); } } /*---------------------測試---------------------------*/ public static void main(java.lang.String[] args) { Jedis jedis = RedisClient.getJedis(); // do something RedisClient.testCallLua(jedis); RedisClient.close(jedis); } public static void testCallLua(Jedis jedis){ String luaStr = "return {KEYS[1],KEYS[1],ARGV[1],ARGV[2]}"; Object result = jedis.eval(luaStr, Lists.newArrayList("userName","age"), Lists.newArrayList("Jack","20")); System.out.println(result); } }
運行結果:
[userName, userName, Jack, 20]
同理將工程中的lua文件加載成String,做爲參數運行也是可行的。
![](http://static.javashuo.com/static/loading.gif)
java: 該段代碼圖個方便,引用了guava.jar包
/** * 調用lua腳本 * @param jedis */ public static void testCallLuaFile(Jedis jedis){ String luaStr = null; //帶反斜槓,路徑爲classPath,不帶反斜槓,路徑爲類的同一目錄 Reader r = new InputStreamReader(RedisClient.class.getResourceAsStream("/jedisCallLuaTest.lua")); try { luaStr = CharStreams.toString(r); Object result = jedis.eval(luaStr, Lists.newArrayList("userName"), Lists.newArrayList("20","Tom")); System.out.println(result); } catch (IOException e) { e.printStackTrace(); } }
注意:getResourceAsStream()這但是好幫手,用到將文件內容加載成String,必定要想到他。CharStreams是guava.jar中的對象。
Reader轉String還有以下兩種伎倆:(發散。。。。)
@Test public void apcheIo() throws IOException{ String luaStr=null; //帶反斜槓,路徑爲classPath,不帶反斜槓,路徑爲類的同一目錄 Reader r= new InputStreamReader(Reader2StrDemo.class.getResourceAsStream("/jedisCallLuaTest.lua")); luaStr = org.apache.commons.io.IOUtils.toString(r); System.out.println(luaStr); } @Test public void java8() throws IOException{ String luaStr=null; String path = "F:\\xxxx\\ideaProjects\\java8-pro\\resource\\jedisCallLuaTest.lua"; luaStr = Files.lines(Paths.get(path),Charset.defaultCharset()).collect(Collectors.joining()); System.out.println(luaStr); }
運行結果: