分布式系列十一: Redis进阶 - 好文

分布式锁

*
数据库

数据库是使用唯一索引不允许重复的特性(或自定义实现如乐观锁). 但持有锁的进程如果释放锁时异常则容易导致死锁.

*
zookeeper

使用临时节点, watcher可以获得节点被删除的通知, 当客户端连接失效后, 临时节点清除, 所以这种情况下不会有死锁发生.

*
redis

setNX实现
// 为了简单就不用配置文件了 @Configuration public class RedisManager { private JedisPool
jedisPool ; public RedisManager(){ JedisPoolConfig jedisPoolConfig = new
JedisPoolConfig(); jedisPoolConfig.setMaxTotal(20);
jedisPoolConfig.setMaxIdle(10); this.jedisPool = new JedisPool(jedisPoolConfig,
"127.0.0.1",6379); } @Bean public Jedis getJedis(){ if (this.jedisPool==null){
return null; } return jedisPool.getResource(); } } // lock, unlock 方法这里没有用异常处理.
@Component public class RedisLock { @Autowired private Jedis jedis; public
String lock(String key, int timeout){ String uuid =
UUID.randomUUID().toString(); long lockTime = System.currentTimeMillis();
while(System.currentTimeMillis()-lockTime<timeout*1000) { long rs =
jedis.setnx(key, uuid); if (rs==1){ jedis.expire(key, (int) timeout); return
uuid; } // 保证key被设置了超时时间 if (jedis.ttl(key)==-1){ jedis.expire(key, (int)
timeout); } } return uuid; } public boolean unlock(String key, String value){
while(true) { jedis.watch(key); String ret = jedis.get(key); if
(value.equals(ret)) { Transaction transaction = jedis.multi();
transaction.del(key); List<Object> transResult = transaction.exec(); if
(transResult == null) { continue; } jedis.unwatch(); return true; }
jedis.unwatch(); break; } return false; } }
lua语言

redis可以使用lua脚本. lua是动态类型语言.

*
减少网络开销

*
原子操作

*
代码可以复用

*
轻量级

安装

tar -zxvf ...
make linux
make install

出现fatal error: readline/readline.h: No such file or directory 则需要运行

sudo apt-get install libreadline-dev

命令

* 全局变量, 局部变量 a=1 print(a) local b=2 print(b) //局部变量,在一条语句 local array =
{"a","b"} //数组定义
*
逻辑表达式

*
*
* / %
不等于使用~=

* 逻辑运算
not (a and/or B)

* 字符串连接
str1..str2

* 字符串长度用#
#"hello"

* 分支
if expression then elseif expression then end

* 循环
while expression do ..... end

for i=1,100 do .... end

for i,v in iparis(array) do ..... end

* 注释
单行使用-- ; 范围使用--[[ ..... ]]

* 函数 function(params...) --...... return a; end
内置对象: String , Table tonumber()

* lua 可以调用redis命令
redis.call() --需要引入库支持, redis内置的lua, 可以在redis内部执行

lua在Redis中的使用

*
执行 eval 'lua script' keynumber key...

*
KEYS[] ARGV[] 入参, 必须大写

*
执行lua脚本文件./redis-cli --eval luafile.lua keyparam1 , valueparam2 vlaueparam3

程序中使用lua
String lua = "local num = redis.call('incr',KEYS[1]) ... "; jedis.eval();
可以使用摘要执行脚本, 这对大脚本文件比较有用.
jedis.evalsha(jedis.scriptLoad(lua),key,value);

热门工具换一换