Ruby MongoDB驱动连接副本集无限重试问题的原因与解决

问题原因 #

Mongo Ruby驱动连接副本集时，默认会启动后台监控线程（Replica Set Monitor），用来定期检测副本集的节点状态、拓扑变化。当初始握手失败（比如节点不可达、认证错误），主线程的Mongo::Client.new会抛出异常，但后台监控线程不会自动终止，会持续尝试重新握手并输出错误日志——这就是终端一直刷错误的原因：主线程代码已经执行完毕（所以Before和After只打印一次），但后台线程仍在运行。

解决办法 #

• 设置连接超时与重试参数：初始化客户端时，通过connect_timeout限制单次连接超时时间，用max_retries控制重试次数，避免无限重试：

def get_mongo_client
  puts "Before"
  client = Mongo::Client.new(
    "mongodb://foo:bar@0.example.com,1.example.com/admin?replicaSet=rs0",
    connect: :replica_set,
    connect_timeout: 5, # 连接超时5秒
    max_retries: 2,     # 最多重试2次
    retry_interval: 1   # 重试间隔1秒
  ).use("mydb")
  puts "After"
  client
rescue Mongo::Error::SocketError => e
  puts "连接失败: #{e.message}"
  nil
end

• 显式禁用后台监控（仅适用于测试场景）：如果只是临时测试，可以通过monitoring: false关闭后台监控线程，初始失败后不会有后台重试：

def get_mongo_client
  puts "Before"
  client = Mongo::Client.new(
    "mongodb://foo:bar@0.example.com,1.example.com/admin?replicaSet=rs0",
    connect: :replica_set,
    monitoring: false
  ).use("mydb")
  puts "After"
  client
rescue Mongo::Error::SocketError => e
  puts "连接失败: #{e.message}"
  nil
end

• 捕获异常后清理客户端资源：捕获连接异常时，显式调用close方法终止客户端，确保后台线程被销毁：

def get_mongo_client
  puts "Before"
  client = nil
  begin
    client = Mongo::Client.new(
      "mongodb://foo:bar@0.example.com,1.example.com/admin?replicaSet=rs0",
      connect: :replica_set
    ).use("mydb")
    puts "After"
  rescue Mongo::Error::SocketError => e
    puts "连接失败: #{e.message}"
    client.close if client # 清理资源，终止后台线程
    client = nil
  end
  client
end

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