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 個すべてが処理されるまでさらに 4 つが送信されます。

カスタムディスパッチャーを作成するために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
}

25 個のリクエストすべてを非同期で送信するように Akka/Spray を構成するにはどうすればよいですか?

使用: Akka 2.2.3、Spray 1.2.0

4

1 に答える 1