Spring Boot Batch自定义ItemWriter处理List项编译错误解决方法

问题根因 #

Spring Batch 块（Chunk）模式步骤的泛型是严格绑定的：你在Step配置中声明的输出类型为List<? extends ProcessedItem>，框架会要求注入的Writer必须支持处理该类型——即Writer的泛型必须是List<? extends ProcessedItem>的父类。但你当前实现的MyCustomWriter泛型为ProcessedItem，框架判定该Writer只能接收单个ProcessedItem组成的块，和Processor返回的List类型不匹配，因此抛出编译错误。

另外你当前Reader中写的SQLSELECT FROM data where processed = false存在语法错误，漏了查询字段，后续运行会报错，需要补上对应查询列。

修复方案 #

方案1：调整Writer泛型直接匹配Processor输出（改动最小） #

直接修改MyCustomWriter的泛型声明，和Processor的输出类型对齐。注意Spring Batch传入Writer的items参数，是当前Chunk块中所有Processor返回结果的集合，由于你的Processor单条输入返回一个List，因此Writer拿到的是嵌套List结构，需要做一次拆平再走原有写入逻辑。
修改后的MyCustomWriter代码：

@Component
public class MyCustomWriter implements ItemWriter<List<? extends ProcessedItem>> {

    @Override
    public void write(List<? extends List<? extends ProcessedItem>> items) throws Exception {
        // 拆平嵌套列表，拿到所有待写入的ProcessedItem
        List<ProcessedItem> allProcessItems = items.stream()
                .flatMap(List::stream)
                .collect(Collectors.toList());

        for (ProcessedItem data : allProcessItems) {
            // 原有写入逻辑
        }
    }
}

该方案不需要调整其他组件和Step配置，改完即可消除编译错误。

方案2：扁平化Processor输出，对齐原有Writer泛型（符合框架设计规范） #

Spring Batch常规设计中，单条读入数据处理后返回多个结果的场景，推荐做扁平化处理，让Step的输出类型保持为单个ProcessedItem，和Writer的泛型对齐，不需要修改原有Writer的逻辑，也方便后续调整Chunk大小优化性能。
Spring Batch 4.2及以上版本提供了FlatMapItemProcessor专门支持一对多的处理场景，改造Processor即可：

@Component
public class MyCustomProcessor extends FlatMapItemProcessor<ReadItem, ProcessedItem> {

    @Override
    protected void doProcess(ReadItem item, Consumer<ProcessedItem> consumer) throws Exception {
        List<ProcessedItem> listData = new ArrayList<>();
        // 原有数据处理逻辑，生成listData
        // 将每个处理结果交给consumer，框架自动完成扁平化
        listData.forEach(consumer);
    }
}

同时调整Step配置的泛型声明，将原来的<ReadItem, List<? extends ProcessedItem>>改为<ReadItem, ProcessedItem>即可，原有MyCustomReader、MyCustomWriter代码不需要任何修改。

@Bean
public Step createStep() {
    return stepBuilderFactory.get("MyStep")
            // 泛型对齐为输入ReadItem、输出ProcessedItem
            .<ReadItem, ProcessedItem>chunk(100) // Chunk大小可根据性能要求调整，不用再设为1
            .reader(myCustomReader)
            .processor(myCustomProcessor)
            .writer(myCustomWriter)
            .transactionManager(transactionManager)
            .build();
}

这种实现更符合Spring Batch的组件设计约定，后续维护成本更低。

内容的提问来源于stack exchange，提问作者leonidas79