Spring Batch 批次處理框架可以應用于企業級大量的資料處理系統。以 POJO 和大家熟知的 Spring 框架為基礎。本文分別用兩個範例作為說明，範例一介紹如何在eclipse及maven環境搭建Spring Batch框架，並手動執行作業;範例二則以搭建好的框架為基礎，設定SpringBatch使其定時執行作業。

1) 了解 Spring Batch 基本架構及環境設定，以及如何啟動 SpringBatch 作業 。

Eclipse with Maven

Jave Jdk 1.7

Database Postgresql 9.3

1) JobRepository 負責提供 Launcher 、 Job 、 Step 的持久化機制，負責運行中的 CRUD 。

2) 一個 JobLauncher 觸發相對應的 Job 。

3) 一個 Job 有數個 Step 。

4) Step 有三種應對:分別是 資料讀取（ ItemReader ）、資料處理（ ItemProcessor ）、資料寫入（ ItemWriter ）。

A.       新增Maven專案後，建立以下目錄：

-建立resoures 路徑 src/main/resoures

-建立設定檔存放路徑  src/main/resoures/config

-建立資料庫資訊檔存放路徑  src/main/resoures/config/database

-建立Spring batch 設定檔存放路徑 src/main/resoures/config/springbatch

-建立測試資料檔存放路徑  src/main/resoures/csv

Ｂ.       新增 database.xml ，加入資料庫資訊

 

src/main/resoures/config/database/database.xml

 

database.xml 內容 ：

<beans xmlns="http://www.springframework.org/schema/beans"

   xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

   xsi:schemaLocation="http://www.springframework.org/schema/beans

    http://www.springframework.org/schema/beans/spring-beans-4.0.xsd

    http://www.springframework.org/schema/jdbc

    http://www.springframework.org/schema/jdbc/spring-jdbc-3.2.xsd">

 

 

   <!-- database 連線設定 -->

   <bean id="dataSource"

    class="org.springframework.jdbc.datasource.DriverManagerDataSource">

    <property name="driverClassName" value="org.postgresql.Driver" />

    <property name="url" value="jdbc:postgresql://127.0.0.1:5433/springTest" />

    <property name="username" value="postgres" />

    <property name="password" value="postgres" />

   </bean>

 

   <bean id="transactionManager"

    class="org.springframework.batch.support.transaction.ResourcelessTransactionManager" />

 

   <jdbc:initialize-database data-source="dataSource">

    <jdbc:script

     location="org/springframework/batch/core/schema-drop-postgresql.sql" />

    <jdbc:script location="org/springframework/batch/core/schema-postgresql.sql" />

   </jdbc:initialize-database>

 

  </beans>

Ｃ.       建立 Spring Batch 相關設定檔

 

 src/main/resoures/config/springbatch/jobs-context.xml

 src/main/resoures/config/springbatch/spring-batch.xml

 

  jobs-context.xml 內容 ：

spring-batch.xml 內容 ：     

 

</beans>  

完成後如下

D.      建立 csv 測試資料檔

 

 

    資料存放位置： src/main/resoures/csv/reportData.csv  

package com.levin.model;

import java.math.BigDecimal;

import java.util.Date;

import javax.xml.bind.annotation.XmlAttribute;

import javax.xml.bind.annotation.XmlElement;

import javax.xml.bind.annotation.XmlRootElement;

/**

 * 訂單報表

 */

@XmlRootElement(name = "record")

public class Report {

 /**

  * 編號

  */

 private int id;

 /**

  * 銷售

  */

 private BigDecimal sales;

 /**

  * 數量

  */

 private int qty;

 /**

  * 銷售人員名稱

  */

 private String staffName;

 /**

  * 日期

  */

 private Date date;

 @XmlAttribute(name = "id")

 public int getId() {

  return id;

 }

 public void setId(int id) {

  this.id = id;

 }

 @XmlElement(name = "sales")

 public BigDecimal getSales() {

  return sales;

 }

 public void setSales(BigDecimal sales) {

  this.sales = sales;

 }

 @XmlElement(name = "qty")

 public int getQty() {

  return qty;

 }

 public void setQty(int qty) {

  this.qty = qty;

 }

 @XmlElement(name = "staffName")

 public String getStaffName() {

  return staffName;

 }

 public void setStaffName(String staffName) {

  this.staffName = staffName;

 }

 public Date getDate() {

  return date;

 }

 public void setDate(Date date) {

  this.date = date;

 }

 @Override

 public String toString() {

  return "Report [id=" + id + ", sales=" + sales + ", qty=" + qty + ", staffName=" + staffName + "]";

 }

}

  - 新增 讀資料程式 ReportFieldSetMapper.java

package com.levin;

import java.text.ParseException;

import java.text.SimpleDateFormat;

import org.springframework.batch.item.file.mapping.FieldSetMapper;

import org.springframework.batch.item.file.transform.FieldSet;

import org.springframework.validation.BindException;

import com.levin.model.Report;

public class ReportFieldSetMapper implements FieldSetMapper {

 private SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd");

 public Report mapFieldSet(FieldSet fieldSet) throws BindException {

  Report report = new Report();

  report.setId(fieldSet.readInt(0));

  report.setSales(fieldSet.readBigDecimal(1));

  report.setQty(fieldSet.readInt(2));

  report.setStaffName(fieldSet.readString(3));

  //fieldSet.readDate(4); //預設的 format yyyy-MM-dd

  String date = fieldSet.readString(4);

  try {

   report.setDate(dateFormat.parse(date));

  } catch (ParseException e) {

   e.printStackTrace();

  }

  return report;

 }

}

package com.levin;

import org.springframework.batch.item.ItemProcessor;

import com.levin.model.Report;

public class ReportItemProcessor implements ItemProcessor {

 public Report process(Report item) throws Exception {

  System.out.println("執行中..." + item);

  return item;

 }

}

  此案將輸入資料轉成 xml 檔，自 App.java 啟動程式後，輸出如下

  新增程式 BatchJob.java

  於 Spring-Batch.xml 中新增以下標籤，並設定 con 屬性值為 */5***** 代表每五秒鐘執行一次 BatchJob.java 程式

  開啟範例一中的 App.java 程式，保留讀取 spring-batch.xml 的部分，其餘註解掉

於App.java啟動程式後，執行結果如下，每五秒鐘於console印出字串

參考來源：