1

我有一个基于 spring-batch xml 的配置，应该迁移到基于注释的配置。

但我找不到任何解决方案来在 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();
}

此致

4

2 回答 2

3

使用 @Component 标记 PointFileReader 和 PointFileWriter PointFileProcessor，如果需要，使用 @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;
}
于 2014-11-13T13:22:00.533 回答
1

只需删除 .tasklet 部分，如果您想要类型安全，请使用.<TypeFromReader, TypeForWriter>chunk

.tasklet 用于自定义 Tasklet，.chunk 已经为您提供了（隐藏的）基于块的实现

于 2014-11-13T12:13:56.657 回答