如何测试响应式流驱动的MongoClient是否已真实建立连接？

底层原因 #

MongoClients.create 方法默认采用懒加载逻辑，仅校验Mongo URI的语法合法性，不会立刻发起真实的网络连接请求。因此只要URI格式符合规范，哪怕指向的Mongo实例不存在、地址无效，客户端实例都能正常创建，只有首次执行数据库读写、管理操作时才会实际建立连接，此时才会抛出连接相关错误。

高效测试方法 #

无需执行重资源的列举数据库操作，用轻量的ping命令搭配自定义短超时参数即可实现快速检测，具体实现逻辑如下：

• 首先配置短超时参数：将服务选择超时、连接建立超时设置为可接受的短阈值（比如1秒），避免无效等待
• 调用ping命令检测：ping是MongoDB提供的轻量健康检查命令，服务端处理开销极低，返回速度远快于列举数据库操作

Java驱动示例代码如下：

import com.mongodb.*;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import org.bson.Document;
import java.util.concurrent.TimeUnit;

public class MongoConnectTest {
    public static boolean checkConnection(String mongoUri) {
        // 仅用于检测的短超时配置
        MongoClientSettings testSettings = MongoClientSettings.builder()
                .applyConnectionString(new ConnectionString(mongoUri))
                .applyToClusterSettings(builder -> 
                    // 服务器寻址超时，设置为1秒
                    builder.serverSelectionTimeout(1, TimeUnit.SECONDS)
                )
                .applyToSocketSettings(builder -> 
                    // TCP连接建立超时，设置为1秒
                    builder.connectTimeout(1, TimeUnit.SECONDS)
                )
                .build();

        try (MongoClient testClient = MongoClients.create(testSettings)) {
            // 发送ping命令，无业务开销
            testClient.getDatabase("admin").runCommand(new Document("ping", 1));
            return true;
        } catch (MongoTimeoutException | MongoSocketException | MongoSecurityException e) {
            // 分别捕获超时、连接错误、鉴权错误等连接类异常
            return false;
        }
    }
}

注意：上述短超时配置仅适用于连接有效性检测场景，如果是生产环境正常业务使用，请根据实际网络情况设置合理的超时参数，不要使用过短的超时配置避免正常请求被误杀。

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