2014-11-05 37 views
0

鑑於:如何獲取高出境併發與阿卡IO(HTTP)

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個。

我試着用噴霧的配置創建一個自定義調度調整,但這並沒有影響......

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個請求?

使用:阿卡2.2.3,噴霧1.2.0

回答

2

正在運行到最大連接配置設置在噴霧主機連接器(它是通過4默認值)。

這就是你如何改變它: spray.can.host-connector.max-connections=25