Spring Batch能否用Composite Item Processor一步生成两个实体？

完全可以在一个步骤里完成你的业务流程，不需要拆分成两个步骤，而且这里用不上Composite Item Processor——它的作用是串联多个单输入单输出的处理器做链式处理，不是用来生成多实体的。

具体实现思路 #

1. 封装复合对象：定义一个包含B和C实体的复合类（比如BcPair），用来在处理器和写入器之间传递两个实体。
2. 自定义ItemProcessor：输入A实体，加工后返回封装好的BcPair对象。
3. 使用CompositeItemWriter：配置两个独立的ItemWriter，分别从BcPair中提取B、C实体，写入对应的表。

代码示例 #

1. 定义复合对象

public class BcPair {
    private B bEntity;
    private C cEntity;

    // 构造方法、getter/setter
    public BcPair(B bEntity, C cEntity) {
        this.bEntity = bEntity;
        this.cEntity = cEntity;
    }

    // 省略getter和setter
}

2. 自定义处理器

public class AToBcProcessor implements ItemProcessor<A, BcPair> {
    @Override
    public BcPair process(A aEntity) throws Exception {
        // 从A实体加工生成B、C实体的业务逻辑
        B b = new B();
        b.setXXX(aEntity.getXXX());
        // ... 其他赋值操作

        C c = new C();
        c.setYYY(aEntity.getYYY());
        // ... 其他赋值操作

        return new BcPair(b, c);
    }
}

3. 配置复合写入器

@Bean
public CompositeItemWriter<BcPair> compositeItemWriter(ItemWriter<B> bItemWriter, ItemWriter<C> cItemWriter) {
    CompositeItemWriter<BcPair> compositeWriter = new CompositeItemWriter<>();
    
    List<ItemWriter<? super BcPair>> delegateWriters = new ArrayList<>();
    // 处理B实体的写入逻辑
    delegateWriters.add(items -> {
        List<B> bItems = items.stream().map(BcPair::getBEntity).collect(Collectors.toList());
        bItemWriter.write(bItems);
    });
    // 处理C实体的写入逻辑
    delegateWriters.add(items -> {
        List<C> cItems = items.stream().map(BcPair::getCEntity).collect(Collectors.toList());
        cItemWriter.write(cItems);
    });

    compositeWriter.setDelegates(delegateWriters);
    return compositeWriter;
}

4. 组装步骤

@Bean
public Step processAndWriteStep(StepBuilderFactory stepBuilderFactory,
                                ItemReader<A> aItemReader,
                                AToBcProcessor aToBcProcessor,
                                CompositeItemWriter<BcPair> compositeItemWriter) {
    return stepBuilderFactory.get("processAndWriteStep")
            .<A, BcPair>chunk(100)
            .reader(aItemReader)
            .processor(aToBcProcessor)
            .writer(compositeItemWriter)
            .build();
}

关于多实体支持的问题 #

Spring Batch的步骤本身是基于单一输入输出类型设计的，但通过封装复合对象的方式，就能实现同时处理不同实体——本质是把多个实体打包成一个对象在步骤中传递，最后在写入层拆分处理，完全满足你的业务需求。

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