private LockUtils(){ } public static boolean lock(String lockName){//lockName可以为共享变量名,也可以为方法名,主要是用于模拟锁信息 System.out.println(Thread.currentThread() + "开始尝试加锁!"); Long result = RedisPoolUtil.setnx(lockName, String.valueOf(System.currentTimeMillis() + 5000)); //setnx这个操作成功并且返回1,表示这个锁没有被别人获取,如果锁在别人手上则会返回0 if (result != null && result.intValue() == 1){ System.out.println(Thread.currentThread() + "加锁成功!"); RedisPoolUtil.expire(lockName, 5); System.out.println(Thread.currentThread() + "执行业务逻辑!"); RedisPoolUtil.del(lockName); return true; } else { //这里的走向主要判断锁还在被别的线程持有,而且持有的时间已经超过所设置的过期时间。 //否则表示这把锁已经被人拿走了,因为这里的走向代表返回的不是1 //通过key查询value(这个value代表上一个线程持锁线程的时间戳) String lockValueA = RedisPoolUtil.get(lockName); //当前时间大于所设置时间戳,表示锁的时间已经过期了 if (System.currentTimeMillis() >= (lockValueA != null && Long.parseLong(lockValueA)) ){ //如果锁已经过期了说明锁失效了,就可以重新获取锁,通过getset重新设置时间戳,并且返回上一个持锁线程的时间戳lockValueB String lockValueB = RedisPoolUtil.getSet(lockName, String.valueOf(System.currentTimeMillis() + 5000)); //如果lockValueB !=lockValueA,代表lockValue在getset之前有一条线程已经拿走锁了,然后重新设置了时间戳,所以导致现在这条线程拿到的时间戳和lockValueA对不上。 if (lockValueB == null || lockValueB.equals(lockValueA)){ System.out.println(Thread.currentThread() + "加锁成功!"); RedisPoolUtil.expire(lockName, 5); System.out.println(Thread.currentThread() + "执行业务逻辑!"); RedisPoolUtil.del(lockName); return true; } else { return false; } } else { return false; } } } 1
参考:
(64条消息) Redis分布式锁实现以及避免死锁_qq_40925755的博客-CSDN博客_redis避免死锁