Spring Batch -自定义读取器和编写器

Question

下面是读取多个项目的自定义平面文件项目读取器的代码

public class MultipleItemsFlatFileReader<T> implements ItemReader<List<T>>, ItemStream {

private FlatFileItemReader<T> reader;
private int fetchSize;

public void setReader(String readerName, String filePath, String[] headers, int[] includedFileds,
        Class<? extends T> c, int fetchSize) {
    this.reader = CustomFlatFileReader.getReader(readerName, filePath, headers, includedFileds, c);
    this.fetchSize = fetchSize;
}

@Override
public List<T> read() throws Exception{

    List<T> items = new ArrayList<>();

    for (int count = 0; count < this.fetchSize; count++) {
        T item = reader.read();

        if (item == null) {
            break;
        }

        items.add(item);
    }

    if (!items.isEmpty()) {
        return items;
    }

    return null;
}

@Override
public void open(ExecutionContext executionContext) {
    reader.open(executionContext);
}

@Override
public void update(ExecutionContext executionContext) {
    reader.update(executionContext);
}

@Override
public void close() {
    reader.close();
}

}

下面是自定义项目编写器的代码

public class MultipleItemsCompositeJdbcWriter<T> implements ItemWriter<List<T>> {

private List<JdbcBatchItemWriter<T>> delegates;

public void setDelegates(List<JdbcBatchItemWriter<T>> writers) {
    this.delegates = writers;
}

@Override
public void write(List<? extends List<T>> items) throws Exception {
    for (JdbcBatchItemWriter<T> writer: delegates) {
        for (List<T> item: items) { 
            writer.write(item);
        }
    }
}

}

我是Spring批处理的新手。这段代码正确吗？我可能缺少任何用例？目前我的批处理作业按顺序执行，但将来可能会使用多线程和分区。

需要这样做是因为我需要在处理器中进行数据库查找。为多个项目进行查找比为单个项目进行查找要好。

Answer 1

此代码是否正确？

答案取决于你工作的具体要求。在您的案例中，一个项目似乎是平面文件中多个物理行的逻辑组。

对于读者，文档中的以下部分可以提供帮助：https://docs.spring.io/spring-batch/4.0.x/reference/html/common-patterns.html#multiLineRecords

此用例还有两个示例：

• https://github.com/spring-projects/spring-batch/tree/master/spring-batch-samples#multiline
• https://github.com/spring-projects/spring-batch/tree/master/spring-batch-samples#multiline-order-job

对于编写器，您可以使用＜code＞CompositeItemWriter