我可以使用播放框架与akka http(不是播放中的那个)并禁用netty服务器吗？

Question

我并不是说播放禁用PlayNettyServer并启用AkkaHttpServer的方式,使用以下文档中描述的AkkaHttpServer:

lazy val root = (project in file("."))
  .enablePlugins(PlayScala, PlayAkkaHttpServer)
  .disablePlugins(PlayNettyServer)

我的意思是利用play框架的依赖注入和play-slick等其他工具,并直接在代码中使用akka-http:

class AppInitiation @Inject()(implicit val system: ActorSystem, configuration: Configuration) {

  implicit val materializer = ActorMaterializer()

  implicit val timeout: Timeout = 5 seconds

  val logger = Logger("Server")

  val milkywayPath = path(Segment ~ RestPath)
  val methods = get | put | post | delete
  val gatewayExceptionHandler = ExceptionHandler {
    case e: AskTimeoutException =>
      complete(HttpResponse(InternalServerError, Nil, "Ask timeout!"))
    case e: Exception =>
      logger.error("unknown error", e)
      complete(HttpResponse(InternalServerError, Nil, "Unknown error! Please contact administratro!"))
  }

  implicit def rejectionHandler = RejectionHandler.newBuilder()
    .handle { case MissingHeaderRejection("X-Caller-Service") =>
      complete(HttpResponse(BadRequest, Nil, "Missing required header X-Caller-Service!"))
    }
    .handle { case MissingQueryParamRejection("v") =>
      complete(HttpResponse(BadRequest, Nil, "Missing required parameter v!"))
    }
    .result()

  val requestHandler = system.actorOf(Props(new RequestHandler))

  val routes = handleExceptions(gatewayExceptionHandler) {
    (milkywayPath & methods & parameter('v.as[String]) & headerValueByName("X-Caller-Service") & extractRequest) {
      (contextPath: String, resource: Path, v, caller, request) =>
        complete {
          val startTime = System.currentTimeMillis()
          val callerInfo = CallerInfo(caller, contextPath, v, resource.toString())
          val f = (requestHandler ? RequestHandlerMsg(callerInfo, request)).mapTo[HttpResponse]
          f onComplete {
            case r => accessLogger.info(s"method=${request.method.name} " +
              s"uri=${request.uri} " +
              s"caller=$caller " +
              s"totalTime=${System.currentTimeMillis() - startTime}ms " +
              s"resultStatus=${r.map(_.status.intValue).getOrElse(500)}")
          }
          f
        }
    }
  }

  val host = configuration.getString("gateway.host").getOrElse("localhost")
  val port = configuration.getInt("gateway.port").getOrElse(9001)

  Http().bindAndHandle(routes, host, port).onComplete(_ => logger.info(s"Server started listening request on port $port"))
} 

在模块中我可以将其设置为:

override def configure(): Unit = {
  bind(classOf[AppInitiation]).asEagerSingleton()
}

这有效.但我仍然想知道如何在没有运行PlayNettyServer的情况下启动它.我试过了:

lazy val `root` = (project in file("."))
  .enablePlugins(PlayScala)
  .disablePlugins(PlayNettyServer)

但是出现了例外情况:

[info] p.a.l.c.ActorSystemProvider - Starting application default Akka system: application
play.core.server.ServerStartException: No ServerProvider configured with key 'play.server.provider'
    at play.core.server.ServerProvider$$anonfun$1.apply(ServerProvider.scala:54)
    at play.core.server.ServerProvider$$anonfun$1.apply(ServerProvider.scala:54)

我想知道是否有办法充分利用Play框架及其所有功能,并使用akka http构建更高性能的服务器.