Java通过redis管理你的集群定时任务

@Aspect@Component@Log4jpublic class QuartzAop {    
    public boolean checkStatus(){
        String key = "schedular_root:projectA";        try {            // 这个接口必然是并发的，所以加分布式锁
            while (true) {                // 一秒的超时时间
                boolean lock = RedisUtil.checkLock(key,1);                if (lock) {                    // 获取到锁，才能跳出
                    break;
                }
            }
            String ip = InetAddress.getLocalHost().getHostAddress();            // 获取服务器上的工作ip
            String currentIp = RedisUtil.get(key);            // 如果为空的时候，设置进去
            if(currentIp == null){
                RedisUtil.setex(key, ip, 10);                return true;
            }            // 就是当前机器，则返回true
            if(currentIp.equals(ip)){                return true;
            }else{                return false;
            }
        } catch (Exception e) {
            log.error(e);            return false;
        } finally {
            RedisUtil.unLock(key);
        }
    }    
    @Around("@annotation(org.springframework.scheduling.annotation.Scheduled)")    public void around(ProceedingJoinPoint jp) throws Throwable{        if(checkStatus()){
            String ip = InetAddress.getLocalHost().getHostAddress();
            log.info("现在正在执行"+jp.getSignature()+":"+ip);
            jp.proceed();
        }
    }
    
}

public static boolean checkLock(String key,int second) {
  
  String lockKey = "lock:" + key;  try {   // 1表示之前不存在，设置成功
   if (setnx(lockKey, "lock") == 1) {    // 设置有限期
    setExpiredTime(lockKey, second);    return true;
   } else {    // 50毫秒的延迟，避免过多请求
    try {
     Thread.sleep(50L);
    } catch (InterruptedException e) {     log.error(e);
    }    return false;
   }

  } catch (RedisException e) {   log.error(e);   return true;
  }
 }