Chunk-oriented Processing
Spring Batch 在其最常见的实现中使用“分块导向”处理风格。分块导向处理指的是一次读取一个数据,并在事务边界内创建被写入的“块”。一旦读取的项目数量等于提交间隔,整个块就会被 ItemWriter
写出,然后事务就会被提交。以下图片显示了这一过程:
Figure 1. Chunk-oriented Processing
以下伪代码以简化形式展示了相同概念:
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
时流程:
Figure 2. Chunk-oriented Processing with 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);
有关项目处理程序及其用例的更多详细信息,请参阅 Item processing 部分。