Spring Webflux-引发检查的自定义异常不是RuntimeException的正确方法

如何解决Spring Webflux-引发检查的自定义异常不是RuntimeException的正确方法

请问在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;
        }
    }

}

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

如果我抛出并传播，则私有SecondStep getSecondStepFromFirstStepAfterCheck（FirstStep firstStep）抛出MyException，导致lambda调用者方法不满意。

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

谢谢

解决方法

对于我们的应用程序，我们从RuntimeException扩展了自定义基本异常。然后，我们有了标准的异常处理程序，该程序会在将结果返回给最终用户之前寻找特殊处理的自定义异常。这使我们能够使用普通的抛出机制，因为我们希望抛出的所有异常都使调用的最高级泛滥。

出于性能方面的考虑，webflux和active在每次调用的基础上的性能略低，尤其是对于不需要进行任何并行化的调用。但是，一旦负载加到系统上，它往往会变得更高效，这主要与垃圾回收有关。 map和flatMap之间的差异所产生的开销最多应该可以忽略不计。

,

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

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

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

在Reactor项目中抛出异常的最干净方法实际上就是抛出它。错误处理功能使您可以为某些错误情况提供不同的流程。

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

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

doOnError()，onErrorContinue()，onErrorReturn()，onErrorStop()，onErrorMap()

我不太确定您要使用以下示例代码实现什么。

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

但是对于onErrorMap()来说，这似乎是个好例子，因为您似乎在尝试翻译一些例外情况

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