redis锁的基本命令
SETNX(SET if Not exist):当且仅当 key 不存在,将 key 的值设为 value ,并返回1;若给定的 key 已经存在,则 SETNX 不做任何动作,并返回0。 GETSET:将给定 key 的值设为 value ,并返回 key 的旧值。先根据key获取到旧的value,再set新的value。 EXPIRE 为给定 key 设置生存时间,当 key 过期时,它会被自动删除。 正确的加锁方式(很多人以为下面代码多的是正确的加锁方式,其实redis已经解决这个问题了):
// 这里使用集成的jedis jedis.set(String key, String value, String nxxx, String expx, int time) 错误的加锁方式1:
//如果程序在执行完setnx()之后突然崩溃,导致锁没有设置过期时间。那么将会发生死锁。Long result = jedis.setnx(Key,value);if(result ==1) {// 若在这里程序突然崩溃,则无法设置过期时间,将发生死锁jedis.expire(Key, expireTime);}
错误的加锁方式2:
分布式锁才用(Key,过期时间)的方式,如果锁存在,那么获取它的过期时间,如果锁的确已经过期了,那么获得锁,并且设置新的过期时间
错误分析:不同的客户端之间需要同步好时间。
long expires = System.currentTimeMillis() + expireTime; String expiresStr = String.valueOf(expires);
// 如果当前锁不存在,返回加锁成功if(jedis.setnx(lockKey, expiresStr) ==1) {returntrue;}// 如果锁存在,获取锁的过期时间StringcurrentValueStr = jedis.get(lockKey);if(currentValueStr !=null&& Long.parseLong(currentValueStr) < System.currentTimeMillis()) {// 锁已过期,获取上一个锁的过期时间,并设置现在锁的过期时间StringoldValueStr = jedis.getSet(lockKey, expiresStr);if(oldValueStr !=null&& oldValueStr.equals(currentValueStr)) {// 考虑多线程并发的情况,只有一个线程的设置值和当前值相同,它才有权利加锁returntrue; }}// 其他情况,一律返回加锁失败returnfalse;
解锁:判断锁的拥有者后可以使用 jedis.del(lockKey) 来释放锁。