Spring Batch：如何用父类实现带差异化JobName的ItemWriter？

我有一个Spring Batch应用，包含两个独立作业：它们使用不同的Reader，但Processor和Writer几乎完全一致，仅Writer的jobName属性值存在差异。尝试通过Writer父类实现该逻辑，以下是对应问题的解答：

1. 该方案是否可行？ #

完全可行。这是模板方法模式的典型应用场景：父类封装通用的写入逻辑，子类仅负责差异化的属性配置（这里就是jobName），既符合Spring Batch的组件复用设计思想，也能有效减少代码冗余。

2. 如何在配置类中调用对应的Writer？ #

在各自的Job配置类中，分别定义对应Writer子类的Bean，然后在Step配置中注入该Bean即可。具体实现如下：

JobConfig1 修改后 #

public class JobConfig1{
  // ... 其他配置

  @Bean
  public Step jobStep(SynchronizedItemStreamReader<InputObj1> someReader1,
      ItemWriter<DTOObject> someWriter1) {
    return stepBuilderFactory
        .get("nightlyWriteStep") // 建议Step名称区分开，避免跨配置冲突
        .chunk(writeChunkSize)
        .reader(someReader1)
        .processor(new SomeProcessor())
        .writer(someWriter1)
        .faultTolerant()
        .build();
  }

  // 定义SomeWriter1的Bean
  @Bean
  public ItemWriter<DTOObject> someWriter1() {
    return new SomeWriter1();
  }

  // reader、processor的配置...
}

JobConfig2 修改后 #

public class JobConfig2{
  // ... 其他配置

  @Bean
  public Step jobStep(SynchronizedItemStreamReader<InputObj1> someReader2,
      ItemWriter<DTOObject> someWriter2) {
    return stepBuilderFactory
        .get("intradayWriteStep") // 区分Step名称
        .chunk(writeChunkSize)
        .reader(someReader2)
        .processor(new SomeProcessor())
        .writer(someWriter2)
        .faultTolerant()
        .build();
  }

  // 定义SomeWriter2的Bean
  @Bean
  public ItemWriter<DTOObject> someWriter2() {
    return new SomeWriter2();
  }

  // reader、processor的配置...
}

3. Writer类的签名应如何定义？ #

• 父类SomeWriter需要实现Spring Batch的ItemWriter<DTOObject>接口，将jobName定义为protected（方便子类直接访问），或者提供getter方法；
• 子类仅需继承父类，通过构造方法赋值差异化的jobName即可。

父类签名修正 #

public abstract class SomeWriter implements ItemWriter<DTOObject> {
    protected String jobName; // 改为protected，子类可直接访问

    @Override
    public void write(List<? extends DTOObject> items) throws Exception {
        // 通用写入逻辑，使用jobName属性
        // 具体写入操作...
    }
}

子类签名修正 #

public class SomeWriter1 extends SomeWriter {
    public SomeWriter1() {
        this.jobName = "NIGHTLY"; // 构造方法赋值，更规范
    }
}

public class SomeWriter2 extends SomeWriter {
    public SomeWriter2() {
        this.jobName = "INTRADAY";
    }
}

注：父类设为抽象类，可强制子类必须完成差异化配置，避免误用。

4. write()方法应放在父类还是子类？ #

必须放在父类。因为write()是通用逻辑，统一在父类实现可以：

• 避免代码重复，后续修改写入逻辑只需维护父类；
• 符合开闭原则，新增作业时只需新增子类配置jobName，无需修改通用逻辑；
• 保证所有Writer的写入行为一致，避免子类实现不一致导致的业务问题。

内容的提问来源于stack exchange，提问作者shoaib-jpeg