从 completablefuture 抛出实际异常

Question

我正在使用 completablefuture 进行并行调用，如下所示，

public Response getResponse() {
    Response resultClass = new Response();
   try {
    CompletableFuture<Optional<ClassA>> classAFuture
        = CompletableFuture.supplyAsync(() -> service.getClassA() );
    CompletableFuture<ClassB> classBFuture
        = CompletableFuture.supplyAsync(() -> {
             try {
                   return service.getClassB(); 
              }
              catch (Exception e) {
                   throw new CompletionException(e);
              }
     });

   CompletableFuture<Response> responseFuture =
    CompletableFuture.allOf(classAFuture, classBFuture)
         .thenApplyAsync(dummy -> {
            if (classAFuture.join().isPresent() {
               ClassA classA = classAFuture.join();
               classA.setClassB(classBFuture.join());
               response.setClassA(classA)
             }
            return response;
         });
   responseFuture.join();
  } catch (CompletionExecution e) {
    throw e;
  }
  return response;
}

我需要为return service.getClassB() 添加try catch，因为它会在getClassB 方法中引发异常。

现在我面临的问题是如果service.getClassB() 抛出错误，它总是包裹在java.util.concurrent.ExecutionException 中。在这种情况下，此方法会抛出 UserNameNotFoundException ，但它被包裹在 ExecutionException 中，并且它没有被捕获在正确的位置 @ControllerAdvice 异常处理程序类中。我尝试了使用 throwable 的不同选项，但没有帮助。

有没有很好的方法来处理异常并解包并将其发送到@ControllerAdvice 类？

Answer 1

您的代码有几个错误，例如引用了未在此代码中声明的变量response，并且很可能应该是开头声明的resultClass。这行
ClassA classA = classAFuture.join(); 突然忽略了这个未来封装了一个Optional，并且缺少) 和; 分隔符。

此外，当有干净的替代方案时，您应该避免从周围的代码中访问变量。此外，使用allOf 组合两个期货是不必要的复杂化。

如果我正确理解你的意图，你想做类似的事情

public Response getResponse() {
    return CompletableFuture.supplyAsync(() -> service.getClassA())
        .thenCombine(CompletableFuture.supplyAsync(() -> {
            try {
                return service.getClassB();
            }
            catch(ExecutionException e) {
                throw new CompletionException(e.getCause());
            }
        }), (optA, b) -> {
            Response response = new Response();
            optA.ifPresent(a -> {
                a.setClassB(b);
                response.setClassA(a);
            });
            return response;
        })
        .join();
}

解决您描述的问题的关键是捕获最具体的异常类型。当你捕捉到ExecutionException 时，你就知道它会包装实际的异常并且可以无条件地提取它。当getClassB() 声明您必须捕获的其他检查异常时，添加另一个catch 子句，但要具体而不是捕获Exception，例如

try {
    return service.getClassB();
}
catch(ExecutionException e) {
    throw new CompletionException(e.getCause());
}
catch(IOException | SQLException e) { // all of getClassB()’s declared exceptions
    throw new CompletionException(e); //     except ExecutionException, of course
}