Play2使用AsyncResult（Java）调用多个Web服务

Question

我有一个Java的Play 2.1控制器，需要调用一个外部的webservice来获取一些数据。然后有了这个数据结果，我必须用n次调用调用另一个web服务，对应于第一个web service调用的n个结果。

对于性能问题，我想使用 promise 在单独的线程中进行 n 次调用。

所以我会有一个这样的循环：

List<String> firstResults = WS.url("http://...") ///...blablabla

for(String keyword : firstResults){
  Promise<ResultType> promise = play.libs.Akka.future(
    new Callable<ResultType>() {
      public Integer call() {
        return //...
      }
    }
  );}

如何使用异步API同步n个promise，然后在一个响应（所有结果的列表）中减少结果，然后仅在所有调用完成时返回http响应？

由于无法知道通话次数，问题变得更加困难……（我无法将promise声明为promise人1、promise人2等）

Answer 1

Promise.waitAll是你想要的：

List<String> firstResults = WS.url("http://...") ///...blablabla

List<Promise<? extends ResultType>> webServiceCalls = new ArrayList<>;
for(String keyword : firstResults){
  Promise<ResultType> promise = WS.url("http://...?keyboard=" + keyword).get().map(
    // function of Response to ResultType
  );
  webServiceCalls.add(promise);
}

// Don't be confused by the name here, it's not actually waiting
Promise<List<ResultType>> results = Promise.waitAll(webServiceCalls);

return async(results.map(new Function<List<ResultType, Result>>() {
  public Result apply(List<ResultType> results) {
    // Convert results to ResultType
  }
});