redis 实现分布式锁的演进

在分布式系统中,常常会遇到一些要使用分布式锁的业务场景。

比如说:每分钟要执行关闭未支付订单的定时任务,在集群的环境下,如果不做处理,每台服务器都会去执行这个定时任务,显然每个时间段的定时任务只需要执行一次,并不需要每台服务器都去执行,使用分布式锁来控制让单台服务器来执行这个定时任务 势在必行

实现分布式锁的方式有很多,zookeeper,数据库,或者是其它手段都可以,本文着重分析使用

redis来实现分布式锁的几种方案。

先来看看要使用的redis命令吧

setnx:not exist 的缩写  不存在时,setnx 才会设置成功  具有原子性

getset  获取旧值,然后设置新值。 具有原子性

expire 设置key的有效期

del  删除key

第一种:

    @Scheduled(cron="0 */1 * * * ?")
    public void taskV1(){
        log.info("定时任务启动");
        long lockTimeout = Long.parseLong(PropertiesUtil.getProperty("lock.timeout","5000"));
        Long setnxResult = RedisShardedPoolUtil.setnx(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK,String.valueOf(System.currentTimeMillis()+lockTimeout));
        if(setnxResult != null && setnxResult.intValue() == 1){
            //如果返回值是1,代表设置成功,获取锁
            RedisShardedPoolUtil.expire(lockName,5);//设置超时时间
           //执行定时任务的业务操作
           RedisShardedPoolUtil.del(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK);//释放锁
        }else{
            log.info("没有获得分布式锁:{}",Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK);
        }
        log.info("定时任务结束");
    }

V1版本的定时任务是利用 redis 的 setnx 命令 去做的,setnx 是当key不存在的时候 才会是set 一个key , 如果返回 1 就说明成功了,那就说明得到了锁;

但返回一个结果后,服务器就被kill了,那redis 的key 里面 已经有了 这个key了

会导致 这个定时任务永远不会被执行; 这是这种方案的一个bug

关闭服务器有两种方法,一个是使用tomcat 的 shutdown命令,还有一个是直接kill进程

如果是是 使用 shutdown 命令的话,那 使用 @PreDestroy 这种注解 修饰一个deleteKey的方法也能 将锁释放,但 如果有很多歌分布式锁需要释放的话,那 shutdown 时等待的时间就太久了 更优雅的办法 看 V2版本

第二种办法:

    @Scheduled(cron="0 */1 * * * ?")
    public void taskV2(){
        log.info("定时任务启动");
        long lockTimeout = Long.parseLong(PropertiesUtil.getProperty("lock.timeout","5000"));
        Long setnxResult = RedisShardedPoolUtil.setnx(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK,String.valueOf(System.currentTimeMillis()+lockTimeout));
        if(setnxResult != null && setnxResult.intValue() == 1){
        RedisShardedPoolUtil.expire(lockName,5);//设置超时时间
            //执行定时任务的业务操作
            RedisShardedPoolUtil.del(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK);//释放锁
        }else{
            //未获取到锁,继续判断,判断时间戳,看是否可以重置并获取到锁
            String lockValueStr = RedisShardedPoolUtil.get(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK);
            if(lockValueStr != null && System.currentTimeMillis() > Long.parseLong(lockValueStr)){
                String getSetResult = RedisShardedPoolUtil.getSet(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK,String.valueOf(System.currentTimeMillis()+lockTimeout));
                //再次用当前时间戳getset。
                //返回给定的key的旧值,->旧值判断,是否可以获取锁
                //当key没有旧值时,即key不存在时,返回nil ->获取锁
                //这里我们set了一个新的value值,获取旧的值。
                if(getSetResult == null || (getSetResult != null && StringUtils.equals(lockValueStr,getSetResult))){
                    //真正获取到锁
                  RedisShardedPoolUtil.expire(lockName,5);//设置超时时间
                   //执行定时任务的业务操作
                   //释放锁
                }else{
                    log.info("没有获取到分布式锁:{}",Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK);
                }
            }else{
                log.info("没有获取到分布式锁:{}",Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK);
            }
        }
        log.info("定时任务结束");
    }

