基于块的处理

Spring Batch 在其最常见的实现中使用“基于块的”处理风格。基于块的处理是指一次读取一个数据，并创建在事务边界内写入的“块”。一旦读取的项目数量等于提交间隔，整个块就会由 ItemWriter 写出，然后提交事务。下图显示了此过程

图 1. 基于块的处理

以下伪代码以简化的形式显示了相同的概念

List items = new Arraylist();
for(int i = 0; i < commitInterval; i++){
    Object item = itemReader.read();
    if (item != null) {
        items.add(item);
    }
}
itemWriter.write(items);

您还可以使用可选的 ItemProcessor 配置基于块的步骤，以在将项目传递给 ItemWriter 之前处理项目。下图显示了在步骤中注册 ItemProcessor 时的过程

Chunk Oriented Processing With Item Processor

图 2. 使用 Item Processor 的基于块的处理

以下伪代码以简化的形式显示了如何在其中实现此功能

List items = new Arraylist();
for(int i = 0; i < commitInterval; i++){
    Object item = itemReader.read();
    if (item != null) {
        items.add(item);
    }
}

List processedItems = new Arraylist();
for(Object item: items){
    Object processedItem = itemProcessor.process(item);
    if (processedItem != null) {
        processedItems.add(processedItem);
    }
}

itemWriter.write(processedItems);

有关项目处理器及其用例的更多详细信息，请参阅项目处理部分。