0

鉴于：

val system = ActorSystem("test")
val http = IO(Http)(system)
def fetch = http ! HttpRequest(GET, "http://0.0.0.0:8080/loadtest")

如果我这样做：

(0 to 25).foreach(_ => fetch)

我希望代码会触发 25 个异步请求。相反，会发生四个请求。他们等待回应。当对所有 4 个的响应都返回时，再发送 4 个，直到所有 25 个都被处理。

我尝试使用 Spray 的配置进行调整以创建自定义调度程序，但这没有效果......

outbound-http-dispatcher {
  type = Dispatcher
  executor = "thread-pool-executor"
  throughput = 250
}

spray.can {
  host-connector-dispatcher = outbound-http-dispatcher
  manager-dispatcher = outbound-http-dispatcher
}

如何配置 Akka/Spray 以异步发送所有 25 个请求？

使用：Akka 2.2.3、Spray 1.2.0

4

1 回答 1

2

您正在运行喷雾中主机连接器的最大连接配置设置（默认情况下为 4）。

这是你改变它的方式： spray.can.host-connector.max-connections=25

于 2014-11-05T09:31:31.187 回答