java - flapdoodle.embed.mongo 总是从 Eclipse 中的 Spring Boot 主应用程序开始,如何删除

标签 java spring mongodb spring-boot

我有一个问题。一个简单的 spring boot 应用程序可以很好地与现有的 MongoDB 配置一起工作。 对于集成测试,我使用 flapdoodle 配置为嵌入式 mongodb 添加了必需的配置。所有单元测试都得到正确执行。当我运行主要的 Spring Boot 应用程序时,它默认会考虑 flapdoodle 嵌入的 mongodb 配置。结果,嵌入式 mongodb 永远不会退出,并且在运行 junit 测试用例时,它仍在运行。我在下面提供了代码片段。

每当我启动 Spring Boot 主应用程序时,它仍然运行嵌入式 mongodb。我总是在控制台中看到以下几行。

Download PRODUCTION:Windows:B64 START
Download PRODUCTION:Windows:B64 DownloadSize: 231162327
Download PRODUCTION:Windows:B64 0% 1% 2% 3% 4% 5% 6% 7% 8% 

我提供了运行主 Spring Boot 应用程序时应选择的 Mongodb 配置代码。

@Slf4j
@Configuration
public class NoSQLAutoConfiguration {

    @Autowired
    private NoSQLEnvConfigProperties configProperties;

    /**
     * Morphia.
     *
     * @return the morphia
     */
    private Morphia morphia() {
        final Morphia morphia = new Morphia();
        morphia.mapPackage(DS_ENTITY_PKG_NAME);
        return morphia;
    }


    @Bean
    public Datastore datastore(@Autowired @Qualifier("dev") MongoClient mongoClient) {
        String dbName = configProperties.getDatabase();
        final Datastore datastore = morphia().createDatastore(mongoClient, dbName);
        datastore.ensureIndexes();

        return datastore;
    }

    /**
     * Mongo client.
     *
     * @return the mongo client
     */
    @Primary
    @Bean(name = "dev")
    public MongoClient mongoClient() {
        MongoClient mongoClient = null;
        String dbHost = configProperties.getHost();
        int dbPort = configProperties.getPort();
        String database = configProperties.getDatabase();
        log.debug("MongDB Host: {} - MongoDB Port: {}", dbHost, dbPort);
        List<ServerAddress> serverAddresses = new ArrayList<>();
        serverAddresses.add(new ServerAddress(dbHost, dbPort));
        MongoClientOptions options = getMongoOptions();
        String dbUserName = configProperties.getMongodbUsername();
        String encRawPwd = configProperties.getMongodbPassword();
        char[] dbPwd = null;
        try {
            dbPwd = Util.decode(encRawPwd).toCharArray();
        } catch (Exception ex) {
            // Ignore exception
            dbPwd = null;
        }
        Optional<String> userName = Optional.ofNullable(dbUserName);
        Optional<char[]> password = Optional.ofNullable(dbPwd);

        if (userName.isPresent() && password.isPresent()) {
            MongoCredential credential = MongoCredential.createCredential(dbUserName, database, dbPwd);
            List<MongoCredential> credentialList = new ArrayList<>();
            credentialList.add(credential);
            mongoClient = new MongoClient(serverAddresses, credentialList, options);
        } else {
            log.debug("Connecting to local Mongo DB");
            mongoClient = new MongoClient(dbHost, dbPort);
        }
        return mongoClient;
    }

    
    private MongoClientOptions getMongoOptions() {
        MongoClientOptions.Builder builder = MongoClientOptions.builder();
        builder.maxConnectionIdleTime(configProperties.getMongodbIdleConnection());
        builder.minConnectionsPerHost(configProperties.getMongodbMinConnection());
        builder.connectTimeout(configProperties.getMongodbConnectionTimeout());
        return builder.build();
    }

}

对于集成测试,我有嵌入式 mongodb 的配置,它是 src/test 的一部分。

@TestConfiguration
public class MongoConfiguration implements InitializingBean, DisposableBean {

    MongodExecutable executable;
    private static final String DBNAME = "embeded";
    private static final String DBHOST = "localhost";
    private static final int DBPORT = 27019;

    @Override
    public void afterPropertiesSet() throws Exception {
        IMongodConfig mongodConfig = new MongodConfigBuilder().version(Version.Main.PRODUCTION)
                .net(new Net(DBHOST, DBPORT, Network.localhostIsIPv6())).build();

        MongodStarter starter = MongodStarter.getDefaultInstance();
        executable = starter.prepare(mongodConfig);
        executable.start();
    }

    private Morphia morphia() {
        final Morphia morphia = new Morphia();
        morphia.mapPackage(DS_ENTITY_PKG_NAME);
        return morphia;
    }

    @Bean
    public Datastore datastore(@Autowired @Qualifier("test") MongoClient mongoClient) {
        
        final Datastore datastore = morphia().createDatastore(mongoClient, DBNAME);
        datastore.ensureIndexes();

        return datastore;
    }

    
    @Bean(name = "test")
    public MongoClient mongoClient() {
        return new MongoClient(DBHOST, DBPORT);
    }

    @Override
    public void destroy() throws Exception {
        executable.stop();
    }
}

请帮助我如何在 Eclipse 中运行 Spring Boot 主应用程序时删除此嵌入式 mongo 配置。

我还在下面提供了我的主要应用程序。

@EnableAspectJAutoProxy
@EnableSwagger2
@SpringBootApplication(scanBasePackages = { "com.blr.app" })
public class ValidationApplication {

    /**
     * The main method. f
     * 
     * @param args the arguments
     */
    public static void main(String[] args) {
        SpringApplication.run(ValidationApplication.class, args);
    }

}

最佳答案

我看到您尚未向 MongoConfiguration 类添加任何配置文件的代码。在 eclipse 构建期间,这个类也被 Spring 框架拾取。将以下行添加到此类,以便在运行 Spring Boot 测试时选择此类,而在运行主 Spring Boot 应用程序时,将选择实际的 Mongo 配置文件。这就是 Spring 提出 Profile 概念的原因。为不同的环境适当添加配置文件。

@Profile("test")
@ActiveProfiles("test")

所以最终代码看起来像这样。

@Profile("test")
@ActiveProfiles("test")
@TestConfiguration
public class MongoConfiguration implements InitializingBean, DisposableBean {
   ...
   ...
}

关于java - flapdoodle.embed.mongo 总是从 Eclipse 中的 Spring Boot 主应用程序开始,如何删除,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/65026209/

相关文章:

java - 在同一节点上进行分区处理?

java - 按预定顺序为子树打印 ( )

java - 如何为具有私有(private)字段的类编写junit?

java - 当 ajax 调用提出请求时,重定向页面在过滤器中不起作用?

node.js - forEach执行后如何关闭 Mongoose 连接?

Java MongoDB 查询

java - 如何在 jsf selectOneMenu 中访问选定的标签和选定的描述,其中 selectOneMenu 与 javax.faces.model.SelectItem 对象绑定(bind)?

java - 如果其他类更改了某些内容,如何使更改对一个类可见?

java - 开始认为 Maven 对于我当前的项目来说太过分了

javascript - 如何将所有 Meteor Mongo 集合名称检索为 Javascript 数组?