以功能方式使用 Rest Service

Question

所以我很好奇如何使用 java8 流 API 更有效地重写以下代码。

public static List<FlightInfo> getResults(String origin,List<String> destinations)  {

    final String uri = "https://api.searchflight.com/;
    List<FlightInfo> results = new LinkedList<FlightInfo>();

    for(String destination:destinations) {


            RestTemplate restTemplate = new RestTemplate();

            String params = getParams(origin,destination);
            FlightInfo result = restTemplate.postForObject(uri+params,FlightInfo.class);

            results.add(result);
    }

    return results;

}

此方法完成其正在执行的操作后，我收到 FLightInfo 对象列表，我将其转换为流并将对其进行各种转换（分组依据等）。现在很明显这是一个很长的运行操作。此外，它实际上结合了对 web 服务的多个 rest 调用，所以我在最后一次调用时已经拥有了大部分数据，但我不会在整个方法 returns 之前开始处理它。

有没有一种方法可以更加被动地完成所有这些工作？我可以立即 return 一个流，并在数据从管道下来时对该流进行操作，或者这个要求有点过分？ Java 8. 那

是怎么做到的

Answer 1

好吧，这完全取决于您何时需要结果。如果你希望它是顺序的，下面这个仍然是一个不错的方式，因为它很懒。但它会在终端操作时沸腾（比如在 collect 期间）。

public static Stream<FlightInfo> getResults(String origin,List<String> destinations)  {
    final String uri = "https://api.searchflight.com/";
    return destinations.stream().map(destination -> {
        RestTemplate restTemplate = new RestTemplate();
        String params = getParams(origin,destination);
        FlightInfo result = restTemplate.postForObject(uri+params,FlightInfo.class);
        return result;
    })    
}

或者如果可以的话，我会用 destinations.stream().parallel() 来完成。在大多数情况下，这是一个合理的结果。但是在您为其调用终端操作之前，它仍然不会开始并行处理它。这绝对有道理。

但在我看来，您希望生产者-消费者类型的东西。其中：

public static CompletableFuture<List<FlightInfo>> getResults(String origin,List<String> destinations)  {
    final String uri = "https://api.searchflight.com/";
    List<CompletableFuture<FlightInfo>> collect = destinations
           .stream()
           .map(destination -> CompletableFuture.supplyAsync(() -> {
                 RestTemplate restTemplate = new RestTemplate();
                 String params = getParams(origin,destination);
                 FlightInfo result = restTemplate.postForObject(uri+params,FlightInfo.class);
                 return result;            
           })).collect(Collectors.toList());
    return sequence(collect);       //line-1 
}

public static <T> CompletableFuture<List<T>> sequence(List<CompletableFuture<T>> com) {
    return CompletableFuture.allOf(com.toArray(new CompletableFuture[com.size()]))
            .thenApply(v -> com.stream()
                            .map(CompletableFuture::join)
                            .collect(Collectors.toList())
            );
}

为了 简单性 ，在 line-1 你可以简单地 return collect 而不是 sequence(collect)。然后您可以遍历列表以获取每个值。

但是对于 sequence，您只需担心一个 CompletableFuture 对象，如果完成，您可以立即检查其值。

以功能方式使用 Rest Service

Consuming Rest Service the functional way

java

rest

lazy-evaluation

java-8

java-stream