java - CompletableFuture - 并行运行多个休息调用并获得不同的结果

Question

我有一个相当普遍或独特的要求。例如，我有以下AccountDetails列表：

List<AccountDetails>

class AccountDetails {
    String bankAccountId;
    String mortgageAccountId;
    Integer noOfTrans;
    String addressLine;
    String externalLink;   
}

上述所有字段，除了bankAccountId从外部 REST 服务调用中提取。我想并行调用所有 REST 服务并更新列表中的每个对象：

因此，它如下所示：

对于每个accountDetails

• 调用抵押REST服务并更新martgageAccountId字段（REST返回MortgageInfo对象）
• 调用事务 REST 服务并更新noOfTrans字段（REST 返回Transactions对象）
• 调用地址REST服务和更新addressLine字段（REST返回Address对象）
• 调用链接 REST 服务和更新externalLink字段。（REST 返回Links对象）

我希望所有上述调用并行，并且对于AcccountDetails列表中的每个对象。如果有异常，我想优雅地处理它。请注意，上述每个 REST 服务都返回不同的自定义对象

我对如何通过CompletableFuture链接实现这一点感到困惑。不确定allOf或者thenCombine（只需要两个），或者thenCompose应该使用以及如何将所有这些放在一起。

任何例子/想法？

标签： javamultithreadingspring-bootjava-8completable-future

Answer 1

AccountDetails accountDetails = new AccountDetails();

CompletableFuture.allOf(
                        CompletableFuture.
                                supplyAsync(() -> //CALL MORTAGE INFO REST, executor).
                                thenAccept(x -> {
                                    accountDetails.setMortgageAccountId(x.getReqdField())
                                }).
                                handle(//HANDLE GRACEFULLY),
                        CompletableFuture.
                                supplyAsync(() -> //CALL SOME OTHER REST, executor).
                                thenAccept(x -> {
                                    accountDetails.setNoOfTrans(x.getReqdField())
                                }).
                                handle(//HANDLE GRACEFULLY),
                        CompletableFuture.
                                supplyAsync(() -> //CALL SOME INFO REST, executor).
                                thenAccept(x -> {
                                    accountDetails.setAddressLine(x.getReqdField())
                                }).
                                handle(//HANDLE GRACEFULLY),
                        CompletableFuture.
                                supplyAsync(() -> //CALL SOME OTHER REST, executor).
                                thenAccept(x -> {
                                    accountDetails.setExternalLink(x.getReqdField())
                                }).
                                handle(//HANDLE GRACEFULLY),
                ).join();