根据不同的支付渠道选择不同的step进行处理，主要通过实现JobExecutionDecider接口，返回不同的FlowExecutionStatus来决定step分支。

    其大致实现：

    1、maven依赖：

        
             
      
       org.springframework.batch
              
      
       spring-batch-core
              
      
       3.0.6.RELEASE
          
         
             
      
       org.springframework.batch
              
      
       spring-batch-samples
              
      
       1.1.4.RELEASE
              
      
       sources
          
         
             
      
       mysql
              
      
       mysql-connector-java
              
      
       5.1.5
          
         
             
      
       commons-dbcp
              
      
       commons-dbcp
              
      
       1.4
          
     
    

    2、Reader实现

/** * Created by heyinbo on 2016/8/17. * 抽象数据读取 */public abstract class PayBillItemReader
    
      implements ItemReader
     
      , InitializingBean {    /**     * 当前数据所处位置     */    private volatile int current = 0;    /**     * 数据集     */    protected volatile List
      
        result;    private Object lock = new Object();    public T doReader() {        synchronized (lock) {            if (null == result) {                doDownLoad();            }        }        int next = current++;        if (null != result && next < result.size()) {            return result.get(next);        }        return null;    }    public abstract void doDownLoad();    @Override    public void afterPropertiesSet() throws Exception {    }}
      
     
    

/** * Created by heyinbo on 2016/8/17. * 数据读取的具体实现 * */public class WXPayBillItemReader extends PayBillItemReader
    
      {    private String id;    /**     * 下载日期     */    private Date loadDate;    /**     * 支付渠道     */    private String payWay;    @Override    public void doDownLoad() {        //TODO 下载对账单    }    @Override    public PayBillItem read() throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException {        return doReader();    }    public Date getLoadDate() {        return loadDate;    }    public void setLoadDate(Date loadDate) {        this.loadDate = loadDate;    }    public String getId() {        return id;    }    public void setId(String id) {        this.id = id;    }    public String getPayWay() {        return payWay;    }    public void setPayWay(String payWay) {        this.payWay = payWay;    }}
    

    2、writer实现

public class PayBillItemWriter implements ItemWriter
    
      {    @Override    public void write(List items) throws Exception {        //TODO write database        //测试事务//        throw new DemoException("database rollback");    }}
    

    3、JobExecutionDecider实现

/** * Created by heyinbo on 2016/8/17. * 根据JobParameters传入的值决策流程执行分支 */public class PayBillJobExecutionDecider implements JobExecutionDecider {    @Override    public FlowExecutionStatus decide(JobExecution jobExecution, StepExecution stepExecution) {     //根据传入的参数决定step，具体参考配置文件        String payWay = jobExecution.getJobParameters().getString("payWay");        return new FlowExecutionStatus(payWay);    }}  

    5、测试运行

public class DeciderJobLaunch {    public static void main(String[] args) {        ApplicationContext context = new ClassPathXmlApplicationContext("spring-batch-decider.xml");        JobLauncher launcher = (JobLauncher) context.getBean("jobLauncher");        Job job = (Job) context.getBean("deciderJob");        try {            /* 运行Job */            JobExecution result = launcher.run(job, new JobParametersBuilder()                    .addString("id", "10010")                    .addString("payWay", "weixin")                    .addDate("loadDate", new Date())                    .toJobParameters());            /* 处理结束，控制台打印处理结果 */            System.out.println(result.getExitStatus().toString());        } catch (Exception e) {            e.printStackTrace();        }    }}  

    6、batch相关配置

    以上就是整个job的处理流程，其中包括异常处理以及事务管理。

备注：优化对账方式，将数据初始化到redis服务中，通过redis的sdiff命令进行比对筛选差集。目前采用redis是基于其扩展方便，利于后期针对不同渠道进行扩展。