Spring Cloud 数据流的准备情况

Question

Spring Cloud Data Flow的文档描述了如何与Kubernetes准备探针集成。我正在本地开发我的数据流，并在Docker-Compose配置中运行，而我们等待K8S SCDF环境站立。

是否有其他方法可以实现准备就绪 /不发送SCDF的数据上下文？组件旋转后，我需要重新调用，然后对结果进行一些计算。尝试失败的事情：

• 使用ApplicationavailabilityEvents-在发布加载 +汇编后，发布fargeinessstate。当Spring完成自己的负载时，它会发布Accepting_traffic，因此不会在我的服务中等待我。
• 设置一个应用程序设备，该应用程序还可以作为定制事件的应用程序列表，我在计算完成后投掷的应用程序列表。有效地，Run（）方法看起来像：

public class ApplicationStartupRunner implements ApplicationRunner, ApplicationListener {

private boolean sessionLoaded = false;

public void run(ApplicationArguments args) {

  doTimeExpensiveThing();

  while (!sessionLoaded) {
    TimeUnit.MILLISECONDS.sleep(150);
  }
}

public void onApplicationEvent(SessionLoadEvent event) {

  this.sessionLoaded = true;

}
}

附加技术注意：Spring Boot应用程序是作为处理器构建的，该应用程序使用函数作为Bean提供的功能来提供其功能，ALA 公共功能＆lt; flux＆lt; changeEvent＆gt;，flux＆lt; arter ProcessChangeEvents（）（）

最佳，无论我使用的是在Docker-Compose中起作用的方法，我都会将其连接到一个指示器中，该指标将由K8S及其就绪探针拾取。鉴于SCDF可以部署在K8，Docker-Compose（本地）或CloudFoundry上，希望我可以挂在我刚刚忽略的模型中。

Answer 1

潜在的答案：与其使用ApplicationRunner，不如在ProcessChangeEvents方法中等待，不要返回该功能，直到启动处理完成为止。

在我们的情况下，由于Dotime Expensivething是一种异步活动，因此我使用观看/等待Session LoadSload的标志的技术，但现在在ProcessChangeEvents方法本身中。

@Configuration
public class ConfigurationForProcessor implements ApplicationEventListener<SessionLoadEvent> {

  boolean sessionLoaded;

  Function<Flux<ChangeEvent>, Flux<Alert>> processChangeEvents() {
    
    doTimeExpensiveAsynchronousThing();

    while (!sessionLoaded) {
      TimeUnit.MILLISECONDS.sleep(150);
    }

    return (Flux<ChangeEvent>) -> ... code which returns a Flux of Alert
  }

  public void onApplicationEvent(SessionLoadEvent event) {
    this.sessionLoaded = true;
  }
}

对其他方法非常开放。这看起来像是在起作用，尽管不确定我还没有遇到过的陷阱。