想请教一个redis实现分布式锁的问题,一般大家都是如何做的?我在网上找到的代码感觉有问题?
代码如图所示,这是一段redis做分布式锁的代码,但是getset方法是返回值为上一次的过期时间,然后才判断返回值是否和上一次的过期时间一致。这时已经执行了getset方法,即便不一致也没有写相应的回滚方法是为什么?
getset返回的虽然是上一次的过期时间,但由于
String oldValueStr = jedis.getSet(lockKey, expiresStr);
String oldValueStr = jedis.getSet(lockKey, expiresStr);
执行的间隔时间非常短,即使期间有其它线程的设值被覆盖,影响也不大,expiresStr最多被增加几毫秒
long expires = System.currentTimeMillis() + expireTime;
String expiresStr = String.valueOf(expires);
String oldValueStr = jedis.getSet(lockKey, expiresStr);
取值和设值间隔很短
你既然用了redis,set设置锁的时候,已经设置了过期时间,那么当获取不到锁的时候,就没必要再去读取锁了,redis自己会清除过期的锁。
redies无非就是借助其缓存的性质来实现,这个原理很好理解,写个DEMO,跑几个线程自己测一测问题不大,不过也可以用zk来实现分布式锁。