玩！框架：通過WS

Question

限制併發非阻塞IO調用我一直在使用Play！Framework的WS來進行網絡調用。假設我在範圍內的自定義ExecutionContext中有5個線程。如果我要阻止網絡呼叫，最多可以處理5個並行請求，因此我可以明確限制網絡呼叫的數量。

當使用WS時，情​​況並非如此。它將使網絡調用超出5個線程，因爲它不會阻塞進行WS請求的自定義池。我所觀察到的是，我可以根據需要提出儘可能多的請求，並最終壓倒OS資源。示例代碼可以在下面找到。嵌套調用總共會產生100 * 100 = 10000次調用。 我的問題是，有沒有辦法限制WS（非阻塞IO）並行發生多少個調用？我能想到的唯一方法是在請求到達服務器之前進行負載平衡。謝謝！

val cols = (1 to 100).map { col => 
    ws.url(s"http://get-resource/${col}").get().flatMap { futureColResp => 
    val outerCol = futureColResp.json 

    val rowFutures = (1 to 100).map { row => 
     ws.url(s"http://get-resource/${row}").get().map { futureRowResp => 
     val innerRow = futureRowResp.json 
     doSomething(outerCol, innerRow) 
     } 
    } 
    Future.sequence(rowFutures) 
    } 
} 
Future.sequence(cols) 

Answer 1

在遊戲中的配置，您可以設置以下設置：play.ws.ahc.maxConnectionsTotal

說明如下：https://www.playframework.com/documentation/2.5.x/ScalaWS#configuring-asynchttpclientconfig

但是，我不知道會是怎樣的行爲時，連接的最大數目爲累。

在這種情況下，更好的行爲可能是減少並行性以避免資源用盡或在可能的情況下減少對同一服務器的請求數（它們是否可以批處理？）。