为列表中的每个URL发送WS-request，并将响应映射到新列表

Question

我正在Play with Scala中开发一个REST服务器，在某些时候需要请求一个或多个其他Web服务的数据。根据这些服务的响应，服务器必须编写一个统一的结果供以后使用。

例子：

需要执行 www.someplace.com 上的事件 C。为了执行事件 C，还必须执行 www.anotherplace.com 上的事件 A 和 www.athirdplace.com 上的事件 B。

事件C有一个< code>Seq(www.anotherplace.com，www.athirdplace.com)，我想从这个Seq开始迭代并向每个URL分别发送一个WS请求，以检查B和C是否被执行。

假设对这些 URL 的 GET 返回 true 或 false

我如何从每个请求中收集响应(最好组合成一个列表)并断言每个响应都等于< code>true？

编辑：事件可能包含任意数量的URL。因此，我无法事先知道需要发送多少WS请求。

Answer 1

看看文档，看看你是否能让他们的例子工作。试着这样做:

val futureResponse: Future[WSResponse] = for {
  responseOne <- WS.url(urlOne).get()
  responseTwo <- WS.url(responseOne.body).get()
  responseThree <- WS.url(responseTwo.body).get()
} yield responseOne && responseTwo && responseThree

您可能需要解析web服务的响应，因为它们(可能)不会返回布尔值，但您会明白这一点。

Answer 2

您可以使用未来对象上可用的序列方法。

例如：

import scala.concurrent.Future

val urls = Seq("www.anotherplace.com", "www.athirdplace.com")
val requests = urls.map(WS.url)
val futureResponses = Future.sequence(requests.map(_.get()))

请注意，< code>futureResponses的类型将是< code > Future[Seq[ws response]]。现在您可以处理结果:

futureResponses.map { responses =>
  responses.map { response =>
    val body = response.body
    // do something with response body
  }
}

来自序列方法的ScalaDocs：

将可遍历的Once[Future[A]]转换为一个Future[TraversableOnce[A]]。有助于将许多期货减少到一个单一的未来。

请注意，如果传递给序列的任何未来失败，则生成的将来也将失败。只有成功完成所有未来后，结果才会成功完成。这对于某些目的很好，尤其是如果您希望同时发送请求，而不是一个接一个地发送请求。