MongoDB副本集故障转移

Question

我们有一个mongodb副本集，其中包含两个实例（127.0.0.1:27017-主要，127.0.0.1:27018-次要）和一个仲裁器（127.0.0.1:27019）。当我使用rs.steppdown（60）从主实例中退出时，它应该成为辅助实例，辅助实例应该成为主实例，所有写操作都应该在辅助实例中发生（退出后的主实例）。但在卸任后，我遇到了一个异常“无法将数据写入传输连接：远程主机强制关闭了一个现有连接”。

应用程序。Config有以下键：

<appSettings>
    <add key="mongoServerIP" value="127.0.0.1" />
    <add key="mongoServerPort" value="27017"/>
    <!--<add key="dbname" value="PSLRatingEngine"/>-->
    <add key="MongoDbDatabaseName" value="PSLRatingEngine" />
    <add key="testcollectionname" value="Test"/>
</appSettings>

C#代码：

    using MongoDB.Driver;
    using System;
    using System.Collections.Generic;
    using System.Configuration;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;

    namespace ReplicaSetTest
    {
        class Program
        {
            static void Main(string[] args)
            {
    string mongoserverip = ConfigurationManager.AppSettings["mongoServerIP"].ToString();

    int port =   Convert.ToInt32(ConfigurationManager.AppSettings["mongoServerPort"].ToString());

   string dbname = ConfigurationManager.AppSettings["MongoDbDatabaseName"].ToString();

 string customercollectionname = ConfigurationManager.AppSettings["testcollectionname"].ToString();
            try
            {
                MongoServerSettings settings = new MongoServerSettings();
               settings.Server = new MongoServerAddress(mongoserverip, port);


                    // Create server object to communicate with our server
                    MongoServer server = new MongoServer(settings);
                    // Get our database instance to reach collections and data
                    var db = server.GetDatabase(dbname);
                    // Get user collection reference
                    var collection = db.GetCollection(customercollectionname);
                    int i = 0;
                    while(true)
                    {

                        Employee emp = new Employee();
                        emp.EmpId = i + 1000;
                        Random r = new Random();
                        emp.Age =  r.Next(20, 70);
                        emp.Salary = r.NextDouble() * 100000;
                        emp.Name = "emp" + i;
                        emp.Dept = "Engineering";
                        collection.Insert<Employee>(emp);
                        i++;
                    }   
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }
            }
        }
    }

请让我知道，如果副本集的主实例发生任何变化，我如何通过C#代码自动从主实例切换到辅助实例。

Answer 1

假设您向主设备发送一个确认写入，然后主设备在部分完成写入后，但在完成并确认写入完成之前，被轨道离子炮炸毁。在这种情况下，您应该如何“自动从主设备切换到辅助设备”？这对连接和操作意味着什么？

选举需要几秒钟的时间，在选举期间没有可供写信的初选。在没有主控灯的情况下，驾驶员会做什么？当连接转到不再可用的节点时，它如何保持相同的连接？

关键是，故障转移期间应用程序可能会出现错误，您的应用程序需要能够处理这些错误。当主服务器出现故障时，MongoDB/驱动程序无法神奇地让一切正常工作，就像所有情况下都没有发生一样。在新的初选选出后，司机会自动切换到新的初选，然后就好像什么都没发生过一样。