负载均衡 akka-http

Question

我正在使用 akka-http，我的 build.sbt 配置是：

scalaVersion := "2.11.7"
libraryDependencies += "com.typesafe.akka" % "akka-actor_2.11" % "2.4.2"
libraryDependencies += "com.typesafe.akka" % "akka-http-experimental_2.11" % "2.4.2"
libraryDependencies += "com.typesafe.akka" % "akka-http-spray-json-experimental_2.11" % "2.4.2"
libraryDependencies += "com.typesafe.akka" % "akka-slf4j_2.11" % "2.4.2"

我正在公开一个只有一个 GET url 的简单 REST api
foo 是一个返回 Future 的函数

implicit val actorSystem = ActorSystem("system", config)
implicit val actorMaterializer = ActorMaterializer()

val route: Route = {
  get {
    path("foo") {
      complete { foo }
    }
  }
}

web-service 预计会有很多调用，我想让服务在失败的情况下冗余，所以我想让两个实例同时运行来处理所有请求.

1) 让两个 web 服务实例同时处理请求的最佳方式是什么？使用外部负载均衡器或在 akka/akka- 中使用一些魔法（我不知道） http ?

2) 为了提高性能，我必须调整哪些主要参数？

Answer 1

this question 的答案演示了如何从 Route 中进行 Actor 调用。

如果您将该技术与 Akka 中的 clustering 功能相结合，您应该能够完成工作。

让您的 Route 向 Router 发送消息，该消息会将消息发送到 N 个 remotely deployed Actors 中的 1 个（从您的问题看来，round robin 路由器就是您想要的）。

class HttpResponseActor extends Actor {

  def foo : HttpResponse = ??? // Not specified in question

  override def receive = {
    case _ : HttpRequest => foo 
  }
}

import akka.actor.{ Address, AddressFromURIString }
import akka.remote.routing.RemoteRouterConfig

val addresses = Seq(Address("akka.tcp", "remotesys", "otherhost", 1234),
                    AddressFromURIString("akka.tcp://othersys@anotherhost:1234"))

val routerRemote = 
  system.actorOf(RemoteRouterConfig(RoundRobinPool(5), addresses).props(Props[HttpResponseActor]))

远程 Actor 使用 HttpResponse 进行响应。这个回复可以go through the Router or directly back to the Route。

Route 将答案粘贴在 complete 指令中以返回给客户端。

val route = 
  get {
    path("foo") {
      onComplete((routerRemote ? request).mapTo[HttpResponse]) {
        case Success(response) => complete(response)
        case Failure(ex) => complete((InternalServerError, s"Actor not playing nice: ${ex.getMessage}"))
      }
    }
  }