redis分布式锁 解锁的时候发现锁已经被别的线程写入了

Question

public boolean Lock(String key, Date date)  {
        String key1 = "lock:" + key;
        long time = 5000L;
        Boolean flag = false;
        long maxTime = System.currentTimeMillis()+ DefaultMaxWaitTime;
        for (; ; ) {
            if (System.currentTimeMillis() > maxTime) {
                throw new RuntimeException("系统繁忙");
            }
            redisTemplate.setKeySerializer(redisTemplate.getStringSerializer());
            flag = redisTemplate.opsForValue().setIfAbsent(key1, date.toString() + Thread.currentThread().getId(), time, TimeUnit.MILLISECONDS);
            if (flag&&(date.toString() + Thread.currentThread().getId()).equals(redisTemplate.opsForValue().get(key1))) {
                break;
            } else {
                try {
                    Thread.sleep(new Random().nextInt(10));
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
        if (!flag){
            throw new RuntimeException(Thread.currentThread().getId()+"异常跳出   当前锁为==>"+redisTemplate.opsForValue().get(key1)+"加锁内容为:==>"+date.toString() + Thread.currentThread().getId());
        }
        getWatchDog(key, date, String.valueOf(Thread.currentThread().getId()));
        return flag;
    }

Answer 1

 public boolean UnLock(String key, Date date) {
        String key1 = "lock:" + key;
        System.out.println(Thread.currentThread().getId()+"释放锁");
        if ((date.toString() + Thread.currentThread().getId()).equals(redisTemplate.opsForValue().get(key1))) {
            redisTemplate.delete(key1);
            return true;
        }
        throw new RuntimeException("解锁失败 请检查锁是否正确 ===  >" + date.toString() + Thread.currentThread().getId() + "      " + redisTemplate.opsForValue().get(key1));
    }

解锁的代码