集群服务器下使用SpringBoot @Scheduled注解定时任务

原文：https://blog.csdn.net/huyang1990/article/details/78551578

在实际开发中由于项目部署在分布式或集群服务器上 会导致定时任务多次触发

因此，使用redis分布锁机制可以有效避免多次执行定时任务

  核心方法是org.springframework.data.redis.core包下的

 setIfAbsent() 方法 返回值为布尔类型

  方法类似redis的SETNX命令 即”SET if Not Exists”

  服务器在执行邮件定时发送任务之前会向redis缓存中写入lock_key即任务锁 表明此服务器正在执行定时任务

  另一台服务器在写入锁时 由于锁已经存在就不做任何操作

  执行定时任务的服务器在执行完成后需释放任务锁

@Scheduled(cron = "${scheduled.cron}")
public void scheduler(){
try {
if (redisUtil.get("key") == null) {
if(redisUtil.setScheduler("key", "value")){

//定时任务执行代码
Thread.sleep(3000);
}
}
} catch (InterruptedException e) {
logger.error("定时任务异常");
}finally{
redisUtil.remove("key");
}
}

RedisUtils.java

public boolean setScheduler(final String key, Object value) {
boolean result = false;
try {
ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
return operations.setIfAbsent(key, value);
} catch (Exception e) {
e.printStackTrace();
}
return result;
}