Spring将在用户返回数据之前等待其完成任务

Question

我正在尝试使用返回Mono的Spring反应器webclient执行多个HTTP调用。我正在使用Mono.block（）等待所有monos完成。这不是等待直到订阅（）完成。

public class UserValidator {

    public Mono<User> getUserSummary(int userId) {
        User user = new User();

        // First Mono
        Mono<Address> address = WebClientUtil.mono(userId, Address.class);
        address.subscribe(adrs -> updateAddress(adrs, user));

        // Second Mono
        Mono<Education> education = WebClientUtil.mono(userId, Education.class);
        education.subscribe(edcn -> updateEducationDeatils(edcn, user));

        Mono.when(address, education).block(); // Blocking the monos to complete

        // Intermittently returning the incomplete data ******************
        return Mono.just(user);
    }

    private void updateAddress(Address adrs, User user) {
        // Do some validations
        // Validations takes 5 to 10 seconds
        user.setAddress(adrs);
    }

    private void updateEducationDeatils(Education education, User user) {
        // Do some validations
        // Validations takes 5 to 10 seconds
        user.setEducation(education);
    }

}

有人能帮我解决这个问题，在subscribe（）完成后返回更新的用户对象吗？

Answer 1

如果返回值也是Mono，则不应阻止Mono，而是使用zip：

    public Mono<User> getUserSummary(int userId) {
        Mono<Address> addressMono = WebClientUtil.mono(userId, Address.class);
        Mono<Education> educationMono = WebClientUtil.mono(userId, Education.class);

        return Mono.zip(addressMono, educationMono, (address, education) -> {
          User user = new User();
          user.setAddress(address);
          user.setEducation(education);
        });
    }

此外，请确保您的验证不会阻止任何一个。