import de.flapdoodle.embed.mongo.MongodProcess; //导入依赖的package包/类
@BeforeClass
public static void beforeClass() throws Exception {
  MongodStarter runtime = MongodStarter.getDefaultInstance();
  mongodExe = runtime.prepare(
    new MongodConfigBuilder().version(Version.V3_3_1)
      .net(new Net(12345, Network.localhostIsIPv6()))
      .build());
  MongodProcess process = mongodExe.start();
  await().until(() -> process != null);
}
 

import de.flapdoodle.embed.mongo.MongodProcess; //导入依赖的package包/类
private void startMongo(final List<IMongodConfig> mongodConfigList) throws IOException {
    // @formatter:off
    final ProcessOutput processOutput = new ProcessOutput(
            logTo(LOGGER, Slf4jLevel.INFO),
            logTo(LOGGER, Slf4jLevel.ERROR),
            named("[console>]", logTo(LOGGER, Slf4jLevel.DEBUG)));

    final IRuntimeConfig runtimeConfig = new RuntimeConfigBuilder()
            .defaultsWithLogger(Command.MongoD,LOGGER)
            .processOutput(processOutput)
            .artifactStore(new ExtractedArtifactStoreBuilder()
                .defaults(Command.MongoD)
                .download(new DownloadConfigBuilder()
                    .defaultsForCommand(Command.MongoD)
                    .progressListener(new Slf4jProgressListener(LOGGER))
                    .build()))
            .build();
    // @formatter:on
    final MongodStarter starter = MongodStarter.getInstance(runtimeConfig);

    for (final IMongodConfig mongodConfig : mongodConfigList) {
        final MongodExecutable mongodExecutable = starter.prepare(mongodConfig);
        final MongodProcess mongod = mongodExecutable.start();

        mongoProcesses.put(mongod, mongodExecutable);
    }
}
 

import de.flapdoodle.embed.mongo.MongodProcess; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
public IResponse run(IContext context) throws CommandException
{
	// Creates the response
	IResponse response = new Response();
	
	// If the embedded server is not already stated or starting
	if(context.getState() != State.STARTING && context.getState() != State.STARTED) {
	
		// Sets the starting state
		context.setState(State.STARTING);

		// Creates and starts a MongodExecutable
		MongodStarter starter = MongodStarter.getInstance(context.getMongoContext().getRuntimeConfig());
		MongodExecutable mongodExecutable = starter.prepare(context.getMongoContext().getMongodConfig());
		
		try {
			MongodProcess mongodProcess = mongodExecutable.start();
			context.getMongoContext().setMongodProcess(mongodProcess);
		} catch (IOException ioException) {
			throw new CommandException(ioException);
		}

		context.getMongoContext().setMongodExecutable(mongodExecutable);

		// Sets the started state
		context.setState(State.STARTED);

	}

	// Otherwise this is an error because the server is already started
	else {
		
		// TODO: Trouver un moyen de modéliser une erreur générique
		
	}

	return response;
}
 

import de.flapdoodle.embed.mongo.MongodProcess; //导入依赖的package包/类
public void start() throws Throwable {
    this.mongodProcessList = new ArrayList<MongodProcess>();
    Set<Entry<String, List<IMongodConfig>>> entries = replicaSet.entrySet();
    for (Entry<String, List<IMongodConfig>> entry : entries) {
        initializeReplicaSet(entry);
    }
}
 

import de.flapdoodle.embed.mongo.MongodProcess; //导入依赖的package包/类
@Bean(destroyMethod = "stop")
@DependsOn("mongodExecutable")
public MongodProcess mongod() throws IOException {
    return mongodExecutable().start();
}
 

import de.flapdoodle.embed.mongo.MongodProcess; //导入依赖的package包/类
@Bean(destroyMethod = "stop")
public MongodProcess mongod() throws IOException {
    return mongodExe().start();
}
 

import de.flapdoodle.embed.mongo.MongodProcess; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
public MongodProcess getMongodProcess() {
	return this.mongodProcess;
}
 

import de.flapdoodle.embed.mongo.MongodProcess; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
public void setMongodProcess(MongodProcess mongodProcess)
{
	this.mongodProcess = mongodProcess;
}
 

import de.flapdoodle.embed.mongo.MongodProcess; //导入依赖的package包/类
public void stop() {
    for (MongodProcess process : this.mongodProcessList) {
        process.stop();
    }
}
 

import de.flapdoodle.embed.mongo.MongodProcess; //导入依赖的package包/类
public MongodProcess getMongodProcess() {
    return mongodProcess;
}
 

import de.flapdoodle.embed.mongo.MongodProcess; //导入依赖的package包/类
/**
 * Gets a reference to the Mongo DB process.
 * 
 * @return a reference to the Mongo DB process.
 */
public MongodProcess getMongodProcess();
 

import de.flapdoodle.embed.mongo.MongodProcess; //导入依赖的package包/类
/**
 * Sets a reference to the Mongo DB process.
 * 
 * @param mongodProcess A reference to the Mongo DB process.
 */
void setMongodProcess(MongodProcess mongodProcess);