如何在多Job中为@StepScoped的ItemReader设置字段值？

你遇到的"bean ItemReader is not active for current thread"错误，本质是**@StepScope作用域的Bean延迟初始化特性导致的**：这类Bean不会在Spring容器启动时创建实例，只有当对应的Step开始执行时，才会生成绑定当前Step上下文的实例。而你在配置类定义Step的阶段直接调用reader.setFolderType()，此时Reader实例还未被初始化，自然会触发这个错误。

下面是几种无需依赖Job Parameters的可行解决方案：

方案一：通过工厂方法创建带参数的@StepScope Reader #

放弃直接注入SomeItemReader，改为在配置类中定义带参数的工厂方法，为每个Step生成独立的Reader实例，同时注入对应的folder值。

修改后的Reader代码 #

保持Reader的@StepScope，新增构造方法接收folder参数（替代Setter）：

@Component
@StepScope
public class SomeItemReader implements ItemReader<String> {

    @Value("#{jobParameters['date']}")
    private String date;
    private final String folder;

    // 用构造方法注入folder，避免Setter的线程安全问题
    public SomeItemReader(String folder) {
        this.folder = folder;
    }

    // 实现read()方法...
}

配置类修改 #

在配置类中为每个Step单独创建Reader实例，通过StepScope的工厂方法传递folder值：

@Setter
@Configuration
@EnableBatchProcessing
@RequiredArgsConstructor
@ConfigurationProperties(prefix = "ftp")
public class BatchConfiguration {
  
  private String folderA;
  private String folderB;

    @Bean
    @StepScope // 每个Step会生成独立的实例
    public SomeItemReader readerA() {
        return new SomeItemReader(folderA);
    }

    @Bean
    @StepScope
    public SomeItemReader readerB() {
        return new SomeItemReader(folderB);
    }

    @Bean
    public Step importStepA(StepBuilderFactory stepBuilderFactory,
                           ItemProcessor<String, List<***>> processor,
                           SomeItemReader readerA, // 注入对应Step的Reader
                           ItemWriter<List<***>> itemWriter,
                           BackOffPolicy policy
    ) {
        return stepBuilderFactory.get("importStepA")
                .<String, List<***>>chunk(chunkSize)
                .reader(readerA)
                .processor(processor)
                .writer(itemWriter)
                .faultTolerant()
                .backOffPolicy(policy)
                .retry(***.class)
                .retry(IOException.class)
                .retryLimit(retryLimit)
                .build();
    }

    @Bean
    public Step importStepB(StepBuilderFactory stepBuilderFactory,
                           ItemProcessor<String, List<***>> processor,
                           SomeItemReader readerB,
                           ItemWriter<List<***>> itemWriter,
                           BackOffPolicy policy
    ) {
        return stepBuilderFactory.get("importStepB")
                .<String, List<***>>chunk(chunkSize)
                .reader(readerB)
                .processor(processor)
                .writer(itemWriter)
                .faultTolerant()
                .backOffPolicy(policy)
                .retry(***.class)
                .retry(IOException.class)
                .retryLimit(retryLimit)
                .build();
    }
}

方案二：通过StepExecutionContext传递参数 #

在Step配置时将folder值存入StepExecutionContext，然后在Reader中读取这个值。

Reader代码修改 #

实现StepExecutionListener接口，从Step上下文获取folder：

@Component
@StepScope
public class SomeItemReader implements ItemReader<String>, StepExecutionListener {

    @Value("#{jobParameters['date']}")
    private String date;
    private String folder;

    @Override
    public void beforeStep(StepExecution stepExecution) {
        // 从Step上下文获取预先存入的folder值
        this.folder = stepExecution.getExecutionContext().getString("folder");
    }

    // 实现read()方法...
}

配置类修改 #

在定义Step时，通过listener()方法将folder存入StepExecutionContext：

@Bean
public Step importStepA(StepBuilderFactory stepBuilderFactory,
                       ItemProcessor<String, List<***>> processor,
                       SomeItemReader reader,
                       ItemWriter<List<***>> itemWriter,
                       BackOffPolicy policy
) {
    return stepBuilderFactory.get("importStepA")
            .<String, List<***>>chunk(chunkSize)
            .reader(reader)
            .processor(processor)
            .writer(itemWriter)
            // 存入folder值到Step上下文
            .listener((StepExecutionListener) stepExecution -> 
                stepExecution.getExecutionContext().putString("folder", folderA))
            .faultTolerant()
            .backOffPolicy(policy)
            .retry(***.class)
            .retry(IOException.class)
            .retryLimit(retryLimit)
            .build();
}

@Bean
public Step importStepB(StepBuilderFactory stepBuilderFactory,
                       ItemProcessor<String, List<***>> processor,
                       SomeItemReader reader,
                       ItemWriter<List<***>> itemWriter,
                       BackOffPolicy policy
) {
    return stepBuilderFactory.get("importStepB")
            .<String, List<***>>chunk(chunkSize)
            .reader(reader)
            .processor(processor)
            .writer(itemWriter)
            .listener((StepExecutionListener) stepExecution -> 
                stepExecution.getExecutionContext().putString("folder", folderB))
            .faultTolerant()
            .backOffPolicy(policy)
            .retry(***.class)
            .retry(IOException.class)
            .retryLimit(retryLimit)
            .build();
}

方案三：用@Value结合配置属性占位符 #

直接在Reader中通过@Value注入不同的配置属性，配合Spring的占位符解析，无需手动调用Setter。

Reader代码修改 #

@Component
@StepScope
public class SomeItemReader implements ItemReader<String> {

    @Value("#{jobParameters['date']}")
    private String date;
    // 通过占位符注入，占位符的值由Step上下文传递
    @Value("#{stepExecutionContext['folderProp']}")
    private String folder;

    // 实现read()方法...
}

配置类修改 #

在Step配置时，通过JobParameters或者直接设置Step上下文的占位符值：

@Bean
public Step importStepA(StepBuilderFactory stepBuilderFactory,
                       ItemProcessor<String, List<***>> processor,
                       SomeItemReader reader,
                       ItemWriter<List<***>> itemWriter,
                       BackOffPolicy policy
) {
    return stepBuilderFactory.get("importStepA")
            .<String, List<***>>chunk(chunkSize)
            .reader(reader)
            .processor(processor)
            .writer(itemWriter)
            .listener((StepExecutionListener) stepExecution -> 
                stepExecution.getExecutionContext().putString("folderProp", folderA))
            .faultTolerant()
            .backOffPolicy(policy)
            .retry(***.class)
            .retry(IOException.class)
            .retryLimit(retryLimit)
            .build();
}

方案对比 #

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