解决定时任务在多台服务器上重复执行的问题
在我们使用定时任务部署在单台服务器的时候,没有问题
但是当我们使用多台服务器执行这个定时任务的时候,就会对数据产生影响
解决方法:
1、使用redis的过期机制和分布式锁
首先添加依赖:
-
<dependency>
-
<groupId>org.springframework.boot</groupId>
-
<artifactId>spring-boot-starter-data-redis</artifactId>
-
</dependency>
配置redis的信息:
在我们的具体实现业务上:
-
-
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会自动加载这个定时任务类,通过类上的注解判断是否加载该实例,如果不加载,就不会执行定时任务
havingValue中的内容和配置类中的相同的话就执行,否则不执行。
这篇好文章是转载于:学新通技术网
- 版权申明: 本站部分内容来自互联网,仅供学习及演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,请提供相关证据及您的身份证明,我们将在收到邮件后48小时内删除。
- 本站站名: 学新通技术网
- 本文地址: /boutique/detail/tanhfhikei
系列文章
更多
同类精品
更多
-
photoshop保存的图片太大微信发不了怎么办
PHP中文网 06-15 -
《学习通》视频自动暂停处理方法
HelloWorld317 07-05 -
Android 11 保存文件到外部存储,并分享文件
Luke 10-12 -
word里面弄一个表格后上面的标题会跑到下面怎么办
PHP中文网 06-20 -
photoshop扩展功能面板显示灰色怎么办
PHP中文网 06-14 -
微信公众号没有声音提示怎么办
PHP中文网 03-31 -
excel下划线不显示怎么办
PHP中文网 06-23 -
excel打印预览压线压字怎么办
PHP中文网 06-22 -
怎样阻止微信小程序自动打开
PHP中文网 06-13 -
TikTok加速器哪个好免费的TK加速器推荐
TK小达人 10-01