如何使用基于Java的配置来配置Spring批处理StepScope？

Question

我正在使用Spring批处理设置一个作业服务器。我的JdbcCursorItemReader需要配置sql,该sql在每个作业运行的基础上进行更改。因为sql发生了变化，所以我希望阅读器具有@stepscope，这样我就不需要担心sql的状态性了。

所以我设置了这样一个类：

public class ParameterSettingJdbcCursorItemReader extends JdbcCursorItemReader implements StepExecutionListener {

    @Override
    public void beforeStep(StepExecution stepExecution) {

        JobParameters jobParameters = stepExecution.getJobParameters();

        if (jobParameters != null) {
            List<Object> args = new ArrayList<Object>();
            for (JobParameter jobParameter : jobParameters.getParameters().values()) {
                args.add(jobParameter.getValue());
            }

            Object[] arrayArgs = args.toArray(new Object[args.size()]);
            String sql = String.format(getSql(), arrayArgs);
            setSql(sql);
        }
    }

    @Override
    public ExitStatus afterStep(StepExecution stepExecution) {
        return null;
    }
}

我在整个服务器上使用基于Java的配置。ItemReader的一个实例的bean如下所示：

@Bean
@StepScope
public ItemReader<MyInputObject> myInputObjectItemReader() {
    ParameterSettingJdbcCursorItemReader itemReader = new ParameterSettingJdbcCursorItemReader();
    itemReader.setDataSource(myDataSource());
    itemReader.setSql("SELECT * FROM my_table WHERE date = '%1$s'");
    itemReader.setRowMapper(myInputObjectMapper);
    return itemReader;
}

启动服务器并运行Spring批处理作业时，会出现以下错误:java.lang.IllegalStateException:No Scope registered for Scope“step”

我在其他地方读到，为了能够使用StepScope，首先需要将其添加到xml应用程序配置中，如下所示:

但由于我使用的是基于Java的配置，所以这不是一个选项。

那么如何通过基于Java的配置注册StepScope呢？我试过这个：

@Bean
public org.springframework.batch.core.scope.StepScope stepScope() {
    return new org.springframework.batch.core.scope.StepScope();
}

...但是当我这样做的时候，我会在bean上的应用程序启动过程中得到各种与stepscope无关的NPE。

Answer 1

您必须向applicationcontext注册作用域。通常情况下，当您使用@enablebatchprocessing时，这将为您完成。您是否做到了（将该注释添加到@configurations)？