akka - 如何使用 Akka 在 SIGTERM 上进行自定义关闭？

Question

默认情况下，Akka 在收到 SIGTERM 时关闭 actor 系统。 .在关闭 akka 系统之前，如何覆盖此行为以执行自定义关闭逻辑？我已经在 Actor 中实现了这个逻辑，使用特殊的优雅停止消息 - 我只需要在 SIGTERM 时调用该逻辑收到。

还是我必须使用其他方式关闭应用程序？这也是一种选择。

Answer 1

您可以使用 sys.shutdownHookThread像这样:

def main(args: Array[String]) {
  ... initialization code ...
  sys.shutdownHookThread {
    println "Shutting down ..."
    shutdownHandler ! DoSomething
  }
}