因为自己有 csdn 和博客园两个博客, 所以两边都会发一下。 csdn 地址: http://blog.csdn.net/u012881584/article/details/70194237
需求: 有两台服务器同时部署了同一套代码, 代码中写有 spring 自带的定时任务,但是每次执行定时任务时只需要一台机器去执行。
最后两个方案又都被自己否决了。 第一条,如果指定 ip 的机器出现了问题怎么办? 例如说宕机了, 那么该制定 ip 的机器上的定时任务是不是就无法运行了?如果以后该服务器迁移导致 ip 变化怎么办? 第二条, 同上, 还有就是要维护两套代码很不方便。
因为上面两个假设都不成立, 只能另找他法。 于是便想到利用 mysql 去解决, 之前了解过一点 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`),
- 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="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xmlns:task="http://www.springframework.org/schema/task" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
- http://www.springframework.org/schema/task http://www.springframework.org/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>
然后看看这个 listCar 中的代码:
- //定时任务的名称, 这个和数据库中的task_name是保持一致的, 保证要执行该定时任务。
- public static finalString LIST_CAR_TASK ="listCarTask";privateScheduleClusterTask scheduleClusterTask;//这个时间是根据spring-scheduler.xml中配置的定时刷新时间, 比如说我们以后要设置这个定时任务时4小时刷新一次
- public static final longmaxExpireTime =4*3600;public void listCar() {if(scheduleClusterTask.isValidMachine(maxExpireTime, CommonConstants.ScheduleTaskName.LIST_CAR_TASK)) {//执行具体的task方法,
- doTask();//将execute状态更新为0scheduleClusterTask.end(LIST_CAR_TASK);
- }
- }
最后看下最核心的代码:ScheduleClusterTask.java
- /**
- * 多机定时任务工具类
- * Created by WangMeng on 2017/4/12.
- */
- @Service
- public classScheduleClusterTask {privateScheduleClusterEntityService scheduleClusterEntityService;/**
- * 这里因为两台机器都有同样的定时任务, 会同时执行这个方法,只有一台机器可以执行成功,返回true。
- * @param maxExpireTime 最大的检查时间。
- * @param taskName 任务名称。
- * @return
- */
- public boolean isValidMachine(longmaxExpireTime, String taskName) {booleanisValid =false;try{//通过taskName去数据库中查找到该条记录, 如果大家使用的是mybatis这里需要改一下, 就是一个简单的查询操作ScheduleClusterEntity carIndexEntity = scheduleClusterEntityService.findOne(ScheduleClusterEntity.Fields.taskName.eq(taskName));intexecute = carIndexEntity.getExecute();
- String ip = InetAddress.getLocalHost().getHostAddress();longcurrentTimeMillis = System.currentTimeMillis();longtime = carIndexEntity.getUpdateTime().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();
- }returnisValid;
- }/**
- * end方法主要是将excute(是否正在执行的标志位,0:没有执行, 1:正在执行)更新为0
- * @param taskName
- * @return
- */
- public boolean end(String taskName) {
- ScheduleClusterEntity carIndexEntity = scheduleClusterEntityService.findOne(ScheduleClusterEntity.Fields.taskName.eq(taskName));//将execute状态更新为0
- returnscheduleClusterEntityService.end(carIndexEntity);
- }private boolean checkMachine(String taskName, ScheduleClusterEntity carIndexRefresh, String ip) {returnscheduleClusterEntityService.start(taskName, carIndexRefresh.getVersion(), ip);
- }@Autowired
- public void setScheduleClusterEntityService(ScheduleClusterEntityService scheduleClusterEntityService) {this.scheduleClusterEntityService= scheduleClusterEntityService;
- }
- }
这里还有 start 方法, 看看怎样的操作:
- @Repository
- public classDefaultScheduleClusterEntityDaoextendsAbstractDao implementsScheduleClusterEntityDao {@Override
- public boolean start(String taskName,intversion, 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.addParam(SqlTimeUtils.nowTimestamp());
- s.addParam(taskName);
- s.addParam(version);return 1==executeUpdate(s);
- }
- }
核心的代码到了这里就没有了, 代码确实是非常非常的简单, 有兴趣的话大家可以在本地测试一下就可以。 当然还有更多很好地解决方案, 我这里秉承的是最简单的处理方式, 如果大家对我这个方案有疑问或者做的不好的地方都希望大家能够提出来, 谢谢了, 最后贴上两个其他的解决方案: Java 通过 redis 管理你的集群定时任务:http://www.jianshu.com/p/48c5b11b80cd Quartz 在 Spring 中集群: http://sundoctor.iteye.com/blog/486055
来源: http://www.cnblogs.com/wang-meng/p/6718199.html