SpringBatch并行处理四种模式分别是什么

本篇文章给大家分享的是有关Spring Batch并行处理四种模式分别是什么，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。

成都创新互联公司坚持“要么做到，要么别承诺”的工作理念，服务领域包括：成都网站建设、做网站、企业官网、英文网站、手机端网站、网站推广等服务，满足客户于互联网时代的石狮网站设计、移动媒体设计的需求，帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴！

1 四种模式

大多数情况下，单线程、单进程的Spring Batch已经能满足你的需求。在我们走向更复杂的特性之前，先看看简单的能不能用，Keep it Simple and Stupid。

不过，当你确定要使用并行处理时，Spring Batch也提供了多种选择。整体上分为两大类：

（1）单进程、多线程
（2）多进程

细分如下：

（1）多线程的Step（单进程）
（2）并行的Steps（单进程）
（3）远程分块（多进程）
（4）远程分区（多进程）

光从名字看，很难理解它们之间的差别，我们来一一介绍吧。

1.1 多线程的Step

通过提供一个TaskExecutor来执行，而TaskExecutor是可以自定义的，我们可以提供一个基于线程池的TaskExecutor，则可以实现多线程处理。

@Bean
public TaskExecutor taskExecutor(){
  return new SimpleAsyncTaskExecutor("spring_batch");
}

@Bean
public Step sampleStep(TaskExecutor taskExecutor) {
  return this.stepBuilderFactory.get("sampleStep")
    .chunk(10)
    .reader(itemReader())
    .writer(itemWriter())
    .taskExecutor(taskExecutor)
    .build();
}

1.2 并行Steps

这个看起来跟第一个很像，其实完全不一样。它是多个steps之间来并行处理。所以job应该是可以分解为独立的step，不是按一步一步的顺序处理，这样才可以并行执行。比如下面的例子，step1和step2合并成一个flow1，而step3为flow2，flow1与flow2之间可以并行处理。

Spring Batch并行处理四种模式分别是什么

代码如下：

@Bean
public Job job() {
  return jobBuilderFactory.get("job")
    .start(splitFlow())
    .next(step4())
    .build()        //builds FlowJobBuilder instance
    .build();       //builds Job instance
}

@Bean
public Flow splitFlow() {
  return new FlowBuilder("splitFlow")
    .split(taskExecutor())
    .add(flow1(), flow2())
    .build();
}

@Bean
public Flow flow1() {
  return new FlowBuilder("flow1")
    .start(step1())
    .next(step2())
    .build();
}

@Bean
public Flow flow2() {
  return new FlowBuilder("flow2")
    .start(step3())
    .build();
}

@Bean
public TaskExecutor taskExecutor(){
  return new SimpleAsyncTaskExecutor("spring_batch");
}