RedisUtil提供加锁,解锁,key和value生成

public class RedisLockUtil {

    /**
     * redis分布式锁-加锁
     * @param redisTemplate redis 加锁解锁要保证同一个
     * @param key 分布式锁key
     * @param value 分布式锁value 一般为随机数
     * @param timeout 分布式锁过期时间 秒
     * @param number 重试次数
     * @param interval 重试间隔 毫秒
     * @return
     */
    public static boolean lock(RedisTemplate redisTemplate, String key, String value, int timeout, int number, int interval) {
        //加锁
        for (int i = 0; i < number; i++) {
            //尝试获取锁,成功则返回不成功则重试
            if (redisTemplate.opsForValue().setIfAbsent(key, value, Duration.ofSeconds(timeout))) {
                return true;
            }
            //暂停
            try {
                TimeUnit.MILLISECONDS.sleep(interval);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        //最终获取不到锁返回失败
        return false;
    }

    public static boolean lock(RedisTemplate redisTemplate, String key, String value) {
        return lock(redisTemplate, key, value, 30, 3, 1000);
    }

    /**
     * 解锁脚本,防止线程将其他线程的锁释放
     */
    private static String UN_LOCK_SCRIPT = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";

    /**
     * redis分布式锁-解锁
     * @param redisTemplate redis 加锁解锁要保证同一个
     * @param key 分布式锁key
     * @param value 分布式锁value 一般为随机数
     * @return
     */
    public static void unLock(RedisTemplate redisTemplate, String key, String value) {
        //解锁
        redisTemplate.execute(new DefaultRedisScript<>(UN_LOCK_SCRIPT, Long.class), Collections.singletonList(key), value);
    }

    /**
     * 获取调用者的类名和方法名
     * @return
     */
    public static String getMethodPath() {
        StackTraceElement stackTraceElement = Thread.currentThread().getStackTrace()[2];
        //获取当前类名
        String className = stackTraceElement.getClassName();
        //获取当前方法名
        String methodName = stackTraceElement.getMethodName();
        return className + "#" + methodName;
    }

    /**
     * 获取随机数
     * @return
     */
    public static String getRandom() {
        return Objects.toString(ThreadLocalRandom.current().nextInt(0, 100000));
    }
}

测试代码,先在spring中接入redis再来尝试 Spring Boot中使用Redis数据库

		//分布式锁key
        String key = RedisLockUtil.getMethodPath()+"_"+"100";
        //分布式锁value 一般为随机数
        String value = RedisLockUtil.getRandom();
        if (!RedisLockUtil.lock(stringRedisTemplate, key, value)) {
            //加锁失败
             logger.info(">>>>>分布式锁<<<<< 重入锁失败 key:{} value:{}", key, value);
        }
        try {
            logger.info(">>>>>分布式锁<<<<< 加锁成功 key:{} value:{}", key, value);
            TimeUnit.SECONDS.sleep(20);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //解锁
            RedisLockUtil.unLock(stringRedisTemplate, key, value);
            logger.info(">>>>>分布式锁<<<<< 解锁成功 key:{} value:{}", key, value);
        }

测试结果: