用于Spring Integration中动态流生成的基于JSON或Pipe(|)的DSL



我们正在使用Java DSL创建一些SI流。所有流都集中在一个Spring启动应用程序中,这使得我们每次添加新流时都可以重新部署该应用程序。如果我们以某种方式将流创建抽象为JSON格式或管道分隔的流指令,我会感到好奇。这样我们就可以动态地创建流并注册它。我已经尝试过搜索,但一无所获。如果可能的话,请引导我朝着正确的方向去实现它。。?

您的故事听起来更像Spring Cloud Stream和Spring Cloud Data Flow的组合:

https://spring.io/projects/spring-cloud-stream

https://spring.io/projects/spring-cloud-dataflow

通过在运行时加载XML配置,可以实现与您所要求的类似的解决方案。我们有一些旧项目(目前不支持(-Spring Integration Flow:

https://github.com/spring-projects/spring-integration-flow

尽管您所要求的最大问题是那些动态流中可能使用的组件的Java代码。因此,从一些流畅的外部配置加载动态流是不可能的,因为不清楚如何提供支持的Java代码。

到目前为止,我们所拥有的是Java DSL的动态流:https://docs.spring.io/spring-integration/docs/current/reference/html/dsl.html#java-dsl运行时流。但它仍然不能被表示为来自外部的一些花哨的JSON。它必须是一个应该编译到分类的代码,只有在那之后,我们才能在运行时将它们连接到集成流中。

最新更新