如何消除de.flapdoodle.embed.mongo的Got some response运行时错误

核心问题分析 #

1. 版本不兼容：mongo-java-driver 3.12.14最高仅支持MongoDB 4.4版本，而代码中启动的是MongoDB 7.0，版本差异会引发启动和连接异常。
2. 输出处理器覆盖错误：自定义的NullStreamProcessor完全吞掉了MongoDB启动时的所有输出，包括必要的启动成功标识，导致嵌入MongoDB的运行时无法校验启动状态，误报错误。

具体修复步骤 #

1. 匹配兼容的MongoDB版本 #

将启动的MongoDB版本改为Version.Main.V4_4，与驱动版本保持兼容。

2. 调整输出处理器逻辑 #

使用库内置的NullProcessor关闭日志输出，而非完全自定义空处理器，这样能保留必要的启动校验逻辑，避免误判。

3. 修正MongoClient初始化方式 #

MongoClient接受ServerAddress对象而非字符串，直接传入running.current().getServerAddress()，避免字符串解析可能带来的问题。

修改后的完整代码 #

import java.io.IOException;
import org.bson.Document;

import com.mongodb.MongoClient;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;

import de.flapdoodle.embed.mongo.distribution.Version;
import de.flapdoodle.embed.mongo.transitions.Mongod;
import de.flapdoodle.embed.mongo.transitions.RunningMongodProcess;
import de.flapdoodle.embed.process.io.ProcessOutput;
import de.flapdoodle.embed.process.io.nullio.NullProcessor;
import de.flapdoodle.reverse.Transition;
import de.flapdoodle.reverse.transitions.Start;

public class TestMongoDBembed {

    public static void main(String[] args) throws IOException {
        Mongod mongod = new Mongod() {
            @Override
            public Transition<ProcessOutput> processOutput() {
                return Start.to(ProcessOutput.class)
                        .initializedWith(ProcessOutput.builder()
                                .output(NullProcessor.INSTANCE)
                                .error(NullProcessor.INSTANCE)
                                .commands(NullProcessor.INSTANCE)
                                .build())
                        .withTransitionLabel("disable output");
            }
        };

        try (var running = mongod.start(Version.Main.V4_4)) {
            ServerAddress serverAddress = running.current().getServerAddress();
            try (MongoClient mongo = new MongoClient(serverAddress)) {
                MongoDatabase db = mongo.getDatabase("testDatabase");
                MongoCollection<Document> col = db.getCollection("testCollection");
                col.insertOne(new Document("testString", "testString"));
                System.out.println("数据插入成功");
            }
        }
    }
}

额外说明 #

如果不需要关闭日志，可直接使用默认的Mongod实例，省去自定义processOutput的步骤，还能通过启动日志排查问题：

Mongod mongod = Mongod.instance();

内容的提问来源于stack exchange，提问作者Turok