JavaSpringWebFlup-在反应式管道中使用Mono.error（新的MyCustomException（））

Question

关于Mono用法的小问题。反应管道中出现错误（new MyCustomException（））

我有一个非常简单的业务用例：使用Spring Webflow

• 步骤1：对第三方rest API进行HTTP调用
• 根据第一方rest API的响应，如果只有第一个响应符合条件，则使用map函数将响应转换为MyPojo。但如果不符合条件，则应引发自定义异常

因此，我写了以下内容：

    @PostMapping(path = "/question")
    public Mono<MyPojo> question(String key) {
        return WebClient.create("http://first-service.com/get" + key).get().exchangeToMono(clientResponse -> clientResponse.bodyToMono(String.class)) //Mono<String>
        .map(oneString -> convertOneStringToMyPojoIfStringIsEligible(oneString));
    }

    private MyPojo convertOneStringToMyPojoIfStringIsEligible(String oneString) {
        if (oneString.startsWith("eligible")) {
            return new MyPojo(oneString);
        } else {
            return Mono.error(new MyCustomException("oneString is not eligible.")); //This is not possible
        }
    }

请问正确的方法是什么？

如果可能，不要抛出RuntimeException，也不要使用flatMap Mono。就（新的MyPojo（一串））好吗？

谢谢你

Answer 1

除了@Toerktomlare在评论中建议的之外，另一个选择是将过滤器与SwitchIf空结合使用

WebClient.create("http://first-service.com/get" + key)
                .get()
                .exchangeToMono(clientResponse -> clientResponse.bodyToMono(String.class))
                .filter(s -> s.startsWith("eligible"))
                .map(s -> new MyPojo(s))
                .switchIfEmpty(Mono.error(new RuntimeException("oneString is not eligible.")));

就个人而言，除非您需要访问除正文之外的响应的其他部分，否则我将默认使用ExchangeTomonio上的检索。虽然这只是个人喜好

WebClient.create("http://first-service.com/get" + key)
                .get()
                .retrieve()
                .bodyToMono(String.class)
                .filter(s -> s.startsWith("eligible"))
                .map(s -> new MyPojo(s))
                .switchIfEmpty(Mono.error(new RuntimeException("oneString is not eligible.")))