Spring batch 是一个优秀的专业的批处理框架，但是并不是一个任务调度框架。但是Spring 中也带有一个轻量级的Scheduler来帮助我们做一些事情。除此之外我们还可以选择比较有效的任务调度框架Quartz [quartz ] 可以很好的与Spring Batch 进行结合做一些更加优秀的东西。对于刚刚开始我选择用Spring 自带的轻量级的Scheduler来做个简单的demo,后续将会引入quartz来做一些东西。
这里简单配置一个job任务来讲述如何使用
此处spring batch 的reader process writer三个部分的配置在此省略，但是不影响定时任务执行的效果
job_context.xml
<beans
xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:batch="http://www.springframework.org/schema/batch" xmlns:task="http://www.springframework.org/schema/task" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/batch http://www.springframework.org/schema/batch/spring-batch.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd">
<!-- Import our beans -->
<import resource="classpath:/applicationContext.xml"/>
<batch:job id="job1">
<batch:step id="importFileStep">
<tasklet>
<chunk reader="productReader" writer="productWriter" commit-interval="5"/>
</tasklet>
</batch:step>
</batch:job>
<!--执行器-->
<bean id="runScheduler" class="com.sushou.demo.BatchJob" />
<!--定时任务 每5秒执行一次-->
<task:scheduled-tasks>
<task:scheduled ref="runScheduler" method="run" cron="*/5 * * * * *" />
</task:scheduled-tasks>
</beans>
运行定时任务
BatchJob.java
package com.sushou.demo;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.JobParameters;
import org.springframework.batch.core.JobParametersBuilder;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.Date;
/** * Created by maple on 16/5/14. */
public class BatchJob {
@Autowired
private JobLauncher jobLauncher;
@Autowired
private Job job;
public void run() {
try {
String dateParam = new Date().toString();
JobParameters param = new JobParametersBuilder().addString("date", dateParam).toJobParameters();
System.out.println(dateParam);
JobExecution execution = jobLauncher.run(job, param); //执行job
System.out.println("Exit Status : " + execution.getStatus());
} catch (Exception e) {
e.printStackTrace();
}
}
}
增加一个运行的主方法
App.java
package com.sushou.demo;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/** * Created by maple on 16/5/14. */
public class App {
public static void main(String[] args) {
ApplicationContext context = new ClassPathXmlApplicationContext("job-context.xml");
}
}
运行app.java 就可以看到运行结果
定时任务运行结果 2016-05-14 下午2.03.14.png
