scala - Finagle が作成する接続数を制限するには?

Question

Finalge を使用して、次https://twitter.github.io/finagle/のようにタイムアウトのケースをテストします。

1. サーバー側: RPC 定義では、10 秒間スリープしてから戻ります。
2. withinクライアント側: likeを使用して RPC 関数を呼び出すwithin(50.milliseconds) onSuccess { ... } onFailure { ... }
3. 多くのクライアント: 約 100 のクライアントを使用して RPC 関数を同時に呼び出します。

その結果、もちろんすべての RPC がタイムアウトになります。しかし、netstat接続を確認するために使用すると、100のESTABLISHED接続があることがわかります。問題は、Finagle が作成する接続数を制限できますか?

Answer 1

はい、使用できます

hostConnectionLimit(10)

ClientBuilder で、各ホストへの接続を制限します。ここでの「ホスト」は、サーバー側のボックスを指します。

ソースコードはこちら。