模仿IntegrationTests的CompletableFuture.join()

Question

我正在编写集成测试用例，我被困在无法模拟CompletableFuture.join（）的地方

首先，我将进行异步调用并将所有响应添加到列表中

@Async("AsyncTaskExecutor")
    public <T> CompletableFuture<ResponseEntity<T>> callCarrierPost(
            ServiceConfig serviceConfig, Class<T> responseType, ExecutionContext executionContext,
            AdapterContext adapterContext) {
        ResponseEntity<T> responseEntity = carrierInvoker.postForObject(
                serviceConfig, responseType, executionContext, adapterContext);
        return CompletableFuture.completedFuture(responseEntity);
    }

一旦进行了异步调用，我将如下处理异步调用的响应，

private <T> List<ResponseEntity<T>> processResponseFutureList(List<CompletableFuture<ResponseEntity<T>>> responseEntityFutureList) {
        List<ResponseEntity<T>> responseEntityList = new ArrayList<>();
        responseEntityFutureList.forEach(responseEntityFuture -> {
            try {
                responseEntityList.add(responseEntityFuture.join());
            } catch (CompletionException ex) {
                if (ex.getCause() instanceof HttpStatusCodeException) {
                    HttpStatusCodeException httpStatusCodeException = ((HttpStatusCodeException) ex.getCause());
                    ResponseEntity<T> response = new ResponseEntity<>((T) httpStatusCodeException.getResponseBodyAsString(),
                            httpStatusCodeException.getResponseHeaders(),
                            httpStatusCodeException.getStatusCode());
                    responseEntityList.add(response);
                } else if (ex.getCause() instanceof ResourceAccessException &&
                        ex.getCause().getCause() instanceof SocketTimeoutException) {
                    responseEntityList.add(getErrorResponseEntity(HttpStatus.SERVICE_UNAVAILABLE,
                            TimeOutException.Code.PROVIDER_TIME_OUT.getVal(), ex.getMessage()));
                } else {
                    responseEntityList.add(getErrorResponseEntity(HttpStatus.INTERNAL_SERVER_ERROR,
                            InternalServerException.Code.INTERNAL_M2_BROKER_ERROR.getVal(), ex.getMessage()));
                }
            }
        });
        return responseEntityList;
    }

在Process ResepseFutureList方法中，我试图模拟completableFuture.join（）的响应以涵盖所有异常情况

所以我试着模仿completableFuture，但是运气不好，它没有抛出异常，而是给出了最初的响应。

@MockBean
    private CompletableFuture completableFuture;

Mockito.when(completableFuture.join())
                .thenReturn(new ResourceAccessException("I/O error on /uri", new SocketTimeoutException("Read Timeout")));

我实际上是测试新手，也从未有机会与“可完成的未来”合作。

有人可以帮助模拟可完成未来.join（）抛出一个异常吗？

Answer 1

一般来说，不要模仿你不拥有的类型。特别是，CompletableFuture是一个巨大的应用编程接口，语义学非常复杂，我不建议嘲笑它。（你的团队可能会有不同的意见，但是CompletableFuture的大型和非封装的应用编程接口被认为是一个设计问题，尤其是在如何从外部控制CompletableFuture方面。）

此外，加入永远不会返回资源访问异常，也不会直接抛出一个。期货代表其他一些异步进程的结果，可能在另一个线程上;如果该进程引发资源访问异常，则与您发布的代码一样，联接将引发一个具有 getCause（） 值的完成异常，该值是基础资源访问例外。

在Java9或更好的版本中，您可以使用ailedFuture作为静态工厂，传入原始ResourceAccessException，因为真正的CompletableFuture实现将为您包装它：

// You'll probably need to specify your generics here, but I can't see
// enough of your test to fill them in realistically.
CompletableFuture</* ... */> completableFuture
    = CompletableFuture.failedFuture(new ResourceAccessException(
        "I/O error on /uri",
        new SocketTimeoutException("Read Timeout")));

在Java8中，在没有静态工厂的情况下，如SO问题“CompletableFuture已经异常完成”，只需创建一个真正的CompletableFuture并异常完成它（利用上述外部控制设计问题）：

CompletableFuture</* ... */> completableFuture
    = new CompletableFuture</* ... */>();
completableFuture.completeExceptionally(
    new ResourceAccessException(/*...*/));