MongoDb 连接到副本集主要问题 C#
MongoDb Connect to Replica Set Primary Issue C#
如何取回主数据库的名称?假设数据库 3 是主要的
谢谢
var connString = "mongodb://database1,database2,database3/?replicaSet=repl";
var client = new MongoClient(connString);
var server = client.GetServer().Instances.FirstOrDefault(server => server.IsPrimary);
var address = server.Address;
您确实不应该自己连接到正确的服务器。 MongoDB 驱动程序会为您处理。
只需在连接字符串中指定所有服务器,驱动程序就会连接到其中一个并自行获取副本集的当前状态。然后,驱动程序会将写操作定向到当前主节点。读取操作可能定向到主服务器或任何其他服务器,具体取决于您指定的 read preference。
您可以在此处阅读有关形成副本集连接字符串的信息:https://docs.mongodb.org/v3.0/reference/connection-string/
查看了 MongoDB 驱动程序的源代码后,没有直接的方法从驱动程序本身获取主服务器的名称。但是,您可以通过使用 RunCommand
执行 {isMaster:1}
来查询 MOngoDB 中的服务器名称。然后,您可以从返回的 JSON 文档中解析主服务器。无论您连接到主服务器还是辅助服务器,此方法都有效。
var mongoClient = new MongoClient(clientSettings);
var testDB = mongoClient.GetDatabase("test");
var cmd = new BsonDocument("isMaster", "1");
var result = testDB.RunCommand<BsonDocument>(cmd);
var primaryServer = result.Where(x => x.Name == "primary").FirstOrDefault().Value.ToString();
感谢 Jaco 让我走上正轨,我通过执行以下操作解决了我的问题
public static string GetPrimaryDatabase()
{
var mongoClient = new MongoClient(clientSettings);
var server = mongoClient.GetServer();
var database = server.GetDatabase("test");
var cmd = new CommandDocument("isMaster", "1");
var result = database.RunCommand(cmd);
return result.Response.FirstOrDefault(
response => response.ToString().Contains("primary")).Value.ToString();
}
如何取回主数据库的名称?假设数据库 3 是主要的
谢谢
var connString = "mongodb://database1,database2,database3/?replicaSet=repl";
var client = new MongoClient(connString);
var server = client.GetServer().Instances.FirstOrDefault(server => server.IsPrimary);
var address = server.Address;
您确实不应该自己连接到正确的服务器。 MongoDB 驱动程序会为您处理。
只需在连接字符串中指定所有服务器,驱动程序就会连接到其中一个并自行获取副本集的当前状态。然后,驱动程序会将写操作定向到当前主节点。读取操作可能定向到主服务器或任何其他服务器,具体取决于您指定的 read preference。
您可以在此处阅读有关形成副本集连接字符串的信息:https://docs.mongodb.org/v3.0/reference/connection-string/
查看了 MongoDB 驱动程序的源代码后,没有直接的方法从驱动程序本身获取主服务器的名称。但是,您可以通过使用 RunCommand
执行 {isMaster:1}
来查询 MOngoDB 中的服务器名称。然后,您可以从返回的 JSON 文档中解析主服务器。无论您连接到主服务器还是辅助服务器,此方法都有效。
var mongoClient = new MongoClient(clientSettings);
var testDB = mongoClient.GetDatabase("test");
var cmd = new BsonDocument("isMaster", "1");
var result = testDB.RunCommand<BsonDocument>(cmd);
var primaryServer = result.Where(x => x.Name == "primary").FirstOrDefault().Value.ToString();
感谢 Jaco 让我走上正轨,我通过执行以下操作解决了我的问题
public static string GetPrimaryDatabase()
{
var mongoClient = new MongoClient(clientSettings);
var server = mongoClient.GetServer();
var database = server.GetDatabase("test");
var cmd = new CommandDocument("isMaster", "1");
var result = database.RunCommand(cmd);
return result.Response.FirstOrDefault(
response => response.ToString().Contains("primary")).Value.ToString();
}