原文：https://blog.csdn.net/huyang1990/article/details/78551578
SpringBoot提供了 Schedule模块完美支持定时任务的执行
在实际开发中由于项目部署在分布式或集群服务器上 会导致定时任务多次触发
因此，使用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;
}