Spring Boot连接MongoDB误连仲裁节点致超时，如何规避？

问题根源 #

MongoDB Java驱动（Spring Data Mongo依赖该驱动）在连接副本集时，会自动从已配置节点获取整个副本集的成员列表（包括仲裁节点），并尝试连接所有成员以维护副本集状态。若仲裁节点不可达，驱动在启动阶段的服务器选择过程中会因连接超时导致应用启动失败。

解决方案 #

1. 调整连接超时参数，让驱动跳过不可达仲裁节点 #

在MongoDB连接URI中添加超时相关参数，给驱动足够时间选择可用的数据节点，避免因仲裁节点不可达直接启动失败：

spring.data.mongodb.uri=mongodb://mongoUs:mongoPs@primary@mongo,secondary@mongo:27027/mgbd?authSource=mgdb&replicaSet=rc&ssl=true&serverSelectionTimeoutMS=10000&connectTimeoutMS=5000&socketTimeoutMS=5000

• serverSelectionTimeoutMS：设置驱动选择可用服务器的超时时间（单位：毫秒），超时后会忽略不可达节点，自动切换到可用的主/从节点。
• connectTimeoutMS：单个节点的连接超时时间，避免在单个不可达节点上耗时过久。
• socketTimeoutMS：套接字读写超时时间，控制单次数据交互的超时阈值。

2. 自定义MongoClient过滤仲裁节点（严格禁止连接场景） #

如果需要完全禁止驱动连接仲裁节点，可以通过自定义MongoClient配置，过滤掉仲裁节点。示例代码如下：

import com.mongodb.MongoClientSettings;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.config.AbstractMongoClientConfiguration;

import java.util.Arrays;
import java.util.List;

@Configuration
public class MongoConfig extends AbstractMongoClientConfiguration {

    @Override
    protected String getDatabaseName() {
        return "mgbd";
    }

    @Override
    public MongoClient mongoClient() {
        // 指定仅连接数据节点
        List<ServerAddress> serverAddresses = Arrays.asList(
                new ServerAddress("primary@mongo"),
                new ServerAddress("secondary@mongo", 27027)
        );

        // 配置认证信息
        MongoCredential credential = MongoCredential.createCredential(
                "mongoUs",
                "mgdb",
                "mongoPs".toCharArray()
        );

        MongoClientSettings settings = MongoClientSettings.builder()
                .applyToClusterSettings(builder ->
                        builder.hosts(serverAddresses)
                                // 自定义节点选择逻辑，过滤仲裁节点
                                .serverSelector(serverAddress -> {
                                    // 可根据节点地址、标签等判断是否为仲裁节点，返回true则保留
                                    // 示例：如果仲裁节点地址包含"arbiter"则过滤
                                    return !serverAddress.getHost().contains("arbiter");
                                })
                )
                .credential(credential)
                .applyToSslSettings(builder -> builder.enabled(true))
                .build();

        return MongoClients.create(settings);
    }
}

注意：此方式会限制驱动的副本集自动发现能力，若主节点故障，需确保配置的从节点可用才能实现故障转移。

3. 检查副本集配置（可选） #

若有权限修改MongoDB副本集配置，可将仲裁节点的priority设为0，减少驱动对其的连接优先级，但仲裁节点作为副本集必要成员，此方法仅适用于特殊场景。

验证 #

修改配置后重启应用，观察启动日志是否不再出现仲裁节点连接超时错误，同时确认应用能正常连接主/从节点并完成数据操作。

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