Java中的异步rest调用是非顺序的

Question

我在一次调用中有多个对第三方应用程序的同步调用。我正在使用Spring RestTemplate调用第三方应用程序，如下所示，

Class B {
   public void makeRestCall(String url){
      Collection response = restTemplate.getForObject(url, Collection.class, params);
      return response;
   }
}

我的控制员给我打了个电话

Class A {

    public List<Data> getAllData(){
         // Some Business Logic
         String url1 = "htpp://anyurl1";
         // Some Processing based on Logic
         String url2 = "htpp://anyurl2";
         B b = new B()
         b.makeRestCall(url1);
         b.makeRestCall(url2);

        // Club together data from both calls

        // Again some rest calls based on business logic
        }
    }

现在，当我进行rest调用时，我的rest代码被阻止，直到我从请求的URL获得响应为止。我曾尝试使用AsyncRestTemplate和SimpleReact API，但我面临以下问题。我有一系列的rest调用，我不能在下面的代码中直接提供URL列表，因为我不想将rest调用代码与实际的应用程序流混为一谈。

new SimpleReact()
.fromStream(urls.stream()
        .map(it ->  
            toCompletableFuture(template
                        .getForEntity(it,String.class))))
.then(it -> it.getBody())
.then(it -> extractTitle(it))

如果有人能帮助我如何在我的情况下进行异步Rest呼叫。

Answer 1

我不确定我是否完全理解这个问题，但我想可能是如何在一些简单的react示例代码和op自己的代码之间架起一座桥梁？

如果有帮助的话，您不必使用URL作为SimpleReact的输入，例如，您可以使用任何Java8供应商。只需使用标准的SpringRESTTemplate（即非NIO同步Rest调用），您就可以在简单的react中使用类似的方式使代码异步-

例如。

 List<Results> results = new SimpleReact().react( () -> makeRestCall(url1),
                                                  () -> makeRestCall(url2), 
                                                  ..etc..)
                                          .block();

甚至进一步抽象

   List<Results> results = new SimpleReact().react( supplier1,supplier2, ..etc..)
                  .block();

如果您想插入NIO AsyncRestTemplate（实际上是在进行大量异步调用并且需要避免使用每个请求的线程的情况下），您可以修改makeRestCall以使用AsyncRestTemplate并返回一个完整的未来。您可以将这些可完成的未来推到简单的react中，如下所示

 List<Results> results = new SimpleReact().fromStream(Stream.of(
                                                      makeRestCall(url1),
                                                      makeRestCall(url2))
                                          .block();

在我们的另一个开源项目Microserver中，有一个使用异步NIO Rest客户端和simple react的例子。e、 g(https://github.com/aol/micro-server/blob/master/micro-core/src/test/java/app/async/com/aol/micro/server/AsyncResource.java )