Spring Batch_官网DEMO实现

http://spring.io/guides/gs/batch-processing/

使用spring xml方式实现了spring batch官网的demo，现在把具体的代码贴出来，具体的细节配置还要参考官网的说明。

首先建立maven项目，pom文件如下：

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>lyx</groupId><artifactId>SpringBatch2</artifactId><version>0.0.1-SNAPSHOT</version><packaging>jar</packaging><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><!--spring context --><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>4.1.1.RELEASE</version></dependency><!--spring core --><dependency><groupId>org.springframework</groupId><artifactId>spring-core</artifactId><version>4.1.1.RELEASE</version></dependency><!--spring bean --><dependency><groupId>org.springframework</groupId><artifactId>spring-beans</artifactId><version>4.1.1.RELEASE</version></dependency><!--spring aop --><dependency><groupId>org.springframework</groupId><artifactId>spring-aop</artifactId><version>4.1.1.RELEASE</version></dependency><!--spring jdbc --><dependency><groupId>org.springframework</groupId><artifactId>spring-jdbc</artifactId><version>4.1.1.RELEASE</version></dependency><!-- spring tx --><dependency><groupId>org.springframework</groupId><artifactId>spring-tx</artifactId><version>4.1.1.RELEASE</version></dependency><dependency><groupId>org.springframework.batch</groupId><artifactId>spring-batch-core</artifactId><version>3.0.2.RELEASE</version></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.10</version><scope>test</scope></dependency><dependency><groupId>cglib</groupId><artifactId>cglib</artifactId><version>3.1</version></dependency><dependency><groupId>org.apache.tomcat</groupId><artifactId>tomcat-jdbc</artifactId><version>8.0.14</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.6</version></dependency></dependencies>
</project>

最主要的就是配置下面的这个spring-batch2.xml文件，也就是配置reader，writer，processor，以及各种依赖类。该spring-batch2.xml文件时依据BatchConfiguration.java配置的，具体配置如下：

<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"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsdhttp://www.springframework.org/schema/batch http://www.springframework.org/schema/batch/spring-batch.xsd"><bean id="lineTokenizer"class="org.springframework.batch.item.file.transform.DelimitedLineTokenizer"><property name="delimiter" value="," /><property name="names"><list><value>firstName</value><value>lastName</value></list></property></bean><bean id="fieldSetMapper"class="org.springframework.batch.item.file.mapping.BeanWrapperFieldSetMapper"><property name="prototypeBeanName" value="person" /></bean><bean id="person" class="com.lyx.batch.Person" scope="prototype" /><bean id="lineMapper"class="org.springframework.batch.item.file.mapping.DefaultLineMapper"><property name="lineTokenizer" ref="lineTokenizer" /><property name="fieldSetMapper" ref="fieldSetMapper" /></bean><bean id="resource" class="org.springframework.core.io.ClassPathResource"><constructor-arg index="0" type="java.lang.String"value="sample-data.csv" /></bean><bean id="flatFileItemReader" class="org.springframework.batch.item.file.FlatFileItemReader"><property name="resource" ref="resource" /><property name="encoding" value="utf-8" /><property name="lineMapper" ref="lineMapper" /></bean><bean id="itemProcessor" class="com.lyx.batch.PersonItemProcessor" /><bean id="jdbcBatchItemWriter"class="org.springframework.batch.item.database.JdbcBatchItemWriter"><property name="itemSqlParameterSourceProvider" ref="itemSqlParameterSourceProvider" /><property name="sql"value="INSERT INTO people (first_name, last_name) VALUES (:firstName, :lastName)" /><property name="dataSource" ref="dataSource" /></bean><bean id="itemSqlParameterSourceProvider"class="org.springframework.batch.item.database.BeanPropertyItemSqlParameterSourceProvider" /><!--tomcat jdbc pool数据源配置 --><bean id="dataSource" class="org.apache.tomcat.jdbc.pool.DataSource"destroy-method="close"><property name="poolProperties"><bean class="org.apache.tomcat.jdbc.pool.PoolProperties"><property name="driverClassName" value="com.mysql.jdbc.Driver" /><property name="url" value="jdbc:mysql://localhost:3306/test" /><property name="username" value="root" /><property name="password" value="034039" /><property name="maxActive" value="100" /><property name="initialSize" value="10" /><property name="maxWait" value="10000" /><property name="minIdle" value="10" /></bean></property></bean><batch:job id="sampleJob" job-repository="jobRepository"><batch:step id="step"><tasklet transaction-manager="transactionManager"><chunk reader="flatFileItemReader" processor="itemProcessor"writer="jdbcBatchItemWriter" commit-interval="1" /></tasklet></batch:step></batch:job><!-- spring batch 配置jobRepository --><batch:job-repository id="jobRepository"data-source="dataSource" transaction-manager="transactionManager"isolation-level-for-create="REPEATABLE_READ" table-prefix="BATCH_"max-varchar-length="1000" /><!-- spring的事务管理器 --><bean id="transactionManager"class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource" /></bean><!-- batch luncher --><bean id="jobLauncher"class="org.springframework.batch.core.launch.support.SimpleJobLauncher"><property name="jobRepository" ref="jobRepository" /></bean>
</beans>

