美文网首页
实现redis分布式锁

实现redis分布式锁

作者: 云鲸鱼rain | 来源:发表于2019-04-08 16:55 被阅读0次

首先结合springboot先配置一下redis
在application.yml的配置文件里。

spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    username: root
    password: root
    url: jdbc:mysql://127.0.0.1:3306/demo?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8
  redis:
    database: 1
    host: 127.0.0.1
    port: 6379

@Autowired
private StringRedisTemplate redisTemplate;


/*
    前情提要:
    key: productId;//商品ID
    value: System.currentTimeMillis() + 10*1000;//超时时间10秒

    前两个版本是错误,一步一步完善得到最终版本
*/


/*第一个版本*/
/*
这时候只需要考虑,
    如果key存在于redis数据库,那么证明锁已经存在。
    如果key不存在redis数据库,那么证明锁不存在,可以获得锁。
 所以在这里,key是有用的,其实value是无所谓的。
*/
public boolean lock(String key, String value) {

    if(redisTemplate.opsForValue().setIfAbsent(key, value)) {
        return true;
    }

    return false;
}


/*第二个版本*/
/*
这时候考虑的要多,
    如果一个线程拿到锁之后,还未解锁,
    服务器挂掉了,这样锁就一直存在,那显然不行。
于是要设置一个超时时间,当一个线程持有锁多长时间后,
    需要解锁。
那么value就有用了,可以当作超时时间来存。
*/
public boolean lock(String key, String value) {

    if(redisTemplate.opsForValue().setIfAbsent(key, value)) {
        return true;
    }

    String currentValue = redisTemplate.opsForValue().get(key);
    if(!StringUtils.isEmpty(currentValue) && Long.parseLong(currentValue) < System.currentTimeMillis()) {
        redisTemplate.opsForValue().set(key, value);
        return true;
    }

    return false;
}

/*第三个版本*/
/*
这时候发现,
    这样写完之后,无法保证加锁的原子性,
    如果多个线程进来怎么办?
    多个线程都会拿到key的锁。
然后,再引入第二个redis的方法:getAndSet。
    只有第一个线程是 redis数据库中的value与value自身比较,自然可以拿到锁。
    之后的线程都是用 入参value 与 redis数据库中的value比较,两者必然不相等,拿不到锁。
*/
public boolean lock(String key, String value) {

    if(redisTemplate.opsForValue().setIfAbsent(key, value)) {
        return true;
    }

    String currentValue = redisTemplate.opsForValue().get(key);
    if(!StringUtils.isEmpty(currentValue) && Long.parseLong(currentValue) < System.currentTimeMillis()) {
        String oldValue = redisTemplate.opsForValue().getAndSet(key, value);
        if(!StringUtils.isEmpty(oldValue) && oldValue.equals(currentValue)) {
            return true;
        }
    }

    return false;
}

/*
SET KEY VALUE [EX seconds] [PX milliseconds] [NX|XX]

[EX seconds]: 设置过期时间为seconds秒
[PX milliseconds]: 设置过期时间为milliseconds秒
[NX|XX]: NX->key不存在时,才set. XX->key存在时,才set》
*/

/*第四版本*/
public boolean lock(String key, String value) {

    if(redisTemplate.opsForValue().setIfAbsent(key, value, 10, TimeUnit.SECONDS)) {
        return true;
    }

    return false;
}

相关文章

网友评论

      本文标题:实现redis分布式锁

      本文链接:https://www.haomeiwen.com/subject/jfiuiqtx.html