spray-can webservice 优雅关闭

Question

我有基于 spray.io 的 web 服务，它作为独立的 jar 运行（我使用 sbt assembly，然后只使用 java -jar myws.jar）。它与喷雾示例中的引导程序几乎相同，如下所示：

/** Bootstrap */
object Boot extends App {
   // we need an ActorSystem to host our application in
   implicit val system = ActorSystem("my-system")

   // create and start our service actor
   val service = system.actorOf(Props[MyServiceActor], "my-ws-service")

   implicit val timeout = Timeout(10.seconds)

   CLIOptionsParser.parse(args, CLIOptionsConfig()) map { config =>
     // start a new HTTP server
     IO(Http) ? Http.Bind(service, interface = config.interface, port = config.port)
   }
}

现在我只需在后台使用java -jar my-service "$@" & 运行该过程，然后使用kill -9 pid 停止。

我想优雅地停止我的网络服务，这意味着它会完成打开的连接并拒绝新的连接。

github 上的喷雾罐页面推荐to send it an Akka PoisonPill message。理想情况下，我想从命令行启动它，尽可能简单。我想也许可以再附加一个绑定到本地主机的 HTTP 服务器实例，并有一些休息方法停止，也许诊断 web 服务。可行吗？还有什么其他选择？

更新： 我根据答案添加了我可以想象的必须工作的内容，但似乎没有，至少我从未见过我希望在标准输出或日志中看到的任何消息。实际上，我已经尝试了 HttpUnbind、PoisonPill 的变体，一个一个地尝试。有眼光的人可以看看这个吗？ PS。钩子本身被成功调用，检查它。我发送给 jvm 的信号是 SIGTERM。

/* Simple reaper actor */
class Reaper(refs: ActorRef*) extends Actor {
  private val log = Logging(context.system, this)
  val watched = ArrayBuffer(refs: _*)

  refs foreach context.watch

  final def receive = {
    case Terminated(ref) =>
      watched -= ref
      log.info(s"Terminated($ref)")
      println(s"Terminated($ref)")
      if (watched.isEmpty) {
        log.info("Shutting dow the system")
        println("Shutting dow the system")
        system.shutdown()
      }
  }
}


// termination hook to gracefully shutdown the service
Runtime.getRuntime.addShutdownHook(new Thread() {
  override def run() = {
    val reaper = system.actorOf(Props(new Reaper(IO(Http), service)))
    //IO(Http) ? Http.Unbind(5.minutes)
    IO(Http) ! PoisonPill
  }
})

UPDATE2：所以，它以某种方式起作用，即 - 当 PoisonPill 被发送时，所有当前的 HTTP 连接都关闭了。但我宁愿停止接收新连接，等待 open 返回响应并关闭。

VERDICT：akka 似乎有自己的钩子，因为尽管我的钩子被执行了，但是演员被杀死并且所有连接都在没有我的动作的情况下关闭。如果有人会提供带有 JVM 关闭钩子的解决方案，那就太好了。我认为这是一个重要的问题，很遗憾它在网上没有任何好的食谱。在此期间，我将尝试使用 tcp/http 实现优雅关闭。

Answer 1

当我尝试使用 SIGTERM 和 JVM 钩子时，我需要阻止钩子线程退出，直到我的关闭序列完成，我根本不知道该怎么做（我对 akka 有点缺乏经验，所以也许我错过了一些明显的解决方案）。

我最后所做的只是在 localhost 上再附加一个 HTTP 侦听器，它具有启动关闭的方法（而且它恰好对其他任务很方便，例如获取服务器状态、触发应用程序中的事件等）。

这可能看起来像这样（我怀疑这可能包含不必要的操作，因此欢迎改进）：

在引导中：

implicit val system = ActorSystem(...)

// create and start external service actor
val service = system.actorOf(Props[MyWebServiceActor], "my-web-service")

// create internal service to manage application
val controlService = system.actorOf(Props[ControlServiceActor], "control-service")

implicit val timeout = Timeout(10.seconds)

// start a new HTTP server for external service (notifying control of HTTP listener)
IO(Http).tell(Http.Bind(service, interface = config.interface, port = config.port), controlService)

// start internal server looking at localhost
IO(Http) ? Http.Bind(controlService, interface = "127.0.0.1", port = config.controlPort)

还有控制服务本身：

class ControlServiceActor extends Actor with HttpService with ActorLogging {
  def actorRefFactory = context
  implicit val system = context.system

  /* Listener of main service */
  var listener: ActorRef = _

  def receive = {
    // this is reply from IO.Http when HTTP listener is bound
    case Http.Bound(_) =>
      listener = sender()
      context.become(mainContext)
  }

  // http api for graceful stop
  val mainContext = runRoute {
    path("stop") {
      get {
        parameter('timeout.as[Int] ? 60) { timeout =>
          complete {
            // unbind makes listener to reject new connections
            context.become(shuttingDownContext)
            log.warning(s"Stopping application within $timeout seconds...")
            context.watch(listener)
            listener ! Http.Unbind(timeout.seconds)

            "Stopping..."
          }
        }
      }
    }
  }

  // Shutdown sequence
  val shuttingDownContext = ({
    // when unbound HTTP listener not accepting connections
    case Http.Unbound =>
      log.info("Webservice unbound, waiting for active connections to complete")

    // when HTTP listener terminated after unbound it has been processed all requests
    case Terminated(ref) if ref == listener =>
      log.info("Webservice finished, exiting")
      system.shutdown()
  }: Actor.Receive) orElse runRoute(complete("Shutdown in progress"))
}

Answer 2

kill -9 将立即销毁进程。您可以使用 SIGTERM (kill -15) 在 jvm 中触发关闭挂钩。

Runtime.getRuntime.addShutdownHook(new Thread() {
  def run() = {
    //here you can send PoisonPill
  }
})