Spring Cloud Stream AggregateApplication与本地数据流服务器

Question

我正在尝试创建与Data Flow Web Server一起运行的Spring Cloud Stream聚合应用程序，以便能够通过Web UI管理应用程序。

应用程序运行程序类：

@SpringBootApplication
public class Runner {

public static void main(String[] args) {
    new AggregateApplicationBuilder(args).web(true)
            .from(JSONFileSourceApplication.class).args("--fixedDelay=5000")
            .via(ProcessorOne.class)
            .to(LoggingSinkApplication.class).run(args);
}

这工作正常。现在正在尝试添加数据流服务器。创建类：

@SpringBootApplication
@EnableDataFlowServer
public class WebServer {}

并将其设置为Aggregate Application Builder的父配置：

...
    new AggregateApplicationBuilder(WebServer.class, args).web(true)
...

如果我运行它，将发生以下异常：

BeanCreationException: Error creating bean with name 'initH2TCPServer' ... 
Factory method 'initH2TCPServer' threw exception ... Exception opening port "19092" (port may be in use)

看起来Aggregate Application Builder进程试图创建另一个H2服务器，而不是使用父配置中的服务器。

如果在我的JSONFileSourceApplication、ProcessorOne和LoggingSinkApplication类中用@配置替换@SpringBootApplication注释-流应用程序启动，web服务器启动(http://localhost:9393/dashboard)，但我没有看到我的流组件，web UI中的所有选项卡都是空的。

如何运行启用了WebUI的Spring Cloud Stream Aggregate Application？

Answer 1

SCDF目前的情况是，它不支持聚合应用程序的概念。

造成这种情况的主要原因是，SCDF假设应用程序属于已知通道类型；它是输入/输出或两者兼有（对于处理器）。然而，当使用AggregateApplicationBuilder时，有多种方法可以组合频道，并且DSL/UI中的自动发现和绑定频道变得模糊。

也就是说，在即将发布的版本中，

1）我们计划引入“函数链接”的概念。这允许在运行时将“多个”小函数（例如filterNulls、transformToUppercase、splitByHypen、...）组合到单个流应用程序中。作为开发人员，您将专注于独立开发/测试函数并将它们注册到SCDF。一旦在注册表中可用，您将拥有新的DSL原语将它们组合成一个单元，该单元在内部由SCDF链接（在运行时）。

2） 我们计划提高队列/主题的可见性。将有DSL原语与它们直接交互并创建数据管道。考虑到这种灵活性，类似组合的用例将更容易实现。