来自 Spring 批次的 JobParameters

Question

我正在尝试将作业参数注入自定义 ItemReader。我已经查看了关于该主题的所有 Whosebug 注释（示例：How to get access to job parameters from ItemReader, in Spring Batch?），我发现这是一个常见的痛点，而且大部分都没有得到解决。我希望 spring 大师（@Michael Minella 任何人）能看到这一点并有一些见解。

我已经确定作业参数在大约十分之一的运行中可用，即使没有代码或配置更改。这是一个随机成功而不是随机失败的案例，因此很难追踪。

我用调试器深入研究了 spring 代码，并确定当它失败时，在注入发生时 Spring 中没有注册名称为 jobParameters 的 bean。

我正在使用 Spring 4.1.4 与 spring-batch 3.0.2 和 spring-data-jpa 1.7.1 和 spring-data-commons 1.9.1, 运行在 java 8.

Java 类

@Component("sourceSelectionReader")
@Scope("step")
public class SourceSelectionReaderImpl  
implements ItemReader<MyThing> {
    private Map<String,Object> jobParameters;

// ... snip ...


    @Autowired
    @Lazy
    @Qualifier(value="#{jobParameters}")
    public void setJobParameters(Map<String, Object> jobParameters) {
        this.jobParameters = jobParameters;
    }
}

作业启动参数：

launch-context.xml job1 jobid(long)=1

发射-context.xml（减去绒毛）：

<context:property-placeholder location="classpath:batch.properties" />

<context:component-scan base-package="com.maxis.maximo.ilm" />

<jdbc:initialize-database data-source="myDataSource"  enabled="false">
    <jdbc:script location="${batch.schema.script}" />
</jdbc:initialize-database>

<batch:job-repository id="jobRepository" 
    data-source="myDataSource"
    transaction-manager="transactionManager"
    isolation-level-for-create="DEFAULT"
    max-varchar-length="1000"/>

<import resource="classpath:/META-INF/spring/module-context.xml" />

模块-context.xml（减去绒毛）：

<description>Example job to get you started. It provides a skeleton for a typical batch application.</description>

<import resource="classpath:/META-INF/spring/hibernate-context.xml"/>
<import resource="classpath:/META-INF/spring/myapp-context.xml"/>

<context:component-scan base-package="com.me" />
<bean class="org.springframework.batch.core.scope.StepScope" />

<batch:job id="job1">
    <batch:step id="step0002"  >            
        <batch:tasklet transaction-manager="transactionManager" start-limit="100" >
            <batch:chunk reader="sourceSelectionReader" writer="selectedDataWriter" commit-interval="1" />
        </batch:tasklet>
    </batch:step>
</batch:job>

Answer 1

尝试在@Component("sourceSelectionReader")

之后添加@DependsOn("jobParameters")

Answer 2

让作业参数起作用的重要步骤是定义 StepScope bean 并确保您的 reader 是一个 @StepScope 组件。

我会尝试以下方法：

首先确保定义了一个step-bean。使用 Java 配置设置很好：

@Configuration
public class JobFrameworkConfig {  
    @Bean
    public static StepScope scope() {
        return new StepScope();
    }
    // jobRegistry, transactionManager etc...
}

然后，通过使用 @StepScope-annotation（几乎与您的示例一样）确保您的 bean 是步进范围的。注入一个 @Value 而不是 @Lazy.

@Component("sourceSelectionReader")
@StepScope // required, also works with @Scope("step")
public class SourceSelectionReaderImpl implements ItemReader<MyThing> {
    private final long myParam;

    // Not lazy, specified param name for the jobParameters
    @Autowired
    public SourceSelectionReaderImpl(@Value("#{jobParameters['myParam']}") final long myParam) {
        this.myParam = myParam;
    }

    // the rest of the reader...
}

来自 Spring 批次的 JobParameters

JobParameters from Spring Batch

java

spring

spring-batch