我有一个基于 xml 的 spring-batch 配置,应该迁移到基于注释的配置。
但我找不到任何解决方案来将块定义到 tasklet 定义中。
有我的xml和代码库延迟:
<step id="files2Memory">
<tasklet>
<chunk reader="pointFileReader" processor="pointFileProcessor"
writer="pointFileWriter" commit-interval="50000"/>
</tasklet>
</step>
public Step files2Memory() {
return stepBuilders.get("files2Memory")
.tasklet(new Tasklet() {
@Override
public RepeatStatus execute(StepContribution stepContribution, ChunkContext chunkContext) throws Exception {
return null;
}
})
.chunk(50000)
.reader(new PointFileReader())
.writer(new PointFileWriter())
.processor(new PointFileProcessor())
.build();
}
此致敬意
将 PointFileReader 和 PointFileWriter PointFileProcessor 标记为@Component,如果需要,请使用 @Scope("step")。确保组件扫描覆盖它们。
在您的批处理配置文件中自动执行上述操作。
@Autowired
private PointFileWriter pointFileWriter ;
@Autowired
private PointFileReader pointFileReader ;
@Autowired
private ItemProcessor<TypeFromReader, TypeForWriter> pointFileProcessor ;
@Autowired
private PlatformTransactionManager transactionManager;
...
@Bean
protected Step files2Memory(){
return steps
.get("files2Memory")
.transactionManager(transactionManager)
.<TypeFromReader, TypeForWriter> chunk(5000)
.reader(pointFileReader )
.processor(pointFileProcessor)
.writer(pointFileWriter).build();
}
如果其中一个 PointFileReader 和 PointFileWriter PointFileProcessor 不能指定为 PointFileReader 和 PointFileWriter PointFileProcessorPointFileReader 和 PointFileWriter @Component则可以将它们定义为 @Beans 并将字段替换为方法调用
例如
@Bean
protected ItemReader<TypeFromReader> pointFileReader() {
PointFileReader <TypeFromReader> reader = new PointFileReader <TypeFromReader>();
reader.set(...)
return reader;
}
只需删除.tasklet部分,如果要类型安全,请使用.<TypeFromReader, TypeForWriter>chunk
.tasklet用于自定义Tasklets,.chunk已经为您提供了(隐藏的)基于块的实现