码迷,mamicode.com
首页 > 其他好文 > 详细

使用redis分布式锁来解决集群项目的定时任务冲突问题

时间:2019-01-07 20:47:18      阅读:214      评论:0      收藏:0      [点我收藏+]

标签:pre   ssh   过期   get   import   sys   int   test   程序   

import org.apache.commons.lang3.StringUtils;
import org.springframework.scheduling.annotation.Scheduled;


public class Test {
//  @Scheduled(cron="0 */1 * * * ?")//(每隔1分钟的整数倍)
  public void closeOrderTask(){
      System.out.println("关闭订单定时任务启动");
      long lockTimeout = 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(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK,5);//有效期5秒,防止死锁(这里的锁有效期,与上面的lockTimeout值必须统一)
          System.out.println("-----------业务方法开始---------");
          System.out.println("执行业务方法");
          System.out.println("-----------业务方法结束---------");
          RedisShardedPoolUtil.del(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK);//业务方法执行完之后 手动将锁撤销
      }else{
          System.out.println("未获得分布式锁,锁名是:"+Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK);
      }
      System.out.println("关闭订单定时任务结束");
  }

  @Scheduled(cron="0 */1 * * * ?")//(每隔1分钟的整数倍)
  public void closeOrderTaskV(){
      System.out.println("关闭订单定时任务启动");
      long lockTimeout = 5000;//锁存在的时间 这个时间根据具体业务处理时间来设置
      Long setnxResult = RedisShardedPoolUtil.setnx(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK,String.valueOf(System.currentTimeMillis()+lockTimeout));
      if(setnxResult != null && setnxResult.intValue() == 1){
          closeOrder(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK);
      }else{
          //未获取到锁,那么继续判断,判断时间戳与当前时间对比,看是否可以重置并获取到锁
          String lockValueStr = RedisShardedPoolUtil.get(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK);
          if(lockValueStr ==null||lockValueStr != null && System.currentTimeMillis() > Long.parseLong(lockValueStr)){//这种到老锁存在但是已经超时的情况一般是上面遇到的死锁情况
              //设置新锁 并获取老锁的值,getset是一个原子性的方法
              String getSetResult = RedisShardedPoolUtil.getSet(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK,String.valueOf(System.currentTimeMillis()+lockTimeout));
              if(getSetResult == null || (getSetResult != null && StringUtils.equals(lockValueStr,getSetResult))){//老锁消失 或者老锁过期并且老锁未被其他进程操作的情况下 有权利获取锁
                  //真正获取到锁
                  RedisShardedPoolUtil.expire(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK,5);//有效期5秒,防止死锁
                  System.out.println("-----------业务方法开始---------");
                  System.out.println("执行业务方法");
                  System.out.println("-----------业务方法结束---------");
                  RedisShardedPoolUtil.del(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK);
              }else{
                  System.out.println("没有获取到分布式锁");
              }
          }else{
              System.out.println("没有获取到分布式锁");
          }
      }
      System.out.println("关闭订单定时任务结束");
  }
}

 

使用redis分布式锁来解决集群项目的定时任务冲突问题

标签:pre   ssh   过期   get   import   sys   int   test   程序   

原文地址:https://www.cnblogs.com/tjqBlog/p/10035462.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!