在spring batch中将当前时间戳作为作业参数传递

Question

我正在使用spring batch，但由于作业实例已经存在错误，我需要在我的作业参数中添加当前时间。我无法确定在哪里添加作业参数。下面是我的代码：

<step id="myStep">
 <tasklet>
  <chunk reader="myReader" processor="myProcessor" writer="myWriter" commit-interval="6000" skip-limit="9000">
  //some more code.
 </chunk>
 </tasklet>
</step>

<bean id="myReader" class="org.springframework,batch.item.database.StoredProcedueItemReader" scope="step">
 //define property for datasource , procedurename , rowmapper, parameters
 <property name="preparedStatementSetter" ref="myPreparedStatmentSetter">
</bean>

<bean id="myPreparedStatmentSetter" class="com.mypackage.MyPreparedStatementSetter" scope="step">
 <property name="kId" value="#{jobParameters[kId]}">
</bean>

当我尝试为相同的kid多次运行作业时，我会得到，作业已经存在错误，所以我需要将当前时间戳添加到我的作业参数中。在bean中添加当前时间戳作为属性MyPreparedStatmentSetter就足够了，还是需要在其他地方添加jobparameter？spring文件中jobparameters到底是从哪里挑选的？

这是我的jobLauncher bean

<bean Id= "jobLauncher "class="org.springframework.batch.core.launch.support.SimpleJobLauncher">
 <property name="jobRepository" value="myJobRepo">
</bean>

Answer 1

手工添加一个“随机”作业参数，虽然它可以工作，但不是解决作业实例已经存在错误的最理想方法。相反，您应该考虑在作业中添加JobParametersIncrementer。Spring提供runidincrementer作为开箱即用的实现。用它配置的作业如下所示：

@Bean
public Job myJob() { 
    return jobBuilderFactory.get("myJob")
                            .incrementer(runIdIncrementer())
                            .start(step1())
                            .build();
}

@Bean
public JobParametersIncrementer runIdIncrementer() {
    return new RunIdIncrementer();
}