Redis与分布式-分布式锁-Toy模板网

这篇具有很好参考价值的文章主要介绍了Redis与分布式-分布式锁。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

接上文 Redis与分布式-集群搭建

1.分布式锁

Redis与分布式-分布式锁,SpringCloud Alibaba,redis,分布式,数据库

为了解决上述问题，可以利用分布式锁来实现。
重新复制一份redis，配置文件都是刚下载时候的不用更改，然后启动redis服务和redis客户。

redis存在这样的命令：和set命令差不多，但是它有一个机制，当指定的key不存在的时候，才能进行插入，实际上就是 set if not exists的缩写，当key被删除后可以进行插入。

setnx key value

Redis与分布式-分布式锁,SpringCloud Alibaba,redis,分布式,数据库

利用这种特性，可以再不同的服务中实现分布式锁。但是若某个服务加了锁并且卡顿了，或者崩溃，那么这把锁永远无法释放了，因此可以加过期时间：set a666 EX 5 NX

Redis与分布式-分布式锁,SpringCloud Alibaba,redis,分布式,数据库

如果学习过JUC并发编程，会发现若在超时之前那一刻进入到释放锁的阶段，获取到的值肯定还是自己，但是在即将执行删除之前，由于超时机制导致被删除并且其他任务也加锁了，那么这时候在删除，仍会导致删除其他任务加的锁

导入Redisson依赖

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson</artifactId>
    <version>3.17.0</version>
</dependency>

<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>4.1.75.Final</version>
</dependency>

Redis与分布式-分布式锁,SpringCloud Alibaba,redis,分布式,数据库
不加锁的情况

    public static void main(String[] args) {
        for (int i = 0; i < 10; i++) {
            new Thread(() -> {
                try(Jedis jedis = new Jedis("192.168.0.10", 6379)){
                    for (int j = 0; j < 100; j++) {   //每个客户端获取a然后增加a的值再写回去，如果不加锁那么肯定会出问题
                        int a = Integer.parseInt(jedis.get("a")) + 1;
                        jedis.set("a", a+"");
                    }
                }
            }).start();
        }
    }

在redis中设置a=0，然后测试不加锁
Redis与分布式-分布式锁,SpringCloud Alibaba,redis,分布式,数据库

取出a，得出结果不对

测试加锁

public static void main(String[] args) {
    Config config = new Config();
    config.useSingleServer().setAddress("redis://192.168.0.10:6379");   //配置连接的Redis服务器，也可以指定集群
    RedissonClient client =  Redisson.create(config);   //创建RedissonClient客户端
    for (int i = 0; i < 10; i++) {
        new Thread(() -> {
            try(Jedis jedis = new Jedis("192.168.0.10", 6379)){
                RLock lock = client.getLock("testLock");    //指定锁的名称，拿到锁对象
                for (int j = 0; j < 100; j++) {
                    lock.lock();    //加锁
                    int a = Integer.parseInt(jedis.get("a")) + 1;
                    jedis.set("a", a+"");
                    lock.unlock();   //解锁
                }
            }
            System.out.println("结束！");
        }).start();
    }
}

执行完a的值加了1000，此时写入为正常
Redis与分布式-分布式锁,SpringCloud Alibaba,redis,分布式,数据库

此时若用于存放锁的redis服务挂了，那么肯定会出问题的，这个时候可以用RedLock，它的思路是在多个redis服务器上保持锁，只需要超过半数的redis服务获取到锁，那么就真的获取到锁了，这样挂掉一部分节点，也能保证正常运行。文章来源地址https://www.toymoban.com/news/detail-728117.html

到了这里，关于Redis与分布式-分布式锁的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！