负载平衡akka-http

Question

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"

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

此问题的答案演示了如何从路由内进行执行元调用。

如果您将这种技术与Akka中的集群功能结合起来，您应该能够完成这项工作。

让您的路由向路由器发送消息，该路由器将把消息分派给N个远程部署的参与者中的1个（从您的问题来看，这听起来像是您想要的是循环路由器）。

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]))

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}"))
      }
    }
  }