ScalaWS (Play!)와 동시에 http-URL 목록을 확인하는 방법은 무엇입니까?

Question

def resolve(url: String): Future[WSResponse] = ws.url(url).withFollowRedirects(true).get() 

def validateAllLinks(links: List[String]) = ??? 

어떻게 두 번째 기능을 해결 하시겠습니까?

def validateAllLinks(links: List[String]) = links.map(link => 
    Await.result(resolve(link), Duration.create(3, TimeUnit.SECONDS)) 
) 

이 접근 방식의 문제점 : 내가 얻을

1. 내가 트래버스, Future.sequence, 기다리고 있습니다을 시도

   ...

   이 나의 가장 최근의 시도였다 TimeoutExceptions 및 MaxRedirectException 시도/catch 싶지 않아

2. 솔루션이 작동한다고해도 솔루션이 동시라고 생각하지 않습니다.

미리 감사드립니다. 당신이 Future.sequence 후 Await.result를 호출하는 경우가 완료 병렬 작업을 기다리는,

def validateAllLinks(links: List[String]): Future[List[WSResponse]] = 
    Future.sequence(links.map(resolve)) 

:

Answer 1

그들은 병렬로 실행됩니다 Future.sequence을 자유롭게 사용

import scala.concurrent.duration._ 
def validateAllLinks(links: List[String]): List[WSResponse] = 
    Await.result(Future.sequence(links.map(resolve)), 10 seconds) 

그러나 Await.result은 나쁜 습관으로 간주되므로 Future을 반환해야하며 clien 그것을 다루는 방법을 결정하지 마라.

는 나쁜 관행 이유에 대해 좀 더 자세히 :

1. https://monix.io/docs/2x/best-practices/blocking.html

2. https://github.com/alexandru/scala-best-practices/blob/master/sections/4-concurrency-parallelism.md#45-should-not-block