Redis分布式锁代码实现(Java)

在这里插入图片描述

public class RedisLock {

    public static Boolean getLock(RedisTemplate redisTemplate, String key, String value, long timeout) {
        Boolean lock = redisTemplate.opsForValue().setIfAbsent(key,value,timeout,TimeUnit.SECONDS); //获取锁
        return lock;
    }
    
    public static void closeLock(RedisTemplate redisTemplate,String key, String value) {
        while (true) {
            redisTemplate.watch(key);//保证原子性
            String revalue=String.valueOf(redisTemplate.opsForValue().get(key));
            if (value.equalsIgnoreCase(revalue)) {//判断是否是当前锁
                redisTemplate.setEnableTransactionSupport(true);
                redisTemplate.multi();
                redisTemplate.delete(key);
                List<Object> rlist = redisTemplate.exec();
                if (rlist == null) {
                    continue;
                }
            }
            redisTemplate.unwatch();
            break;
        }
    }
}
Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