如何定制弹簧集成流程

Question

我有类似要求

1. 文件来自FTP
2. 文件被复制到本地目录
3. 文件被拾取
4. 要解析和读取的服务器1
5. 服务2以丰富XYZ
6. 服务3丰富CDY
7. 服务4将数据持久存储在数据库中并获取生成的ID集（稍后需要）
8. 服务5，以基于服务4丰富另一条信息
9. 服务6将向另一个系统发送消息
10. 服务7将再次更新数据
11. 服务8然后将执行某些操作，等等
12. 将文件移回完成的目录

在这一点上，我正在考虑具有一个将处理FTP端的流程并获取文件并下载。

流程＃02将选择文件并按照上述说明进行处理]

我的问题是，我是否应该将变压器用于上述所有这些步骤。如果所有变压器都带有一个流量，还是应该细分为子流量，也可以吗？]

如果任何转换器抛出异常，它将只忽略其余的转换器并进入错误通道吗？

此外，如果我放置一个异常处理通道，我实际上会知道在哪一步抛出了异常？

Answer 1

如果您不熟悉许多其他Spring Integration组件，例如Enricher：https://docs.spring.io/spring-integration/reference/html/message-transformation.html#content-enricher和JPA通道适配器：https://docs.spring.io/spring-integration/reference/html/jpa.html#jpa，您真的可以使用转换器做所有事情。

即使您将拥有多个应用程序实例，您实际上也可以在一个流程中完成所有操作。可以配置一个流程，使每个步骤都可以分布到整个群集以进行均匀计算。另一方面，我确实将流程分为几个逻辑单元。