如何处理mongodb中副本集成员的临时中断

Question

当副本集中的其中一台服务器被关闭或关闭时，应用程序尝试连接到副本集时会超时。

不知道该怎么做。有处理这个问题的编程模式吗？在 Windows 服务器上运行 Mongodb 3.4.24。

Answer 1

应用程序中 MongoDB 副本集的连接超时和失败涉及实施正确的错误处理和重试机制。

以下是您可以遵循的一些编程模式和最佳实践：

连接超时配置： 确保您已在 MongoDB 驱动程序配置中设置了适当的连接超时值。此超时定义驱动程序在认为连接失败之前等待连接建立的时间。适当设置此超时可以帮助您的应用程序更快地响应服务器不可用。

重试逻辑： 实施重试机制来处理暂时性错误。如果连接尝试失败，您的应用程序可以在短暂延迟后重试连接到副本集。确保设置合理的重试次数，以避免连续尝试，这可能会影响应用程序的性能。

指数退避： 重试连接时实施指数退避。这意味着每次重试之间的延迟呈指数增长。这种方法有助于防止服务器再次可用时出现连接请求过多的情况。

处理故障转移： 如果副本集中的一台服务器关闭，您的应用程序应该意识到这一点并准备连接到其他可用的服务器。 MongoDB 驱动程序通常会自动处理故障转移，但您应该确保您的连接字符串或配置包含所有副本集成员。

阅读偏好设置： 根据您的应用程序的要求设置适当的读取首选项。例如，如果您的应用程序可以容忍从辅助节点读取，您可以配置读取首选项以允许这样做。这可以提高网络问题或计划维护期间的可用性。

连接池： 利用 MongoDB 驱动程序提供的连接池机制。连接池有助于高效管理和重用数据库连接，减少每个操作打开和关闭连接的开销。

明确处理连接错误： 在代码中显式捕获并处理 MongoDB 连接错误。记录有关错误的相关信息，并考虑实施后备机制或通知管理员。

以下是使用 PyMongo 驱动程序的 Python 示例代码：

import pymongo
from pymongo.errors import AutoReconnect

设置适当的连接选项

client = pymongo.MongoClient("mongodb://host1,host2,host3/?replicaSet=myReplicaSet", serverSelectionTimeoutMS=2000)

通过指数退避实现重试

def connect_with_retry():
max_retries = 3
delay = 1  # initial delay in seconds

for _ in range(max_retries):
    try:
        # Attempt to connect
        client.admin.command('ping')
        print("Connected successfully!")
        break
    except AutoReconnect as e:
        print(f"Connection failed: {e}")
        print(f"Retrying in {delay} seconds...")
        time.sleep(delay)
        delay *= 2  # exponential backoff

使用connect_with_retry函数

connect_with_retry()

有关更多信息，请查阅 MongoDB 驱动程序的文档，了解特定于语言的详细信息和功能。