首页 > 代码库 > Java之旅--定时任务(Timer、Quartz、Spring、LinuxCron)
Java之旅--定时任务(Timer、Quartz、Spring、LinuxCron)
在Java中,实现定时任务有多种方式,本文介绍4种,Timer和TimerTask、Spring、QuartZ、Linux Cron。
以上4种实现定时任务的方式,Timer是最简单的,不需要任何框架,仅仅JDK就可以,缺点是仅仅是个时间间隔的定时器,调度简单;Spring和QuartZ都支持cron,功能都很强大,Spring的优点是稍微简单一点,QuartZ的优点是没有Spring也可使用;Linux Cron是个操作系统级别的定时任务,适用于所有操作系统支持的语言,缺点是精度只能到达分钟级别。
Timer和TimerTask
代码示例如下:
import java.util.Date; import java.util.Timer; import java.util.TimerTask; public class TimerTest extends TimerTask { private Timer timer; public static void main(String[] args) { TimerTest timerTest= new TimerTest(); timerTest.timer = new Timer(); //立刻开始执行timerTest任务,只执行一次 timerTest.timer.schedule(timerTest,new Date()); //立刻开始执行timerTest任务,执行完本次任务后,隔2秒再执行一次 //timerTest.timer.schedule(timerTest,new Date(),2000); //一秒钟后开始执行timerTest任务,只执行一次 //timerTest.timer.schedule(timerTest,1000); //一秒钟后开始执行timerTest任务,执行完本次任务后,隔2秒再执行一次 //timerTest.timer.schedule(timerTest,1000,2000); //立刻开始执行timerTest任务,每隔2秒执行一次 //timerTest.timer.scheduleAtFixedRate(timerTest,new Date(),2000); //一秒钟后开始执行timerTest任务,每隔2秒执行一次 //timerTest.timer.scheduleAtFixedRate(timerTest,1000,2000); try { Thread.sleep(10000); } catch (InterruptedException e) { e.printStackTrace(); } //结束任务执行,程序终止 timerTest.timer.cancel(); //结束任务执行,程序并不终止,因为线程是JVM级别的 //timerTest.cancel(); } @Override public void run() { System.out.println("Task is running!"); } }
使用spring @Scheduled注解执行定时任务
这种方式非常简单,却能使用cron完成和QuartZ一样的功能,值得推荐一下。
ApplicationContext.xml:
beans根节点增加内容:xmlns:task="http://www.springframework.org/schema/task"
beans根节点中,xsi:schemaLocation属性下增加:
http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.1.xsd
<!-- 开启注解任务 -->
<task:annotation-driven/>
实现类:
@Component //import org.springframework.stereotype.Component; public class MyTestServiceImpl implements IMyTestService { @Scheduled(cron="0/5 * * * * ? ") //每5秒执行一次 @Override public void myTest(){ System.out.println("进入测试"); } }
注意几点:
spring的@Scheduled注解 需要写在实现上;
定时器的任务方法不能有返回值;
实现类上要有组件的注解@Component,@Service,@Repository
QuartZ
QuartZ With Spring
applicationContext-schedule.xml
<?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:context="http://www.springframework.org/schema/context" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd"> <bean id="quartzScheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <property name="triggers"> <list> <!-- 启动的Trigger列表 --> <ref local="startThriftTrigger" /> </list> </property> <property name="quartzProperties"> <props> <prop key="org.quartz.threadPool.threadCount">5</prop> </props> </property> <!-- 启动时延期3秒开始任务 --> <property name="startupDelay" value=http://www.mamicode.com/"3" />>
实现类
package xx.schedule; @Component public class StartThrift { /** * 调度入口 */ public void execute() { // to do something } }
QuartZ No Spring
使用的QuartZ jar是1.8.5,如下:
<dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>1.8.5</version> </dependency>调用类实现代码如下:
import org.quartz.CronExpression; import org.quartz.CronTrigger; import org.quartz.JobDetail; import org.quartz.Scheduler; import org.quartz.SchedulerException; import org.quartz.SchedulerFactory; import org.quartz.impl.StdSchedulerFactory; public class InvokeStatSchedule { public void start() throws SchedulerException { SchedulerFactory schedulerFactory = new StdSchedulerFactory(); Scheduler scheduler = schedulerFactory.getScheduler(); //InvokeStatJob是实现了org.quartz.Job的类 JobDetail jobDetail = new JobDetail("jobDetail", "jobDetailGroup", InvokeStatJob.class); CronTrigger cronTrigger = new CronTrigger("cronTrigger", "triggerGroup"); try { CronExpression cexp = new CronExpression("0 0 * * * ?"); cronTrigger.setCronExpression(cexp); } catch (Exception e) { e.printStackTrace(); } scheduler.scheduleJob(jobDetail, cronTrigger); scheduler.start(); } }
定时任务类代码如下:import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; public class InvokeStatJob implements Job { @Override public void execute(JobExecutionContext arg0) throws JobExecutionException { //...要定时操作的内容 } }
Linux Cron
这其实也是一种非常普遍的实现定时任务的方式,实际是操作系统的定时任务。Linux Cron只能到达分钟级,到不了秒级别。
一般我们是设置定时执行一个sh脚本,在脚本里面写一些控制代码,例如,有如下的脚本:
3,33 * * * * /usr/local/log_parser/run_log_parser.sh &
run_log_parser.sh的内容大致如下:
#!/bin/sh log_parser_dir=/usr/local/log_parser tmp_file=/usr/local/run_parser_tmp.txt parser_log=/usr/local/access_parser.log tmpDir=/data/applogs/access_logs_bp date >> "$parser_log" if [! -f "$tmp_file"]; then echo '访问日志解析正在进行,尚未完成' >> "$parser_log" echo '' >> "$parser_log" else echo '开始解析访问日志' >> "$parser_log" touch "$tmp_file" cd "$log_parser_dir" python access_log_parser.py >> "$parser_log" rm "$tmp_file" echo '解析访问日志完成' >> "$parser_log" echo '' >> "$parser_log" cd "$tmpDir" gzip gzip WEB0* mv *.gz gz/ echo '压缩备份日志及移动到压缩目录成功' >> "$parser_log" fi