如何检查与mongodb的连接

本文关键字：mongodb 连接 检查 何检查 | 更新日期: 2024-09-25 03:21:34

我使用MongoDB驱动程序连接到数据库。当我的表单加载时，我想设置连接并检查它是否正常。我是这样做的：

var connectionString = "mongodb://localhost";
var client = new MongoClient(connectionString);
var server = client.GetServer();
var database = server.GetDatabase("reestr");

但我不知道如何检查连接。我试图将此代码与try-catch重叠，但没有成功。即使我创建了一个不正确的connectionString，我仍然无法获得任何错误消息。

如何检查与mongodb的连接

使用新的3.0驱动程序ping服务器：

var database = client.GetDatabase("YourDbHere");
database.RunCommandAsync((Command<BsonDocument>)"{ping:1}")
        .Wait();

有一种ping方法：

var connectionString = "mongodb://localhost";
var client = new MongoClient(connectionString);
var server = client.GetServer();
server.Ping();
2.4.3的完整示例-其中"client.GetServer（）"不可用。基于"Paul Keister"的回答。 
client = new MongoClient("mongodb://localhost");
database = client.GetDatabase(mongoDbStr);
bool isMongoLive = database.RunCommandAsync((Command<BsonDocument>)"{ping:1}").Wait(1000);
if(isMongoLive)
{
    // connected
}
else
{
    // couldn't connect
}

我遇到了与OP相同的问题，并尝试了我在互联网上找到的每一个解决方案。。。好吧，没有一个能让我真正满意，所以我选择了一项研究，以找到一种可靠且响应迅速的方法来检查与MongoDB数据库服务器的连接是否有效。这样就不会在太长的时间段内阻止应用程序的同步执行。。。

以下是我的先决条件：

  • 连接检查的同步处理
  • 连接检查的短到极短时间片
  • 连接检查的可靠性
  • 如果可能，不抛出异常，也不触发超时

我在默认的localhost URL上提供了一个新的MongoDB安装（3.6版）：mongodb://localhost:27017。我还写下了另一个URL，那里没有MongoDB数据库服务器：mongodb://localhost:27071。

我也在使用C#驱动程序2.4.4，并且不使用遗留实现（MongoDB。Driver.legacy程序集）。

因此，我的期望是，当我检查到第一个URL的连接时，它应该为我提供到现有MongoDB服务器的活动连接的Ok，当我检测到第二个URL的链接时，它会为我提供不存在的MongoDB服务器。。。

使用IMongoDatabase.RunCommand方法查询服务器并导致服务器响应超时，因此不符合先决条件。此外，在超时之后，它会中断一个TimeoutException，这需要额外的异常处理。

这个实际的SO问题和这个SO问题提供了我解决方案所需的大部分启动信息。。。伙计们，非常感谢！

现在我的解决方案：

    private static bool ProbeForMongoDbConnection(string connectionString, string dbName)
    {
        var probeTask = 
                Task.Run(() =>
                            {
                                var isAlive = false;
                                var client = new MongoDB.Driver.MongoClient(connectionString);
                                for (var k = 0; k < 6; k++)
                                {
                                    client.GetDatabase(dbName);
                                    var server = client.Cluster.Description.Servers.FirstOrDefault();
                                    isAlive = (server != null && 
                                               server.HeartbeatException == null && 
                                               server.State == MongoDB.Driver.Core.Servers.ServerState.Connected);
                                    if (isAlive)
                                    {
                                        break;
                                    }
                                    System.Threading.Thread.Sleep(300);
                                }
                                return isAlive;
                            });
        probeTask.Wait();
        return probeTask.Result;
    }

这背后的想法是，在真正尝试访问服务器上的一些资源（例如数据库）之前，MongoDB服务器不会做出反应（而且似乎不存在）。但是仅仅检索一些资源是不够的，因为服务器在服务器的集群描述中仍然没有更新其状态。当再次检索资源时，此更新首先出现。从这个时间点开始，服务器具有有效的集群描述和内部的有效数据…

一般来说，在我看来，MongoDB服务器不会主动将其集群描述传播到所有连接的客户端。相反，当向服务器发出请求时，每个客户端都会收到描述。如果你们中的一些人对此有更多的信息，请确认或否认我对这个话题的理解。。。

现在，当我们针对一个无效的MongoDB服务器URL时，集群描述仍然无效，我们可以捕获并传递用于这种情况的可用信号。。。

因此以下语句（对于有效的URL）

// The admin database should exist on each MongoDB 3.6 Installation, if not explicitly deleted!
var isAlive = ProbeForMongoDbConnection("mongodb://localhost:27017", "admin");
Console.WriteLine("Connection to mongodb://localhost:27017 was " + (isAlive ? "successful!" : "NOT successful!"));

将打印出

连接到mongodb://localhost:27017成功了！

和语句（针对无效URL）

// The admin database should exist on each MongoDB 3.6 Installation, if not explicitly deleted!
isAlive = ProbeForMongoDbConnection("mongodb://localhost:27071", "admin");
Console.WriteLine("Connection to mongodb://localhost:27071 was " + (isAlive ? "successful!" : "NOT successful!"));

将打印出

连接到mongodb://localhost:27071没有成功！

这里有一个简单的扩展方法来ping mongodb服务器

public static class MongoDbExt
{
    public static bool Ping(this IMongoDatabase db, int secondToWait = 1)
    {
        if (secondToWait <= 0)
            throw new ArgumentOutOfRangeException("secondToWait", secondToWait, "Must be at least 1 second");
        return db.RunCommandAsync((Command<MongoDB.Bson.BsonDocument>)"{ping:1}").Wait(secondToWait * 1000);
    }
}

你可以这样使用：

var client = new MongoClient("yourConnectionString");
var database = client.GetDatabase("yourDatabase");
if (!database.Ping())
    throw new Exception("Could not connect to MongoDb");

这是一个使用try-catch方法的解决方案，

var database = client.GetDatabase("YourDbHere");
bool isMongoConnected;
try
{
     await database.RunCommandAsync((Command<BsonDocument>)"{ping:1}");
     isMongoConnected = true;
}
catch(Exception)
{
    isMongoConnected = false;
}

因此，当它无法连接到数据库时，它将抛出一个异常，我们可以在那里处理我们的bool标志。

如果要处理程序中的连接问题，可以使用ICluster.Description事件。

创建MongoClient后，它将继续在后台尝试连接，直到成功为止。

using MongoDB.Driver;
using MongoDB.Driver.Core.Clusters;
var mongoClient = new MongoClient("localhost")
mongoClient.Cluster.DescriptionChanged += Cluster_DescriptionChanged;
public void Cluster_DescriptionChanged(object sender, ClusterDescriptionChangedEventArgs e)
{
    switch (e.NewClusterDescription.State)
    {
        case ClusterState.Disconnected:
            break;
        case ClusterState.Connected:
            break;
    }
}
相关文章：