MongoDB-3.4搭建副本集

搭建副本集

1：首先创建3台虚拟机作为配置环境

IP1：192.168.101.175

IP2：192.168.101.176

IP3：192.168.101.177

2.下载MongoDB 3.4版本，没有的文件或者文件夹请自行创建。

3.编辑配置文件E:mongodb-3.4confmongo.conf

IP1：192.168.101.177

#数据库数据存放目录
dbpath=E:mongodb-3.4data
#数据库日志存放目录
logpath=E:mongodb-3.4logMongoDB.log
#以追加的方式记录日志
logappend=true
#启用日志文件，默认启用
journal=true 
#端口号 默认为27017
port=27017
#副本集名称
replSet=rs1/192.168.101.176:27017

IP2：192.168.101.176

#数据库数据存放目录
dbpath=E:mongodb-3.4data
#数据库日志存放目录
logpath=E:mongodb-3.4logMongoDB.log
#以追加的方式记录日志
logappend=true
#启用日志文件，默认启用
journal=true 
#端口号 默认为27017
port=27017
#副本集名称
replSet=rs1/192.168.101.177:27017

IP3：192.168.101.175

#数据库数据存放目录
dbpath=E:mongodb-3.4data
#数据库日志存放目录
logpath=E:mongodb-3.4logMongoDB.log
#以追加的方式记录日志
logappend=true
#启用日志文件，默认启用
journal=true 
#端口号 默认为27017
port=27017
#副本集名称
replSet=rs1/192.168.101.176:27017,192.168.101.177:27017

 4.添加Windows服务

cmd命令切换到目录E:mongodb-3.4in

输入以下命令

mongod --install -f  E:mongodb-3.4confmongo.conf

  启动MongoDB服务：net start MongoDB

  停止MongoDB服务：net stop MongoDB

  删除MongoDB服务：sc delete MongoDB

5.重启服务

依次重启192.168.101.177、192.168.101.176、192.168.101.175服务

6.搭建副本集

在IP1：192.168.101.177上启动mongod

#使用admin数据库
use admin
#定义副本集配置
config = { _id:"rs1", 
           members:[
                     {_id:0,host:"192.168.101.177:27017"},
                     {_id:1,host:"192.168.101.176:27017"},
                     {_id:2,host:"192.168.101.175:27017"}
                   ]
         }

#初始化副本集配置
rs.initiate(config)

7.验证配置的副本集rs.status()

