在我们使用定时任务部署在单台服务器的时候,没有问题
但是当我们使用多台服务器执行这个定时任务的时候,就会对数据产生影响
解决方法:
1、使用redis的过期机制和分布式锁
首先添加依赖:
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
配置redis的信息:
在我们的具体实现业务上:
@Autowired
private RedisTemplate redisTemplate;
/** 定时任务的名称作为key **/
String key = "QuartzJob";
/** 设置随机key **/
String value = UUID.randomUUID().toString().replace("-", "");
//如果键不存在则新增,存在则不改变已经有的值。(备注:失效时间要大于多台服务器之间的时间差,如果多台服务器时间差大于超时时间,定时任务可能会执行多次)
Boolean flag = redisTemplate.opsForValue().setIfAbsent(key, value, 20, TimeUnit.SECONDS);
if (flag != null && flag) {
log.info("{} 锁定成功,开始处理业务", key);
/** 此处填写业务逻辑 **/
/*
* 业务逻辑处理完毕,释放锁,正常情况下,由于上边 setIfAbsent 已经设置过期时间了,
* 所以在规定时间内,Redis 会自动删除过期的 key,但是这个删除由于不确实是什么删除策略,
* 所以最后执行完再删除一遍比较保险。
*/
String lockValue = (String) redisTemplate.opsForValue().get(key);
/** 只有:值未被释放(也就是当前未达到过期时间),且是自己加锁设置的值(不要释放别人的所),这种情况下才会释放锁 **/
if (lockValue != null && lockValue.equals(value)) {
redisTemplate.delete(key);
log.info("{} 解锁成功,结束处理业务", key);
}
} else {
log.info("{} 获取锁失败", key);
}
该方法比较推荐,简单,对业务逻辑的改变也会少很多,只需要在原来的定时器上加上简单判断即可
2、指定一个服务才能使用定时任务
在配置文件中放一个开关,然后在启动项目时,spring会自动加载这个定时任务类,通过类上的注解判断是否加载该实例,如果不加载,就不会执行定时任务
文章来源:https://www.toymoban.com/news/detail-533746.html
havingValue中的内容和配置类中的相同的话就执行,否则不执行。文章来源地址https://www.toymoban.com/news/detail-533746.html
到了这里,关于解决定时任务在多台服务器上重复执行的问题?的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!