V2版本的定时任务 在执行setnx 命令时 value 加入了一个当前时间 + 防死锁的超时时间(5S),

如果没有获取到锁的话,会通过value判断一下,锁的超时时间。

首先通过key 得到 setnx set 的值 value1,然后如果 当前时间大于 锁的超时时间,

就重新去 更新这个 key的value 值,更新的value值 称为value 2 使用的命令是 getSet命令,

getSet命令会返回一个旧值 这里称为是 value3

如果 value 1等于 null 的话 就说明 redis中 锁的 这个key就消失了,那就使当前线程获取到锁 执行定时任务。

如果value 1不等于null 并且 value3 等于 value1, 就说明 当前 redis 分布式锁 锁的这个key,没有被其它线程修改过,而这个key的 有限期又到时间了,那么 也说明当前线程 有资格获取到 锁 ,于是执行定时任务。

以上两种都是原生的写法,再来看 Redisson 框架 给我们提供的便利吧~

 @Scheduled(cron="0 */1 * * * ?")
    public void taskV3(){
        RLock lock = redissonManager.getRedisson().getLock(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK);
        boolean getLock = false;
        try {
            if(getLock = lock.tryLock(0,5, TimeUnit.SECONDS)){
                log.info("Redisson获取到分布式锁:{},ThreadName:{}",Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK,Thread.currentThread().getName());
                int hour = Integer.parseInt(PropertiesUtil.getProperty("close.order.task.time.hour","2"));
        //执行定时任务的业务操作
            }else{
                log.info("Redisson没有获取到分布式锁:{},ThreadName:{}",Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK,Thread.currentThread().getName());
            }
        } catch (InterruptedException e) {
            log.error("Redisson分布式锁获取异常",e);
        } finally {
            if(!getLock){
                return;
            }
            lock.unlock();
            log.info("Redisson分布式锁释放锁");
        }
    }

task1 task2的思路如图所示:

原创声明,本文系作者授权云+社区发表,未经许可,不得转载。

如有侵权,请联系 yunjia_community@tencent.com 删除。

编辑于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏MasiMaro 的技术博文

枚举进程中的模块

在Windows中枚举进程中的模块主要是其中加载的dll,在VC上主要有2种方式,一种是解析PE文件中导入表,从导入表中获取它将要静态加载的dll,一种是利用查...

1532
来自专栏jeremy的技术点滴

SSM项目脚手架

5194
来自专栏陈树义

玩转SSH(四):Struts + Spring + MyBatis

一、创建 SSMDemo 项目 点击菜单,选择“File -> New Project” 创建新项目。选择使用 archetype 中的 maven-webap...

4726
来自专栏一个会写诗的程序员的博客

第13章 Kotlin 集成 SpringBoot 服务端开发(2)

其中,ON DUPLICATE KEY UPDATE 这句表明当遇到重复的键值的时候,执行更新 gmt_modified = now() 的操作。这里nativ...

1281
来自专栏【转载】DRF+Vue+Mysql_生鲜超市系统

五、商品列表页

在goods文件夹下面新建view_base.py,为了区分django和django rest framework的view

2380
来自专栏Phoenix的Android之旅

Dagger2 Android应用:@Scope和@Subcomponent

这部分会介绍Dagger2中比较莫名的概念,同样也不涉及Android的具体代码。 Dagger2使用中的核心技巧包括@Subcomponent和@Scope,...

1072
来自专栏我是攻城师

在Lucene或Solr中实现高亮的策略

3825
来自专栏一个会写诗的程序员的博客

6.3 Spring Boot集成mongodb开发小结

本章我们通过SpringBoot集成mongodb,Java,Kotlin开发一个极简社区文章博客系统。

2103
来自专栏有趣的django

Django REST framework+Vue 打造生鲜超市(四)

五、商品列表页 5.1.django的view实现商品列表页 (1)goods/view_base.py 在goods文件夹下面新建view_base.py,为...

2.3K9
来自专栏Jerry的SAP技术分享

ABAP和XML数据格式互相转换的两种方式

1. ABAP提供了一个工具类cl_proxy_xml_transform,通过它的两个方法abap_to_xml_xstring和xml_xstring_to...

2552

扫码关注云+社区

领取腾讯云代金券