6

我正在使用 http4s BlazeServer 0.21，如何优雅关机？我想在硬关机时间内拒绝所有即将到来的请求，并保持处理未完成的请求和响应。

我尝试使用启动服务器serveWhile并设置一个 shutdownHook SignallingRef。服务器流和中间件按预期延迟（因此我们的指标和日志中间件仍然记录此响应）

//serverStream
for {
  signal   <- fs2.Stream.eval(SignallingRef[F, Boolean](false))
  exitCode <- fs2.Stream.eval(Ref[F].of(ExitCode.Success))
  _        <- fs2.Stream.eval(shutdown(signal))
  server <- BlazeServerBuilder[F]
    .bindHttp(8080, "0.0.0.0")
    .withHttpApp(httpApp)
    .serveWhile(signal, exitCode)
} yield server

def shutdown[F[_]: Effect](interrupter: SignallingRef[F, Boolean]): F[Unit] = {
  LiftIO[F].liftIO(IO {
    sys.addShutdownHook {
      ...
      interrupter.set(true)
    }
  })
}

object Server extends IOApp {
  def run(args: List[String]): IO[ExitCode] =
    serverStream[IO].compile.drain.as(ExitCode.Success)
}

但是http服务器没有像我预期的那样工作，好像http4s的内部ServerChannel有它自己的shutdownHook并且已经取消了所有的响应。

任何建议/解决方法？或者也许只是一种保持和不杀死请求x几秒钟的方法，也值得赞赏。

4

1 回答 1

3

为方便起见，服务器连接了 SIGTERM。

为方便起见，cats-effect 提供了一个 cats.effect.IOApp trait 和一个返回 IO[ExitCode] 的抽象运行方法。IOApp 运行该进程并添加一个 JVM 关闭挂钩以中断无限进程并在收到 SIGTERM 时优雅地关闭您的服务器。

如果您想使用 URL 关闭，例如http://localhost:8080/ops/shutdown/true，它也可以。

代码很简单，

class SysOpsEndpoints[F[_]: Sync](signal: SignallingRef[F, Boolean]) extends Http4sDsl[F] {
  private def shutdown: HttpRoutes[F] =
    HttpRoutes.of[F] {
      case GET -> Root / "shutdown" / shutdown =>
        for {
          _ <- signal.set(Try(shutdown.toBoolean).getOrElse(false))
          result <- Ok(s"Shutdown: $shutdown")
        } yield result
    }
}

object SysOpsEndpoints {
  def endpoints[F[_]: Sync](signal: SignallingRef[F, Boolean]): HttpRoutes[F] =
    new SysOpsEndpoints(signal).shutdown
}

理解服务器的设置和你的类似，

for {
  signal   <- fs2.Stream.eval(SignallingRef[F, Boolean](false))
  exitCode <- fs2.Stream.eval(Ref[F].of(ExitCode.Success))
  httpApp = Router(
        "/ops" -> SysOpsEndpoints.endpoints(signal)
      ).orNotFound
  server <- BlazeServerBuilder[F](serverEc)
    .bindHttp(8080, "0.0.0.0")
    .withHttpApp(httpApp)
    .serveWhile(signal, exitCode)
} yield server
于 2020-05-25T15:14:28.903 回答