Как передать проверенное исключение из CompletableFuture в ControllerAdvice - PullRequest
Новая
       53

Как передать проверенное исключение из CompletableFuture в ControllerAdvice

3 голосов
/ 24 января 2020

Как сделать так, чтобы класс controllerAdvice перехватывал исключение, которое выбрасывалось из completetablefutrue. В приведенном ниже коде у меня есть метод checkId, который выдает проверенное исключение. Я вызываю этот метод с использованием completetablefuture и заключаю проверенное исключение в CompletionException Хотя у меня есть метод обработчика в классе совета контроллера, но он не обработал ошибку. 

package com.example.demo.controller;
@RestController
public class HomeController {

    @GetMapping(path = "/check")
    public CompletableFuture<String> check(@RequestParam("id") int id) {
        return CompletableFuture.supplyAsync(() -> {
            try {
                return checkId(id);
            }
            catch (Exception e) {
                throw new CompletionException(e);
            }
        });
    }

    public String checkId(int id) throws Exception  {
        if (id < 0) {
            throw new MyException("Id must be greater than 0");
        }
        return "id is good";
    }

}

- 

package com.example.demo;
public class MyException extends Exception {

    public MyException(String message) {
        super(message);
    }

}

- 

package com.example.demo;
@ControllerAdvice
public class ExceptionResolver {

    @ExceptionHandler(value = CompletionException.class)
    public String handleCompletionException(CompletionException ex) {
        return ex.getMessage();
    }

}

- - 

package com.example.demo;
@SpringBootApplication
public class DemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }

}

Трассировка стека: 

com.example.demo.MyException: Id must be greater than 0
    at com.example.demo.controller.HomeController.checkId(HomeController.java:30) ~[classes/:na]
    at com.example.demo.controller.HomeController.lambda$0(HomeController.java:19) ~[classes/:na]
    at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) ~[na:na]
    at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.exec(CompletableFuture.java:1692) ~[na:na]
    at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) ~[na:na]
    at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) ~[na:na]
    at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) ~[na:na]
    at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) ~[na:na]
    at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:177) ~[na:na]

2020-01-24 14:38:30.489 ERROR 938 --- [nio-8080-exec-1] o.a.c.c.C.[.[.[/].[dispatcherServlet]    : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is com.example.demo.MyException: Id must be greater than 0] with root cause

com.example.demo.MyException: Id must be greater than 0
    at com.example.demo.controller.HomeController.checkId(HomeController.java:30) ~[classes/:na]
    at com.example.demo.controller.HomeController.lambda$0(HomeController.java:19) ~[classes/:na]
    at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) ~[na:na]
    at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.exec(CompletableFuture.java:1692) ~[na:na]
    at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) ~[na:na]
    at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) ~[na:na]
    at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) ~[na:na]
    at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) ~[na:na]
    at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:177) ~[na:na]

1 Ответ

2 голосов
/ 25 января 2020

@ Дэдпул и я смогли выявить проблему.

Внутри блока catch в коде completetableFuture исключение заключено в исключение CompletionException, которое является исключением во время выполнения. Когда конечная точка получает удар, в какой-то момент исключение CompletionException разворачивается в исходное исключение типа MyException (проверенное исключение). Это означает, что метод-обработчик должен обрабатывать исключение типа MyException вместо CompletionException. 

@ExceptionHandler(value = MyException.class)
@ResponseBody 
public String handleCompletionException(MyException ex) { 
     return ex.getMessage(); 
}
...