Spring批处理步骤的不同组合

Question

我正在做一个项目，我将使用Spring批处理和Spring集成来创建工作流系统。这个工作流系统应该能够从队列中读取消息，这实际上是来自客户端的作业请求，根据作业请求类型，我需要调用一些7-8系统。

每个系统从某个位置读取输入文件（通常是一个集中存储系统，其中所有输入文件都存储在客户提交的文件中），对其进行处理，然后将其传递给下一个系统，最终我应该能够响应客户端，例如SUCCESS如果它被所有系统成功处理并失败，如果任何系统未能处理文件，如果失败，客户端应该能够从实际失败的步骤重新启动失败的作业。

我将在Spring批处理中添加每个系统作为一个步骤，然后使用Spring集成，我将为系统建模特定的流——例如FTP获取文件、发送JMS/SMAPI请求、接收JMS响应、返回FTP文件。等

我的问题是：

1. 这是正确的方法吗？
2. 如果“是”，使用Spring Batch和Spring集成时的性能调整注意事项是什么？
3. 由于所有系统不会一直以相同的顺序调用，因此如何使用Spring Batch作为潜在的Spring Batch作业编写所有可能的组合？

Answer 1

问题1：同时使用Spring集成和Spring Batch是个好主意。

问题2：对于Spring Batch，您有很多可扩展的选项，因此可以提高性能。你可以并行地启动整个作业，并行地执行步骤，并行地执行块。。。基本问题是：

1. 瓶颈在哪里
2. 并行化在哪里提高了性能

问题3：基本上，Spring Batch不是一个工作流系统。它支持具有固定步骤顺序的作业。

选项1：可以在各自的作业（“jobSystemA”、“jobSystemB”）中对每个系统进行建模。这样，您就可以在“集成”层中实现流的逻辑，并按照正确的顺序为每个系统启动新作业。

选项2：如果您有固定数量的可能流，例如

Flow 1:
Step A (System A)
Step B (System B)
Step C (System C)

Flow 2:
Step A (System A)
Step C (System C)
Step B (System B)

您可以为每个可能的“流”定义一个作业，并将对特定系统作业的调用实现为“StepJob”，它调用特定的“jobSystem”——选项1中提到的作业；差不多

JobFlow1
  Step1 {JobStep call jobSystemA}
  Step2 {JobStep call jobSystemB}
  Step3 {JobStep call jobSystemC}

JobFlow2
  Step1 {JobStep call jobSystemA}
  Step2 {JobStep call jobSystemC}
  Step3 {JobStep call jobSystemB}

选项3：如果使用SpringBatch的fluent API以编程方式定义作业，则可以自由创建一个用于在运行时定义作业的API。