介绍
今天就跟大家聊聊有关Java中怎么利用多机器部署解决大量定时任务问题,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。
<强>需求强>:有两台服务器同时部署了同一套代码,代码中写有弹簧自带的定时任务,但是每次执行定时任务时只需要一台机器去执行。
当拿到这个需求时我脑子中立马出现了两个简单的解决方案:
- <李>
利用ip进行判断,两台机器ip肯定不一样,指定某一台机器的ip运行。
李> <李>只在一台机器上部署定时任务的代码。
李>最后两个方案又都被自己否决了。第一条,如果指定ip的机器出现了问题怎么办?例如说宕机了,那么该制定ip的机器上的定时任务是不是就无法运行了?如果以后该服务器迁移导致ip变化怎么办?
第二条,同上,还有就是要维护两套代码很不方便。
因为上面两个假设都不成立,只能另找他法。于是便想到利用mysql去解决,之前了解过一点mysql的锁机制,知道如果有同时的两个任务去写数据库中同一条记录,只有一条会成功,这是利用了mysql的排他锁。
下面就开始代码演示,这里主要想给大家的是一个思路的提示,代码还是很简单的。
首先需要单独创建一张表
CREATE TABLE “t_schedule_cluster”, ( ,“id”bigint (20), NOT NULL AUTO_INCREMENT COMMENT & # 39; @cname:主键& # 39;, ,'执行' int (1), NOT NULL COMMENT & # 39; @cname:执行状态& # 39;, ,“版本”int (11), NOT NULL COMMENT & # 39; @cname:版本号\ r \ n ,,,,, & # 39; ,‘task_name varchar (128), NOT NULL COMMENT & # 39; @cname:任务名称\ r \ n ,,,,, & # 39; ,‘execute_ip varchar (32), DEFAULT NULL COMMENT & # 39; @cname:执行ip \ r \ n ,,,,, & # 39; ,‘update_time datetime DEFAULT NULL COMMENT & # 39; @cname:修改时间\ r \ n ,,,,, & # 39; ,PRIMARY KEY (id), ,KEY “Index_series_id”,(“执行”) ),引擎=InnoDB AUTO_INCREMENT=8, DEFAULT CHARSET=utf8 评论=& # 39;@cname:多机定时任务调度& # 39;;
看一下建成后的表结构,注释写的已经很清楚了,初始化时需要添加一些定时任务的名称(task_name),这个要和你代码中保持一致,后面会提到:
<强>代码
强>
首先看下我代码中用到春天的定时任务:
& lt; ? xml version=?.0“,编码=癠TF-8" ?比; & lt; beans  xmlns=癶ttp://www.springframework.org/schema/beans", xmlns: xsi=癶ttp://www.w3.org/2001/XMLSchema-instance" ,,,xmlns:任务=癶ttp://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=皌rue"比; & lt; description>才能使用春天的,预定的定时任务配置& lt;/description> & lt;才能!——支持注释的方式——比; & lt;才能任务:annotation-driven /比; & lt;才能任务:scheduler id=皊pringScheduler",池大??0“/比; & lt;任务:scheduled-tasks 才能调度器=皊pringScheduler"比; ,,,& lt; !——,测试使用,,项目启动后每隔一分钟执行一次,——比; ,,,& lt;任务:scheduled ref=發istCarAction",方法=發istCar", cron=?, 0/1 0, *, *, ?“/比; ,,,& lt;任务:scheduled ref=發istCarAction",方法=發istCar", cron=?, 0/1 0, *, *, ?“/比; & lt;才能/任务:scheduled-tasks> & lt;/beans>
相信大家都是用过这种定时任务的设置方法,因为它是春天自带的,所以使用起来很方便,这里我指定了两个定时任务来模拟两台机器的情况,两个定时任务都是项目启动后每隔一分钟执行一次。
然后看看这个listCar中的代码:
//定时任务的名称,,这个和数据库中的task_name是保持一致的,,保证要执行该定时任务。 public static  final String LIST_CAR_TASK =,“listCarTask"; private ScheduleClusterTask  scheduleClusterTask;//这个时间是根据spring-scheduler.xml中配置的定时刷新时间,,比如说我们以后要设置这个定时任务时4小时刷新一次 public static  final long maxExpireTime =, 4, *, 3600; public void  listCar (), { ,,,if (scheduleClusterTask.isValidMachine (maxExpireTime, CommonConstants.ScheduleTaskName.LIST_CAR_TASK)), { ,,,,,//执行具体的任务方法,, ,,,,,doTask (); ,,,,,//将执行状态更新为0 ,,,,,scheduleClusterTask.end (LIST_CAR_TASK); ,,,} 以前,,}Java中怎么利用多机器部署解决大量定时任务问题