1 <?xml version="1.0" encoding="UTF-8"?>
 2 <bean:beans xmlns="//www.springframework.org/schema/batch"
 3     xmlns:bean="//www.springframework.org/schema/beans" xmlns:xsi="//www.w3.org/2001/XMLSchema-instance"
 4     xmlns:p="//www.springframework.org/schema/p" xmlns:tx="//www.springframework.org/schema/tx"
 5     xmlns:aop="//www.springframework.org/schema/aop" xmlns:context="//www.springframework.org/schema/context"
 6     xmlns:util="//www.springframework.org/schema/util"
 7     xsi:schemaLocation="//www.springframework.org/schema/beans 
 8 //www.springframework.org/schema/beans/spring-beans-3.0.xsd  
 9 //www.springframework.org/schema/tx 
10 //www.springframework.org/schema/tx/spring-tx-3.0.xsd  
11 //www.springframework.org/schema/aop 
12 //www.springframework.org/schema/aop/spring-aop-3.0.xsd  
13 //www.springframework.org/schema/context 
14 //www.springframework.org/schema/context/spring-context-2.5.xsd
15 //www.springframework.org/schema/batch 
16 //www.springframework.org/schema/batch/spring-batch-2.1.xsd 
17 //www.springframework.org/schema/util //www.springframework.org/schema/util/spring-util.xsd">
18 
19     <bean:import resource="applicationContext.xml" />
20 
21     <!-- Job信(xin)息的配置 -->
22     <job id="fixedLengthJob">
23         <step id="fixedLengthStep">
24             <tasklet>
25                 <chunk reader="fixedLengthReader" writer="fixedLengthWriter"
26                     processor="fixedLengthProcessor" commit-interval="10">
27                 </chunk>
28             </tasklet>
29         </step>
30     </job>
31 
32     <!-- 固定長(chang)文件的讀(du)信息的配(pei)置 -->
33     <bean:bean id="fixedLengthReader"
34         class="org.springframework.batch.item.file.FlatFileItemReader" scope="step">
35         <bean:property name="resource"
36             value="file:#{jobParameters['inputFilePath']}" />
37         <bean:property name="lineMapper">
38             <bean:bean
39 class="org.springframework.batch.item.file.mapping.DefaultLineMapper">
40                 <bean:property name="lineTokenizer" ref="lineTokenizer" />
41                 <bean:property name="fieldSetMapper">
42                     <bean:bean
43 class="org.springframework.batch.item.file.mapping.BeanWrapperFieldSetMapper">
44                         <bean:property name="prototypeBeanName" value="studentBean"/>
45                     </bean:bean>
46                 </bean:property>
47             </bean:bean>
48         </bean:property>
49     </bean:bean>
50     <bean:bean id="studentBean"
51         class="com.wanggc.springbatch.sample.fixedlength.StudentPojo" scope="prototype" />
52     <bean:bean id="lineTokenizer"
53         class="org.springframework.batch.item.file.transform.FixedLengthTokenizer">
54         <bean:property name="columns" value="1-6,7-15,16-18,19-" />
55         <bean:property name="names" value="ID,name,age,score" />
56     </bean:bean>
57 
58     <!-- 固定長(chang)格式文件的(de)寫 -->
59     <bean:bean id="fixedLengthWriter"
60         class="org.springframework.batch.item.file.FlatFileItemWriter" scope="step">
61         <bean:property name="resource"
62             value="file:#{jobParameters['outputFilePath']}" />
63         <bean:property name="lineAggregator">
64             <bean:bean
65 class="org.springframework.batch.item.file.transform.FormatterLineAggregator">
66                 <bean:property name="fieldExtractor">
67                     <bean:bean
68 class="org.springframework.batch.item.file.transform.BeanWrapperFieldExtractor">
69                         <bean:property name="names" value="ID,name,age,score" />
70                     </bean:bean>
71                 </bean:property>
72                 <bean:property name="format" value="%-9s%-20s%3d%-2.0f" />
73             </bean:bean>
74         </bean:property>
75     </bean:bean>
76 </bean:beans>

package com.wanggc.springbatch.sample.fixedlength;

import org.springframework.batch.item.ItemProcessor;
import org.springframework.stereotype.Component;

/**
 * 業務處理類。
 * 
 * @author Wanggc
 */
@Component("fixedLengthProcessor")
public class FixedLengthProcessor implements
        ItemProcessor<StudentPojo, StudentPojo> {

    /**
     * 對取到的數據進行簡單的處理。
     * 
     * @param student
     *            處理前的數據。
     * @return 處理后的數據。
     * @exception Exception
     *                處理是發生的任何異常。
     */
    public StudentPojo process(StudentPojo student) throws Exception {
        /* 合(he)并ID和(he)名字(zi) */
        student.setName(student.getID() + "--" + student.getName());
        /* 年齡(ling)加2 */
        student.setAge(student.getAge() + 2);
        /* 分數加10 */
        student.setScore(student.getScore() + 10);
        /* 將處理后的(de)結果(guo)傳遞(di)給(gei)writer */
        return student;
    }

}

package com.wanggc.springbatch.sample.fixedlength;

/** Pojo類_Student */
public class StudentPojo {
    /** ID */
    private String ID = "";
    /** 名字 */
    private String name = "";
    /** 年齡(ling) */
    private int age = 0;
    /** 分(fen)數 */
    private float score = 0;
    /* 為節(jie)省篇幅，getter 和 setter 已經刪(shan)除 */    
}

package com.wanggc.springbatch.sample.fixedlength;

import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.JobParametersBuilder;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Launch {
    public static void main(String[] args) {
        ApplicationContext context = new ClassPathXmlApplicationContext(
                "batch.xml");
        JobLauncher launcher = (JobLauncher) context.getBean("jobLauncher");
        Job job = (Job) context.getBean("fixedLengthJob");

        try {
            // JOB實行
            JobExecution result = launcher.run(
                    job,
                    new JobParametersBuilder()
                            .addString("inputFilePath",
                                    "C:\\testData\\fixedLengthInputFile.txt")
                            .addString("outputFilePath",
                                    "C:\\testData\\fixedLengthOutputFile.txt")
                            .toJobParameters());
            // 運行結果輸出
            System.out.println(result.toString());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}