自定义MongoDB Server选择

Overview

所有MongoDB驱动程序在选择要读取或写入的服务器时都遵循定义的算法。通过使用 MongoClient对象的 ClusterConfigurator属性，您可以自定义此算法以选择最适合您的应用程序的服务器。

默认算法

当.NET/ C#驱动程序执行读取操作时，它会按顺序执行以下步骤，以选择MongoDB 部署：

1. 从已知服务器列表中选择与主动读取偏好（read preference）匹配的所有服务器。

2. 如果至少存在一个可读服务器，驾驶员将调用用户定义的服务器选择器函数并传入上一步中的列表。

3. 将 LocalThreshold 连接设置应用于从该函数返回的服务器列表。

4. 从仍在列表中的服务器中随机选择一个服务器，并对该服务器执行操作。

当.NET/ C#驱动程序执行写入操作时，它首先选择所有可写入的服务器，而不仅仅是那些与活动读取偏好（read preference）匹配的服务器。其余步骤相同。

要学习；了解默认服务器选择算法（在您未指定任何自定义服务器选择逻辑时驾驶员遵循的算法）的更多信息，请参阅MongoDB Server手册中的服务器选择算法。

指定其他服务器选择算法

您可以通过将服务器选择器类的实例传递给 ClusterConfigurator 的 PreServerSelector 或 PostServerSelector属性来指定不同的服务器选择逻辑。PreServerSelector属性指定在标准服务器选择逻辑运行之前运行的服务器选择器，而 PostServerSelector属性指定在标准服务器选择逻辑运行之后运行的服务器选择器。然后，您可以在创建 MongoClient实例时将 ClusterConfigurator实例传递给 MongoClientSettings对象，以应用自定义服务器选择逻辑。

下表列出了您可以传递给 ClusterConfigurator属性的不同类型的服务器选择器：

以下示例指示 MongoClient 在标准服务器选择逻辑运行之前使用 RandomServerSelector 类随机选择一个服务器：

var settings = MongoClientSettings.FromConnectionString("<connection string>");
var clusterConfigurator = builder =>
{
    builder.ConfigureCluster(c =>
        c.With(PreServerSelector: new RandomServerSelector()));
};
settings.ClusterConfigurator = clusterConfigurator;
var client = new MongoClient(settings);

要学习；了解有关不同服务器选择器类的更多信息，请参阅 ServerSelectors API文档。

实施自定义服务器选择逻辑

您可以通过创建一个类来继承 IServerSelector 接口并覆盖 SelectServers() 方法，实现自己的自定义服务器选择逻辑。以下示例显示了一个简单的自定义服务器选择类，该类选择 ServerType 为 ServerType.ReplicaSetSecondary 的服务器：

public class CustomServerSelector : IServerSelector
{
    public IEnumerable<ServerDescription> SelectServers(ClusterDescription cluster,
        IEnumerable<ServerDescription> servers)
    {
        return servers.Where(server => server.Type == ServerType.ReplicaSetSecondary);
    }
}

然后，您可以将此类的实例传递给 ClusterConfigurator实例的 PreServerSelector 或 PostServerSelector属性，如指定其他服务器选择算法部分所示。

使用设置配置服务器选择

您可以在 MongoClient对象或连接 URI 中指定以下服务器选择设置：

readPreference=primaryPreferred
&maxStalenessSeconds=90
&readPreferenceTags=dc:ny,rack:1

故障排除

A timeout occurred after 30000ms selecting a server using CompositeServerSelector{ Selectors = MongoDB.Driver.MongoClient+AreSessionsSupportedServerSelector, LatencyLimitingServerSelector{ AllowedLatencyRange = 00:00:00.0150000 }, OperationsCountServerSelector }.
Client view of cluster state is
{
    ClusterId : "1",
    Type : "Unknown",
    State : "Disconnected",
    Servers :
    [{
        ServerId: "{ ClusterId : 1, EndPoint : "Unspecified/localhost:27017" }",
        EndPoint: "Unspecified/localhost:27017",
        ReasonChanged: "Heartbeat",
        State: "Disconnected",
        ServerVersion: ,
        TopologyVersion: ,
        Type: "Unknown",
        HeartbeatException: "<exception details>"
    }]
}.

API 文档

要学习；了解有关本指南中使用的类和方法的更多信息，请参阅以下API文档：

• MongoClient

• MongoClientSettings

• ClusterConfigurator

• ServerSelectors

• IServerSelector

• SelectServer()