{
        "set" : "rs1",
        "date" : ISODate("2018-02-01T08:12:43.079Z"),
        "myState" : 1,
        "term" : NumberLong(1),
        "heartbeatIntervalMillis" : NumberLong(2000),
        "optimes" : {
                "lastCommittedOpTime" : {
                        "ts" : Timestamp(1517472756, 1),
                        "t" : NumberLong(1)
                },
                "appliedOpTime" : {
                        "ts" : Timestamp(1517472756, 1),
                        "t" : NumberLong(1)
                },
                "durableOpTime" : {
                        "ts" : Timestamp(1517472756, 1),
                        "t" : NumberLong(1)
                }
        },
        "members" : [
                {
                        "_id" : 0,
                        "name" : "192.168.101.177:27017",
                        "health" : 1,
                        "state" : 1,
                        "stateStr" : "PRIMARY",
                        "uptime" : 714,
                        "optime" : {
                                "ts" : Timestamp(1517472756, 1),
                                "t" : NumberLong(1)
                        },
                        "optimeDate" : ISODate("2018-02-01T08:12:36Z"),
                        "electionTime" : Timestamp(1517472425, 1),
                        "electionDate" : ISODate("2018-02-01T08:07:05Z"),
                        "configVersion" : 1,
                        "self" : true
                },
                {
                        "_id" : 1,
                        "name" : "192.168.101.176:27017",
                        "health" : 1,
                        "state" : 2,
                        "stateStr" : "SECONDARY",
                        "uptime" : 348,
                        "optime" : {
                                "ts" : Timestamp(1517472756, 1),
                                "t" : NumberLong(1)
                        },
                        "optimeDurable" : {
                                "ts" : Timestamp(1517472756, 1),
                                "t" : NumberLong(1)
                        },
                        "optimeDate" : ISODate("2018-02-01T08:12:36Z"),
                        "optimeDurableDate" : ISODate("2018-02-01T08:12:36Z"),
                        "lastHeartbeat" : ISODate("2018-02-01T08:12:42.251Z"),
                        "lastHeartbeatRecv" : ISODate("2018-02-01T08:12:42.537Z"
),
                        "pingMs" : NumberLong(1),
                        "syncingTo" : "192.168.101.177:27017",
                        "configVersion" : 1
                },
                {
                        "_id" : 2,
                        "name" : "192.168.101.175:27017",
                        "health" : 1,
                        "state" : 2,
                        "stateStr" : "SECONDARY",
                        "uptime" : 348,
                        "optime" : {
                                "ts" : Timestamp(1517472756, 1),
                                "t" : NumberLong(1)
                        },
                        "optimeDurable" : {
                                "ts" : Timestamp(1517472756, 1),
                                "t" : NumberLong(1)
                        },
                        "optimeDate" : ISODate("2018-02-01T08:12:36Z"),
                        "optimeDurableDate" : ISODate("2018-02-01T08:12:36Z"),
                        "lastHeartbeat" : ISODate("2018-02-01T08:12:42.270Z"),
                        "lastHeartbeatRecv" : ISODate("2018-02-01T08:12:42.634Z"
),
                        "pingMs" : NumberLong(1),
                        "syncingTo" : "192.168.101.177:27017",
                        "configVersion" : 1
                }
        ],
        "ok" : 1
}

 8.在192.168.101.177（Primary）上读写数据

db.users.insert({_id:1,name:"mf",age:24})

9.检查副本集数据同步情况

模拟primary节点宕机的情况

可以看到**已经成了primary节点。主界面宕机导致了整个集群发生一次election，实现了failover。等**恢复了会自动成为secondary节点：

修改配置

可以随时修改副本集的配置：添加、删除、修改已有的成员。很多常用的操作都有对应的shell函数。

rs.add("host:port") => 添加一个节点

rs.remove("host:port") => 删除成员

rs.config() => 查看副本集配置

rs.reconfig(config) => 根据config配置对象，重新配置副本集

注意：重新配置副本集时， 主节点会先退化为备份节点, 以便接受新的配置。然后会恢复。这段时间，副本集中可能没有主节点，之后会恢复

连接复本集的正确姿势

引用命名空间： MongoDB.Driver.dll
              MongoDB.Bson.dll
MongoClientSettings set = new MongoClientSettings();
List<MongoServerAddress> servers = new List<MongoServerAddress>();
servers.Add(new MongoServerAddress("192.168.101.175", 27017));
servers.Add(new MongoServerAddress("192.168.101.176", 27017));
servers.Add(new MongoServerAddress("192.168.101.177", 27017));
set.Servers = servers;

//设置副本集名称
set.ReplicaSetName = "rs1";
//设置超时时间为3秒
set.ConnectTimeout = new TimeSpan(0, 0, 0, 3, 0);


MongoClient client = new MongoClient(set);
MongoServer server = client.GetServer();
MongoDatabase db = server.GetDatabase("test");
MongoCollection coll = db.GetCollection("test");

//插入
BsonDocument bd = new BsonDocument();
bd.Add("name", "zhanjindong");
bd.Add("age", 23);
bd.Add("sex", "男D");

coll.Insert(bd);

//读取
QueryDocument qd = new QueryDocument();
qd.Add("name", "zhanjindong");
qd.Add("age", 23);
qd.Add("sex", "男D");

BsonDocument rd = coll.FindOneAs<BsonDocument>(qd);

Console.WriteLine(rd.ToString());