Spring Batch v5.2中如何用StepBuilder配置异步处理器

问题背景 #

StepBuilderFactory已被弃用（计划在v5.2版本移除），改用StepBuilder构建步骤时，尝试使用AsyncItemProcessor和AsyncItemWriter实现异步处理提升性能，但遇到了强制类型转换需求和类型不匹配错误。

核心问题分析 #

1. Chunk泛型指定错误：原代码中StepBuilder的chunk方法指定了<ArchiveDevisDTO, NodeDTO>泛型，但实际业务中reader输出是MyInputItem，处理器输出是MyItem，泛型不匹配导致后续组件类型校验失败。
2. AsyncItemWriter泛型缺失：创建AsyncItemWriter时未指定泛型，编译器无法推断正确类型，引发类型不匹配报错。

修正后的代码 #

1. 修正AsyncItemWriter的Bean定义

@Bean
public MyItemWriter myItemWriter() {
    return new MyItemWriter();
}

@Bean
public AsyncItemWriter<MyItem> asyncItemWriter(MyItemWriter myItemWriter) {
    // 显式指定泛型<MyItem>，确保类型对齐
    AsyncItemWriter<MyItem> asyncItemWriter = new AsyncItemWriter<>();
    asyncItemWriter.setDelegate(myItemWriter);
    return asyncItemWriter;
}

2. 保留正确的AsyncItemProcessor Bean定义

@Bean
public MyItemProcessor myItemProcessor() {
    return new MyItemProcessor();
}

@Bean
public AsyncItemProcessor<MyInputItem, MyItem> asyncMyItemProcessor(MyItemProcessor myItemProcessor) throws Exception {
    AsyncItemProcessor<MyInputItem, MyItem> processor = new AsyncItemProcessor<>();
    processor.setDelegate(myItemProcessor);
    processor.setTaskExecutor(new SimpleAsyncTaskExecutor());
    return processor;
}

3. 修正Step构建代码

@Bean
public Step archiveMiniDevisStep(JobRepository jobRepository,
                                 PlatformTransactionManager transactionManager,
                                 AsyncItemProcessor<MyInputItem, MyItem> asyncMyItemProcessor,
                                 AsyncItemWriter<MyItem> asyncItemWriter
                                 ) {

    return new StepBuilder("MY_AWESOME_STEP", jobRepository)
            // 修正chunk泛型为实际的输入(MyInputItem)和输出(MyItem)类型
            .<MyInputItem, MyItem>chunk(chunkSize, transactionManager)
            .reader(myReader()) // 确保myReader返回ItemReader<MyInputItem>类型
            .processor(asyncMyItemProcessor) // 无需强制转换，类型自动匹配
            .writer(asyncItemWriter) // 泛型对齐后，类型匹配无报错
            .build();
}

关键说明 #

• 确保myReader()返回的是ItemReader<MyInputItem>类型，这样才能和chunk的输入泛型匹配。
• AsyncItemProcessor和AsyncItemWriter本身已经实现了ItemProcessor和ItemWriter接口，只要泛型和chunk的输入输出类型对齐，就不需要强制转换。

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