为什么 MongoDB Atlas 不能与反应式 Spring Data 和 Spring Boot 一起使用？

Question

我正在开发一个简单的示例应用程序。一个组件是使用Spring Boot和Mongo的反应性弹簧数据的网关服务，因为这是我要存储用户和登录信息的地方。

为了测试不同的解决方案，我想使用MongoDB地图集。因此，我设置了一个应用程序。但是，当我只想保存示例用户时，什么也不会发生，数据不会保存到数据库中。但是，该应用程序似乎已连接到MongoDB地图集。没有关于失败连接的错误日志。

这是主要类，其中我拥有@enableReactivemongorePosories注释：

@SpringBootApplication
@EnableReactiveMongoRepositories("com.bkk.sm.authentication.repository")
public class GatewayApplication {

    public static void main(String[] args) {
        SpringApplication.run(GatewayApplication.class, args);
    }
}

这是我在application..yml和存储库中设置mongo的方式：

spring:
  data:
    mongodb:
      database: users
      uri: mongodb+srv://${MONGO_USER}:${MONGO_PASSWORD}@taocluster.qa3sd.mongodb.net/users?retryWrites=true&w=majority

@Repository
public interface ReactiveUserRepository extends ReactiveMongoRepository<User, String> {
    Mono<User> findByUsername(String username);

}

我不使用任何特定的反应性mongodb config，我不使用'' t扩展了avtactRactReaCtiveMongoConfiguration（这实际上只是实验如何工作的回合），我使用默认值。

在我的userDetailsserviceimpl中，我尝试保存示例记录，就在bean构造之后：

@Slf4j
@Service
public class UserDetailsServiceImpl implements UserDetailsService {

    private ReactiveUserRepository repository;

    public UserDetailsServiceImpl(ReactiveUserRepository repository) {
        this.repository = repository;
    }

    @PostConstruct
    public void setup() {
     BCryptPasswordEncoder encoder = new BCryptPasswordEncoder();
     String pwd = encoder.encode("user");
     User user = User.builder()
             .username("user")
             .password(pwd)
             .accountExpired(false)
             .accountLocked(false)
             .activationCode(null)
             .activatedTime(Date.from(Instant.now()))
             .email("[email protected]")
             .enabled(true)
             .firstName("User")
             .failedLoginAttempts(0)
             .lastModificationTime(Date.from(Instant.now()))
             .lastName("User")
             .middleName("User")
             .passwordExpiryTime(Date.from(Instant.now()))
             .registrationTime(Date.from(Instant.now()))
             .roles(List.of(CompanyRole.builder().companyCode("bkk")
                     .companyName("Beszterce KK")
                     .role(Role.ROLE_USER)
                     .build())
             )
             .passwordExpiryTime(null)
             .version(0)
             .build();
     this.repository.save(user).map(user1 -> {
         log.info("User saved. {}", user1);
         return user1;
     }).onErrorResume(Objects::nonNull, throwable -> {
         log.error("Something is not right here.", throwable);
         return Mono.error(throwable);
     }).switchIfEmpty(Mono.defer(() -> {
         log.info("Cannot save ure={}", user.toString());
         return Mono.error(new Exception("WTF?"));
     }));
    }
... SOME MORE METHODS COME HERE
}

当它执行this.repository.save（user） line时，什么都没有发生。好吧，我试图进行调试，并更深入地进入框架，但最终什么也没有发生。这就是为什么我添加了一些日志消息。但是什么都没有。如果我对MAP或onerrorsume或switchifempty分支进行断点，则执行不止于此。没有编写日志来安慰其他行：

2022-04-09 00:02:46.061  INFO 72528 --- [ntLoopGroup-3-7] org.mongodb.driver.connection            : Opened connection [connectionId{localValue:7, serverValue:78530}] to taocluster-shard-00-02.qa3sd.mongodb.net:27017

这是我声明集合名称的数据对象：

@Getter
@Builder
@NoArgsConstructor
@AllArgsConstructor
@Document(collection = "users")
public class User implements UserDetails {

    @Id
    private String id;

    @Indexed
    @NonNull
    private String username;

... SOME MORE FIELDS COME HERE ...
}

所以，我的问题是，我在做什么错？为什么我看不到MongoDB Atlas样本数据库中添加的任何内容？我刚刚设置了0.0.0.0/0，目的是在测试这些东西的暂时接受连接。

任何帮助将不胜感激。