Spring Batch：如何在运行时读取Chunk Size？

当然可以在运行时读取Chunk Size！针对你提到的要在ChunkListener的afterChunk方法里动态获取这个值的需求，Joe Chiavaroli提出的方案确实很实用，我来给你拆解具体的实现步骤：

• 第一步：在Batch配置类中注入Chunk Size参数
  先在你的批处理配置类里，把Chunk Size作为可注入的参数（可以用@Value读取配置文件值，也可以直接指定固定值，根据你的实际场景选择），示例代码如下：

  @Configuration
  public class BatchConfig {
      // 可从配置文件读取，默认值设为10
      @Value("${batch.chunk.size:10}")
      private int chunkSize;
  
      @Bean
      public Step myStep(ItemReader<?> reader, ItemProcessor<?, ?> processor, ItemWriter<?> writer, MyChunkListener chunkListener) {
          return stepBuilderFactory.get("myStep")
                  .<Object, Object>chunk(chunkSize)
                  .reader(reader)
                  .processor(processor)
                  .writer(writer)
                  .listener(chunkListener)
                  .build();
      }
  
      @Bean
      public MyChunkListener myChunkListener() {
          // 通过构造函数把chunkSize传递给监听器
          return new MyChunkListener(chunkSize);
      }
  }
  

• 第二步：自定义ChunkListener接收并使用Chunk Size
  接着在你实现的ChunkListener中，通过构造函数接收这个Chunk Size，这样就能在afterChunk方法里直接调用它来执行你的更新操作了：

  public class MyChunkListener implements ChunkListener {
      private final int chunkSize;
  
      // 构造函数注入chunkSize
      public MyChunkListener(int chunkSize) {
          this.chunkSize = chunkSize;
      }
  
      @Override
      public void afterChunk(ChunkContext context) {
          // 在这里就能动态获取到配置的Chunk Size，执行你的更新逻辑
          System.out.println("当前批处理的Chunk Size为：" + chunkSize);
          // 你的更新操作代码...
      }
  
      // 按需实现其他ChunkListener方法
  }
  

这种方式简单直接，通过依赖注入把配置的Chunk Size传递给监听器，不需要额外从上下文里查找，代码的可读性和维护性都很不错，完全能满足你在afterChunk方法中获取Chunk Size并执行更新的需求。

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