WebClient Spring Boot：仅当数据返回值时才保存数据

Question

当我返回值时，我使用Mailchimp api，它工作正常，但当我不返回任何值时，它不工作，也不会引发任何异常。

@GetMapping(value = "/members/add/{email}") //using GET to test
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);
}

这不是保存数据

@GetMapping(value = "/members/add/{email}") //using GET to test
    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);
        mailchimpService.create(user);

        return null;
    }

public Mono<String> create(User user) {
        try {
            Members members = convertUserToMailchimpObject(user);
            return webClient.post()
                    .contentType(MediaType.APPLICATION_JSON)
                    .body(BodyInserters.fromValue(members))
                    .exchangeToMono(clientResponse -> {
                        if (clientResponse.statusCode().is5xxServerError()) {
                            clientResponse.body((clientHttpResponse, context) -> clientHttpResponse.getBody());
                            System.out.println(clientResponse.statusCode() + " statusCode error");
                            System.out.println(clientResponse.statusCode().value() + " value error");
                            return clientResponse.bodyToMono(String.class);
                        } else
                            System.out.println(clientResponse.statusCode() + " statusCode");
                        System.out.println(clientResponse.statusCode().value() + " value");
                        return clientResponse.bodyToMono(String.class);
                    });
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }

Answer 1

原因是在反应式编程中，除非您订阅，否则不会发生任何事情。create方法永远不会被订阅，因此永远不会进行webclient调用。

第一个代码段是有效的，因为只要您提供发布者（Mono），Webflux框架就会为您订阅。