与えられた:
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