Webflux mongo保存多个模型

Question

@DBRef
private List<Server> servers;

在要创建服务器的控制器中,我首先创建并保存服务器,然后将服务器添加到user中的服务器列表中,并保存该用户：

@PostMapping
public Mono create(@Valid @RequestBody Server server, Mono<Authentication> authentication) {
    return this.serverRepository.save(server) // This works, the server is saved.
            .and(authentication.map(value -> {
                User user = (User) value.getDetails();
                System.out.println(user); // This works, so this function is called.
                if (user.getServers() == null) {
                    // Create empty list so .add can be used.
                    user.setServers(new ArrayList<>());
                }
                user.getServers().add(server);
                return userRepository.save(user); // Isn't working, in the UserCascadeSaveMongoEventListener I don't see it.
            }));
}

我认为我使用.and()的方式是不对的。

要保存关系，我使用UserCascadeSavemongoEventListener:

public class UserCascadeSaveMongoEventListener extends AbstractMongoEventListener<Object> {

    @Autowired
    private MongoOperations mongoOperations;

    @Override
    public void onBeforeConvert(BeforeConvertEvent<Object> event) {
        Object source = event.getSource();
        System.out.println(source); // On server create only the Server is shown, User is not shown.
        if ((source instanceof User) && (((User) source).getServers() != null)) {
            mongoOperations.save(((User) source).getServers());
        }
    }
}

使用的存储库都是正常的ReactiveCrudRepositories。

用多个mono响应调用多个存储库的正确方法是什么？

Answer 1

save调用实际上并不保存，而是设置一个可用于保存的反应管道。该操作仅在某些内容订阅时才执行：

Mono<User> savedUser = userRepository.save(user);

因此，您应该在您的controller方法中组合各种位，并确保没有任何反应类型被单独保留。

通过在保存操作之后添加log()运算符，您可以看到这一点-没有任何东西订阅它，因此不执行该操作。

@PostMapping
public Mono<User> create(@Valid @RequestBody Server server, Mono<Authentication> authentication) {
    return this.serverRepository.save(server) // This works, the server is saved.
            .then(authentication.flatMap(value -> {
                User user = (User) value.getDetails();
                System.out.println(user); // This works, so this function is called.
                if (user.getServers() == null) {
                    // Create empty list so .add can be used.
                    user.setServers(new ArrayList<>());
                }
                user.getServers().add(server);
                return userRepository.save(user);
            }));
}