代码之家 › 专栏 › 技术社区 › manash

混合顺序和并行步骤处理

spring-batch spring java

manash · 技术社区 · 9 年前

我已经扩展了FlowJob类,并将流程设置为:

final Flow subflow1 = new FlowBuilder<Flow>("subflow1")
    .start(new StepBuilder("SubFlow1-step")
            .chunk(1000)
            .reader(reader)
            .writer(writer)
            .repository(jobRepository)
            .transactionManager(txManager).build())
    .end();
final Flow subflow2 = new FlowBuilder<Flow>("subflow2")
    .start(new StepBuilder("SubFlow2-step")
            .chunk(1000)
            .reader(reader)
            .writer(writer)
            .taskExecutor(new SimpleAsyncTaskExecutor())
            .repository(jobRepository)
            .transactionManager(txManager).build())
    .end();

setFlow(new FlowBuilder<Flow>("Flow")
            .start(new StepBuilder("Flow-step1")
                    .chunk(10000)
                    .reader(reader)
                    .writer(writer)
                    .repository(jobRepository)
                    .transactionManager(txManager).build())
            .next(new StepBuilder("Flow-step2")
                    .tasklet(processor)
                    .repository(jobRepository)
                    .transactionManager(txManager).build())
            .split(new SimpleAsyncTaskExecutor())
            .add(subflow1, subflow2)
            .end());

如你所见,我想做的如下:

执行步骤1
执行步骤2
同时执行subflow1和subflow2。subflow1步骤将依次执行。subflow2步骤将并行执行(向可用线程分派块)。

当我运行作业时,正确执行步骤1和步骤2,然后作业终止。

知道吗?

编辑: SO相关问题 Spring-batch flow / split after a step .

1 回复 | 直到 7 年前

Michael Minella 9 年前

我相信这是一个错误记录。目前的解决方法是使用拆分创建流,并将流添加到作业中,如下所示:

@Bean
public Job splitJob(@Qualifier("foo") Flow foo, @Qualifier("foo") Flow bar) {
    FlowBuilder<Flow> flowBuilder = new FlowBuilder<>("split");

    Flow flow = flowBuilder.split(new SimpleAsyncTaskExecutor())
            .add(foo, bar)
            .end();

    return jobBuilderFactory.get("splitJob")
            .start(myStep1())
            .next(myStep2())
            .on("COMPLETED").to(flow)
            .end()
            .build();
}

推荐文章

Abhilash Muthuraj · 用于构建文件操作过程的Spring批处理或Spring核心库

6 年前

Nipuna Don Pranciscu · Spring批处理读取器抱怨资源

6 年前

PlickPlick · 使用@MockBean模拟带有@BeforeStep的ItemReader会对带有@BeforeStep Anotion的许多方法引发异常。我该如何解决它?

6 年前

Sheep · Spring聚合器聚合输入组

6 年前

Ares91 · Java Spring批处理使用嵌入式数据库作为元数据,使用第二个数据库作为其他数据

6 年前

R.Henderson · 我只能使用spring batch的itemReader吗

6 年前

Nikhil Pareek · 如何使用具有Java配置的CommandLineJobRunner启动Spring批处理作业

7 年前

bernardo · 无需声明额外的TaskScheduler

7 年前

Florent06 · 在上一个批处理作业启动5秒后启动计划的spring批处理作业

7 年前

tero17 · 读取大文件的最佳方式spring boot

7 年前