本文介紹了來自Spring Batch的JobParameters的處理方法,對大家解決問題具有一定的參考價值,需要的朋友們下面隨著小編來一起學習吧!
問題描述
我正在嘗試將作業參數注入自定義ItemReader。我已經回顧了關于這個主題的所有StackOverflow注釋(示例:How to get access to job parameters from ItemReader, in Spring Batch?),我發現這是一個常見的痛點,大部分都沒有解決。我希望春天的大師(@Michael Minella Anyone)能看到這一點,并有一些洞察力。
我已經確定作業參數大約每10次運行中就有一次可用,即使沒有代碼或配置更改。這是一個隨機成功的案例,而不是隨機失敗的案例,因此很難追蹤。
我使用調試器深入研究了Spring代碼,確定當此操作失敗時,在發生注入時沒有名為jobParameters的bean在Spring中注冊。
我使用的是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
Launch-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" />
Module-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>
JOB
讓推薦答案參數正常工作的重要步驟是定義StepScope
Bean,并確保您的讀取器是@StepScope
組件。
我將嘗試以下操作:
首先,確保定義了一個步驟bean。這很適合使用Java配置進行設置:
@Configuration
public class JobFrameworkConfig {
@Bean
public static StepScope scope() {
return new StepScope();
}
// jobRegistry, transactionManager etc...
}
然后,確保您的bean通過使用@StepScope
注釋(與您的示例幾乎相同)來確定步驟范圍。插入不是@Lazy
的@Value
。
@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 Batch的JobParameters的文章就介紹到這了,希望我們推薦的答案對大家有所幫助,