问题背景:当我们有多个服务器,每个服务器上都有相同的定时任务,如每天凌晨定时插入数据,如果多个服务器上的定时任务都执行了会导致数据重复,如果只让一个服务器存在定时任务代码,部署起来比较麻烦,需要多套代码,万一定时任务机器宕机这会导致系统不稳定性

一般解决方案有如下几种:

  1. 数据库实现
  2. 基于 Redis 的分布式锁
  3. 利用 quartz 集群分布式

数据库实现

  1. 数据库建立一个定时表,记录 IP 和插入时间
  2. 当多个服务器通知执行任务时把自己的 IP 和当前时间插入定时表
  3. 定时表中查询当天最早插入的时间那条记录返回,与服务器自己的 IP 进行对比
  4. 若服务器自己的 IP 与数据库查询的 IP 匹配则执行,不匹配则不执行

Redis 的分布式锁实现

在 Redis 中定一个兼职对,如:项目名称:服务器IP,执行任务前先从 Redis 中读取键值对,若没有值代表任务未被执行,启动执行流程:

  • redis 中存入键值对:projectName: serviceIP 并设置过期时间
  • 触发定时任务

如果在 Redis 中查询已经存在键值对则不执行定时任务即可

Quartz 的集群应用方式

如果你的项目使用的是 Spring 自带的 Task 定时任务机制,quartz 框架本身就是支持集群环境,可以搭建集群环境下的定时器,但是该方案需要额外配置多张数据库表,工作量较大

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