Team,
我正在做一个技术 poc,用于从平面文件中读取记录并将数据插入数据库。
我正在使用块任务并使用弹簧批处理管理成功运行此作业。
我必须实施重试策略以及设置每次重试之间时间间隔的功能。我坚持设置每次重试之间的时间间隔,因为卡盘不直接支持它。有什么解决方法吗?
我的代码是
<batch:job id="importDataJob" job-repository="jobRepository">
<batch:step id="importDataStep">
<batch:tasklet transaction-manager="transactionManager">
<batch:chunk reader="dataReader" writer="dataWriter" commit-interval="1" retry-limit="3">
<batch:retryable-exception-classes>
<batch:include class="javax.naming.ServiceUnavailableException" />
</batch:retryable-exception-classes>
</batch:chunk>
</batch:tasklet>
</batch:step>
</batch:job>
在您的情况下,配置将如下所示:
春季批次 2.x
<bean id="stepParent" class="org.springframework.batch.core.step.item.FaultTolerantStepFactoryBean" abstract="true">
<property name="backOffPolicy">
<bean class="org.springframework.batch.retry.backoff.FixedBackOffPolicy"
<property name="backOffPeriod" value="2000" />
</bean>
</property>
</bean>
<batch:job id="importDataJob" job-repository="jobRepository">
<batch:step id="importDataStep" parent="stepParent">
...
</batch:step>
</batch:job>
遗憾的是,batch
命名空间不支持将backOffPolicy
直接设置为 step
,请参阅 BATCH-1441。
春季批次 3.0
在 Spring Batch 3.0 中,一些类已移至其他包。这是配置片段:
<bean id="stepParent"
class="org.springframework.batch.core.step.factory.FaultTolerantStepFactoryBean"
abstract="true">
<property name="backOffPolicy">
<bean class="org.springframework.retry.backoff.FixedBackOffPolicy">
<property name="backOffPeriod" value="2000"/>
</bean>
</property>
</bean>