主要的类有以下两个类：

Person.java

package com.lyx.batch;public class Person {private String lastName;private String firstName;public Person() {}public Person(String firstName, String lastName) {this.firstName = firstName;this.lastName = lastName;}public void setFirstName(String firstName) {this.firstName = firstName;}public String getFirstName() {return firstName;}public String getLastName() {return lastName;}public void setLastName(String lastName) {this.lastName = lastName;}@Overridepublic String toString() {return "firstName: " + firstName + ", lastName: " + lastName;}}

PersonItemProcessor.java

package com.lyx.batch;import org.springframework.batch.item.ItemProcessor;public class PersonItemProcessor implements ItemProcessor<Person, Person> {public Person process(final Person person) throws Exception {final String firstName = person.getFirstName().toUpperCase();final String lastName = person.getLastName().toUpperCase();final Person transformedPerson = new Person(firstName, lastName);System.out.println("Converting (" + person + ") into ("+ transformedPerson + ")");return transformedPerson;}}

最后，运行这个demo的前提是你要把spring batch的数据库配置好，具体的sql文件在spring batch core jar包中，还有数据源文件，要放在resources目录中。。

AppMain.java启动该demo

package com.lyx.batch;import org.springframework.batch.core.ExitStatus;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.JobParametersBuilder;
import org.springframework.batch.core.JobParametersInvalidException;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.batch.core.repository.JobExecutionAlreadyRunningException;
import org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException;
import org.springframework.batch.core.repository.JobRestartException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;public class AppMain {public static void main(String[] args)throws JobExecutionAlreadyRunningException, JobRestartException,JobInstanceAlreadyCompleteException, JobParametersInvalidException {@SuppressWarnings("resource")ApplicationContext context = new ClassPathXmlApplicationContext(new String[] { "classpath:spring-batch2.xml" });JobParametersBuilder jobParametersBuilder = new JobParametersBuilder();Job job = (Job) context.getBean("sampleJob");JobLauncher launcher = (JobLauncher) context.getBean("jobLauncher");JobExecution result = launcher.run(job,jobParametersBuilder.toJobParameters());ExitStatus es = result.getExitStatus();if (es.getExitCode().equals(ExitStatus.COMPLETED.getExitCode())) {System.out.println("任务正常完成");} else {System.out.println("任务失败，exitCode=" + es.getExitCode());}}
}

如果没有意外的话，会在数据库中看到相应的结果。

在该demo的基础上可以 试验spring batch的各种特性，可以进一步探索spring batch。

==========END==========