Java应⽤集下的定时任务处理⽅案（mysql）
今天来说⼀个Java多机部署下定时任务的处理⽅案。
需求: 有两台服务器同时部署了同⼀套代码，代码中写有spring⾃带的定时任务，但是每次执⾏定时任务时只需要⼀台机器去执⾏。
当拿到这个需求时我脑⼦中⽴马出现了两个简单的解决⽅案：
利⽤ip进⾏判断，两台机器ip肯定不⼀样，指定某⼀台机器的ip运⾏。
只在⼀台机器上部署定时任务的代码。
最后两个⽅案⼜都被⾃⼰否决了。第⼀条，如果指定ip的机器出现了问题怎么办？例如说宕机了，那么该制定ip的机器上的定时任务是不是就⽆法运⾏了？如果以后该服务器迁移导致ip变化怎么办？
第⼆条，同上，还有就是要维护两套代码很不⽅便。
因为上⾯两个假设都不成⽴，只能另他法。于是便想到利⽤mysql去解决，之前了解过⼀点mysql的锁机制，知道如果有同时的两个任务去写数据库中同⼀条记录，只有⼀条会成功，这是利⽤了mysql的排他锁。(详细内容可以看下我的这篇⽂章：)
下⾯就开始代码演⽰，这⾥主要想给⼤家的是⼀个思路的提⽰，代码还是很简单的。
⾸先需要单独创建⼀张表
CREATE TABLE `t_schedule_cluster` (
`id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '@cname：主键',
`execute` int(1) NOT NULL COMMENT '@cname：执⾏状态',
`version` int(11) NOT NULL COMMENT '@cname：版本号\r\n            ',
`task_name` varchar(128) NOT NULL COMMENT '@cname：任务名称\r\n            ',
`execute_ip` varchar(32) DEFAULT NULL COMMENT '@cname：执⾏ip\r\n            ',
`update_time` datetime DEFAULT NULL COMMENT '@cname：修改时间\r\n            ',
PRIMARY KEY (`id`),mysql下载不了怎么办
KEY `Index_series_id` (`execute`)
) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8 COMMENT='@cname：多机定时任务调度';
看⼀下建成后的表结构，注释写的已经很清楚了，初始化时需要添加⼀些定时任务的名称（task_name），这个要和你代码中保持⼀致，后⾯会提到：
代码
⾸先看下我代码中⽤到的spring定时任务：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="/schema/beans" xmlns:xsi="/2001/XMLSchema-instance"
xmlns:task="/schema/task"
xsi:schemaLocation="/schema/beans /schema/beans/spring-beans-3.2.xsd
/schema/task /schema/task/spring-task-3.2.xsd"
default-lazy-init="true">
<description>使⽤Spring的 Scheduled的定时任务配置</description>
<!--⽀持annotation的⽅式-->
<task:annotation-driven  />
<task:scheduler id="springScheduler"  pool-size="10"/>
<task:scheduled-tasks scheduler="springScheduler">
<!-- 测试使⽤，项⽬启动后每隔⼀分钟执⾏⼀次 -->
<task:scheduled ref="listCarAction" method="listCar" cron="0 0/1 0 * * ?"/>
<task:scheduled ref="listCarAction" method="listCar" cron="0 0/1 0 * * ?"/>
</task:scheduled-tasks>
</beans>
相信⼤家都是⽤过这种定时任务的设置⽅法，因为它是spring⾃带的，所以使⽤起来很⽅便，这⾥我指定了两个定时任务来模拟两台机器的情况，两个定时任务都是项⽬启动后每隔⼀分钟执⾏⼀次。
然后看看这个listCar中的代码：
//定时任务的名称，这个和数据库中的task_name是保持⼀致的，保证要执⾏该定时任务。
public static final String LIST_CAR_TASK = "listCarTask";
private ScheduleClusterTask scheduleClusterTask;
//这个时间是根据l中配置的定时刷新时间, ⽐如说我们以后要设置这个定时任务时4⼩时刷新⼀次
public static final long maxExpireTime = 4 * 3600;
public void listCar() {
if (scheduleClusterTask.isValidMachine(maxExpireTime, CommonConstants.ScheduleTaskName.LIST_CAR_TASK)) {
//执⾏具体的task⽅法，
doTask();
//将execute状态更新为0
}
}
最后看下最核⼼的代码：ScheduleClusterTask.java
/**
* 多机定时任务⼯具类
* Created by WangMeng on 2017/4/12.
*/
@Service
public class ScheduleClusterTask {
private ScheduleClusterEntityService scheduleClusterEntityService;
/**
* 这⾥因为两台机器都有同样的定时任务，会同时执⾏这个⽅法，只有⼀台机器可以执⾏成功，返回true。
* @param maxExpireTime 最⼤的检查时间。
* @param taskName 任务名称。
* @return
*/
public boolean isValidMachine(long maxExpireTime, String taskName) {
boolean isValid = false;
try {
//通过taskName去数据库中查到该条记录，如果⼤家使⽤的是mybatis这⾥需要改⼀下，就是⼀个简单的查询操作
ScheduleClusterEntity carIndexEntity = scheduleClusterEntityService.findOne(ScheduleClusterEntity.
Fields.taskName.eq(taskName));
int execute = Execute();
String ip = LocalHost().getHostAddress();
long currentTimeMillis = System.currentTimeMillis();
long time = UpdateTime().getTime();
if (execute == 0 && time + maxExpireTime - 1000 < currentTimeMillis) {
isValid = checkMachine(taskName, carIndexEntity, ip);
} else if (time + maxExpireTime - 1000 < currentTimeMillis){
//这⾥要判断下，如果上⼀次执⾏出现异常导致execute没有更新为0，那么这⾥要判断上⼀次更新时间的间隔。
isValid = checkMachine(taskName, carIndexEntity, ip);
}
} catch (UnknownHostException e) {
e.printStackTrace();
}
return isValid;
}
/**
* end⽅法主要是将excute(是否正在执⾏的标志位，0：没有执⾏， 1：正在执⾏)更新为0
* @param taskName
* @return
*/
public boolean end (String taskName) {
ScheduleClusterEntity carIndexEntity = scheduleClusterEntityService.findOne(ScheduleClusterEntity.Fields.taskName.eq(taskName));
//将execute状态更新为0
d(carIndexEntity);
}
private boolean checkMachine(String taskName, ScheduleClusterEntity carIndexRefresh, String ip) {
return scheduleClusterEntityService.start(taskName, Version(), ip);
}
@Autowired
public void setScheduleClusterEntityService(ScheduleClusterEntityService scheduleClusterEntityService) {
this.scheduleClusterEntityService = scheduleClusterEntityService;
}
}
这⾥还有start⽅法，看看怎样的操作：
@Repository
public class DefaultScheduleClusterEntityDao extends AbstractDao<ScheduleClusterEntity> implements ScheduleClusterEntityDao {
@Override
public boolean start(String taskName, int version, String ip) {
String sql = "update t_schedule_cluster set execute = 1, " +
"version = ?, execute_ip = ?, update_time = ?" +
" where task_name = ? and version = ?";
Sql s = new Sql(sql);
s.addParam(version + 1);
s.addParam(ip);
s.wTimestamp());
s.addParam(taskName);
s.addParam(version);
return 1 == executeUpdate(s);
}
}
核⼼的代码到了这⾥就没有了，代码确实是⾮常⾮常的简单，有兴趣的话⼤家可以在本地测试⼀下就可以。
当然还有更多很好地解决⽅案，我这⾥秉承的是最简单的处理⽅式，如果⼤家对我这个⽅案有疑问或者做的不好的地⽅都希望⼤家能够提出来，谢谢了，最后贴上两个其他的解决⽅案：
Java通过redis管理你的集定时任务：
Quartz在Spring中集：

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。