如何在JVM关闭时允许/等待Akka流完成？

问题描述

基本上，我的目标是在重新启动正在处理一堆Akka流的服务器时，关闭挂钩应等待所有流完成，然后终止ActorSystem。

我定义了一个关闭方法，该方法可以终止actor系统，就像这样-

def close(): Future[Terminated] = {
    logger.info("Terminating actor system")
    system.terminate()
  }

然后从JVM的关闭钩子中调用它。

但是，这显然不是等待流完成，而是只是中止正在运行的流并终止actor，这不能解决我正在尝试做的事情。因此，这似乎不正确。

我还通读了参与者支持其自身的关闭挂钩的文档，但是如何配置它们以使流运行到完成，然后才允许JVM退出？

解决方法

我们为此使用killswitch：它允许关闭actor流。您仍然需要等待所有流完成，killswitch才启动适当的流关闭。