Spring Boot WebClient无返回值时数据不保存且无异常问题

这个问题是响应式编程的核心特性导致的：

• WebClient是Project Reactor生态的响应式HTTP客户端，它返回的Mono/Flux本质是懒加载的执行逻辑声明，不是已经执行完成的结果。只有当流被订阅（subscribe()）时，封装在流里的HTTP请求、参数序列化、响应处理等逻辑才会真正执行。
• 当你直接把mailchimpService.create(user)返回的Mono交还给Spring WebFlux控制器时，框架本身会作为订阅者，在请求处理生命周期内主动触发流执行，所以Mailchimp接口能收到请求，数据正常保存。
• 当你仅调用mailchimpService.create(user)但不接收返回值、也不做订阅操作时，这行代码只是在内存里生成了一个封装了HTTP请求逻辑的Mono对象，没有任何动作触发实际的网络请求——相当于写好了执行计划但从来没启动执行，请求根本没发出去，自然不会保存数据，也不会抛出任何异常。

你的代码里还存在两个容易出问题的坏实践：

1. 控制器方法直接返回null，在WebFlux中会被直接处理为空响应，框架不会等待任何未挂载到响应流上的异步逻辑执行
2. Service层用try-catch包裹整个流组装逻辑、异常时返回null，会破坏响应式流的异常传播机制，容易引发空指针、异常丢失等问题

根据你的业务需求选对应的实现即可：

场景1：需要等待Mailchimp接口返回结果后再响应前端 #

直接复用你第一份可正常运行的写法，把Service返回的Mono交还给框架托管即可，这也是响应式接口的标准写法：

@GetMapping(value = "/members/add/{email}") // 测试用GET，生产建议用POST
public Mono<String> addMember(@PathVariable String email) {
    User user = new User();
    user.setFirst_name("Test");
    user.setLast_name("Data");
    user.setEmail_id(email);
    return mailchimpService.create(user);
}

场景2：接口不需要等待Mailchimp返回，先给前端响应、异步执行Mailchimp请求 #

注意不能直接丢弃Mono对象，需要主动触发订阅，同时指定适合IO操作的调度器，做好异常处理避免异常静默丢失：

@GetMapping(value = "/members/add/{email}")
public Mono<String> addMember(@PathVariable String email) {
    User user = new User();
    user.setFirst_name("Test");
    user.setLast_name("Data");
    user.setPhone("");
    user.setEmail_id(email);

    // 主动触发异步流执行，切换到IO专用调度器，配置异常处理逻辑
    mailchimpService.create(user)
            .subscribeOn(Schedulers.boundedElastic())
            .subscribe(
                    resp -> System.out.println("Mailchimp请求成功，返回内容：" + resp),
                    err -> System.err.println("Mailchimp请求失败，错误信息：" + err.getMessage())
            );

    return Mono.just("提交成功");
}

同时建议修正Service层的实现，去掉无意义的外层try-catch，确保响应体被完整消费避免连接泄漏：

public Mono<String> create(User user) {
    Members members = convertUserToMailchimpObject(user);
    return webClient.post()
            .contentType(MediaType.APPLICATION_JSON)
            .body(BodyInserters.fromValue(members))
            .exchangeToMono(clientResponse -> {
                HttpStatusCode status = clientResponse.statusCode();
                if (status.is5xxServerError()) {
                    System.out.println(status.value() + " 服务端错误");
                } else {
                    System.out.println(status.value() + " 请求完成");
                }
                // 必须完整消费响应体，避免HTTP连接泄漏
                return clientResponse.bodyToMono(String.class);
            })
            .doOnError(Throwable::printStackTrace);
}

注意：直接调用subscribe()实现的异步任务属于内存级火并忘任务，服务重启、线程池满时会直接丢失，可靠性要求高的场景建议将任务持久化后通过消息队列、调度线程池执行。

内容的提问来源于stack exchange，提问作者Manoj Rawat