Spring Webflux-抛出选中的自定义异常（而不是RuntimeException）的正确方法

Question

请问在Spring webflux中抛出选中的自定义异常的正确方法是什么？我想坚持，这是关于检查自定义异常，如MyException。java，而不是RuntimeException，它是关于抛出异常，而不是处理异常。

我尝试了以下方法：

@Controller
@SpringBootApplication
public class QuestionHowToThrowException {

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

    @PostMapping(path = "/question", consumes = MediaType.APPLICATION_JSON_VALUE, produces = MediaType.APPLICATION_JSON_VALUE)
    public Mono<ResponseEntity<QuestionResponse>> question(@RequestBody QuestionRequest questionRequest) {
        Mono<FirstStep> firstStepMono = WebClient.create().post().uri("http://firstWebService:8111/getFirstStep")
                .body(questionRequest.getThing(), String.class).retrieve().bodyToMono(FirstStep.class);
        Mono<SecondStep> secondStepMono = firstStepMono.map(oneFirstStep -> getSecondStepFromFirstStepAfterCheck(oneFirstStep));
        return secondStepMono.map(oneSecondStep -> ResponseEntity.ok(new QuestionResponse(oneSecondStep.getSecondThing())));
    }

    private SecondStep getSecondStepFromFirstStepAfterCheck(FirstStep firstStep) throws MyException {
        if (firstStep.getThingNeedsToCheckCanThrowException().equals("exception")) {
            throw new MyException("exception");
        } else {
            return new SecondStep(firstStep.getThingNeedsToCheckCanThrowException() + "good");
        }
    }

    public class QuestionRequest {
        private String thing;
        public String getThing() {
            return thing;
        }
    }

    public class QuestionResponse {
        private String response;
        public QuestionResponse(String response) {
            this.response = response;
        }
    }

    public class FirstStep {
        private String thingNeedsToCheckCanThrowException;
        public String getThingNeedsToCheckCanThrowException() {
            return thingNeedsToCheckCanThrowException;
        }
    }

    public class SecondStep {
        private String secondThing;
        public SecondStep(String secondThing) {
            this.secondThing = secondThing;
        }
        public String getSecondThing() {
            return secondThing;
        }
    }

}

这是不可能的，因为get秒dStepFromFirstStepAfterCheck方法中存在未处理的异常。

如果我抛出并传播，私有的SecondStep getSecondStepFromFirstStepAfterCheck（FirstStep FirstStep）抛出我的异常lambda调用方方法不愉快。

请问，在webflux中引发自定义异常的最干净和正确的方法是什么？

非常感谢。

Answer 1

对于我们的应用程序，我们有从RuntimeException扩展而来的自定义基异常。然后，我们有标准的异常处理，在将结果返回给最终用户之前，它会为特殊处理查找自定义异常。这允许我们使用普通抛出机制，因为我们希望抛出的所有异常都能波及调用的顶层。

对于性能问题，webflux和reactive在每次调用的基础上的性能稍低，尤其是对于不需要进行任何并行化的调用。然而，一旦加载到系统上，它的性能往往会变得更高，主要与垃圾收集有关。map和flatMap之间的差异产生的开销最好可以忽略不计。

Answer 2

通过阅读示例代码，您似乎试图在Mono上引入一些错误处理。

您可以通过扩展RuntimeException类来创建未经检查的异常。如果您想要一个强制处理的检查异常，您可以简单地扩展Exception。

public class MyException extends RuntimeException {
    public MyException(String msg) {
       super(s);
    }
}

对Reactor项目抛出异常的最干净的方法实际上就是抛出它。有一些错误处理函数允许您为某些错误情况提供不同的流。

好消息是您有几个选项可以为错误处理提供一些流控制。

Project Reactor在Mono对象上提供了其中几种方法。

在Error（）上执行，在错误继续（）上执行，在错误返回（）上执行，在ErrorS top（）上执行，在错误映射（）上执行

我不完全确定您试图用以下示例代码实现什么。

 return Mono.error(new MyException("exception"));
        } else {
 return Mono.just(new SecondStep(firstStep.getThingNeedsToCheckCanThrowException() + "good"));

但这看起来像是一个很好的例子，因为它看起来像是您试图在这里翻译一些异常

return Mono.just(new SecondStep(firstStep.getThingNeedsToCheckCanThrowException() + "good")
   .onErrorMap(e -> "translated result");