CompletableFuture 循环中：如何收集所有响应并处理错误

我正在尝试调用rest apiPUT循环请求。每个调用都是一个CompletableFuture。每个 api 调用都会返回一个类型的对象RoomTypes.RoomType

• 我想收集响应（成功和错误 响应）在不同的列表中。我该如何实现这一目标？我确信我 不能用allOf因为它不会得到所有结果（如果有的话） 一次调用无法更新。

• 如何记录每次调用的错误/异常？

public void sendRequestsAsync(Map<Integer, List> map1) {
    List<CompletableFuture<Void>> completableFutures = new ArrayList<>(); //List to hold all the completable futures
    List<RoomTypes.RoomType> responses = new ArrayList<>(); //List for responses
    ExecutorService yourOwnExecutor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());

    for (Map.Entry<Integer, List> entry :map1.entrySet()) { 
        CompletableFuture requestCompletableFuture = CompletableFuture
                .supplyAsync(
                        () -> 
            //API call which returns object of type RoomTypes.RoomType
            updateService.updateRoom(51,33,759,entry.getKey(),
                           new RoomTypes.RoomType(entry.getKey(),map2.get(entry.getKey()),
                                    entry.getValue())),
                    yourOwnExecutor
            )//Supply the task you wanna run, in your case http request
            .thenApply(responses::add);

    completableFutures.add(requestCompletableFuture);
}

你可以简单地使用allOf()当所有初始 future 都完成（无论是否例外）时，获得一个已完成的 future，然后使用Collectors.partitioningBy() https://docs.oracle.com/javase/8/docs/api/java/util/stream/Collectors.html#partitioningBy-java.util.function.Predicate-:

List<CompletableFuture<RoomTypes.RoomType>> completableFutures = new ArrayList<>(); //List to hold all the completable futures
ExecutorService yourOwnExecutor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());

for (Map.Entry<Integer, List> entry : map1.entrySet()) {
    CompletableFuture<RoomTypes.RoomType> requestCompletableFuture = CompletableFuture
            .supplyAsync(
                    () ->
                //API call which returns object of type RoomTypes.RoomType
                updateService.updateRoom(51, 33, 759, entry.getKey(),
                        new RoomTypes.RoomType(entry.getKey(), map2.get(entry.getKey()),
                                entry.getValue())),
                    yourOwnExecutor
            );

    completableFutures.add(requestCompletableFuture);
}

CompletableFuture.allOf(completableFutures.toArray(new CompletableFuture[0]))
        // avoid throwing an exception in the join() call
        .exceptionally(ex -> null)
        .join();
Map<Boolean, List<CompletableFuture<RoomTypes.RoomType>>> result =
        completableFutures.stream()
                .collect(Collectors.partitioningBy(CompletableFuture::isCompletedExceptionally)));

生成的地图将包含一个条目true对于失败的期货，以及另一个条目false成功者的关键。然后您可以检查这 2 个条目以采取相应的操作。

请注意，与原始代码相比，有 2 个细微的变化：

• requestCompletableFuture现在是一个CompletableFuture<RoomTypes.RoomType>
• thenApply(responses::add)和responses列表已被删除

关于日志记录/异常处理，只需添加相关的requestCompletableFuture.handle()单独记录它们，但保留requestCompletableFuture而不是由此产生的handle().