手把手教你 MongoDB 的安装与详细使用（二）

时间 2019-12-07

标签手把手 mongodb 安装详细使用栏目 MongoDB 繁體版

原文原文链接

上一篇文章练习了，MongoDB 的如下操做html

安装 MongoDB 服务
链接 MongoDB
MongoDB 建立数据库
MongoDB 删除数据库
MongoDB 插入文档
MongoDB 删除文档
MongoDB 查询文档
MongoDB AND 条件
MongoDB OR 条件
MongoDB AND 和 OR 联合使用
MongoDB 条件操做符
MongoDB (>) 大于操做符 - $gt
MongoDB（>=）大于等于操做符 - $gte
MongoDB (<) 小于操做符 - $lt
MongoDB (<=) 小于操做符 - $lte
MongoDB 使用 (<) 和 (>) 查询 - gt

手把手教你 MongoDB 的安装与详细使用（一）node

www.ymq.io/2018/01/29/…sql

接下来继续mongodb

MongoDB Limit与Skip方法
MongoDB 排序
MongoDB 索引
MongoDB 聚合
MongoDB 主从复制（副本集）
MongoDB 自动故障转移

1. MongoDB Limit与Skip方法

Limit() 方法

MongoDB Limit() 方法shell

若是你须要在MongoDB中读取指定数量的数据记录，可使用MongoDB的Limit方法，limit()方法接受一个数字参数，该参数指定从MongoDB中读取的记录条数。数据库

插入测试数据ubuntu

db.col.insert({title: 'MongoDB-1'})
db.col.insert({title: 'MongoDB-2'})
db.col.insert({title: 'MongoDB-3'})
db.col.insert({title: 'MongoDB-4'})
复制代码

MongoDB Enterprise > db.col.find()
{ "_id" : ObjectId("5a6e8eaef14a3f270ba2dd0c"), "title" : "MongoDB-1" }
{ "_id" : ObjectId("5a6e8ec8f14a3f270ba2dd0d"), "title" : "MongoDB-2" }
{ "_id" : ObjectId("5a6e8ecbf14a3f270ba2dd0e"), "title" : "MongoDB-3" }
{ "_id" : ObjectId("5a6e8ed5f14a3f270ba2dd0f"), "title" : "MongoDB-4" }
MongoDB Enterprise >
复制代码

语法数组

limit()方法基本语法以下所示：安全

> db.COLLECTION_NAME.find().limit(NUMBER)
复制代码

以上实例为显示查询文档中的两条记录：服务器

MongoDB Enterprise > db.col.find().limit(2)
{ "_id" : ObjectId("5a6e8eaef14a3f270ba2dd0c"), "title" : "MongoDB-1" }
{ "_id" : ObjectId("5a6e8ec8f14a3f270ba2dd0d"), "title" : "MongoDB-2" }
MongoDB Enterprise > db.col.find({},{"title":1,_id:0}).limit(2)
{ "title" : "MongoDB-1" }
{ "title" : "MongoDB-2" }
MongoDB Enterprise >
复制代码

注：若是大家没有指定limit()方法中的参数则显示集合中的全部数据。

MongoDB Enterprise > db.col.find({},{"title":1,_id:0}).limit()
{ "title" : "MongoDB-1" }
{ "title" : "MongoDB-2" }
{ "title" : "MongoDB-3" }
{ "title" : "MongoDB-4" }
复制代码

Skip() 方法

咱们除了可使用limit()方法来读取指定数量的数据外，还可使用skip()方法来跳过指定数量的数据，skip方法一样接受一个数字参数做为跳过的记录条数。语法

skip() 方法脚本语法格式以下：

> db.COLLECTION_NAME.find().limit(NUMBER).skip(NUMBER)
复制代码

实例

以上实例只会显示第二条文档数据

MongoDB Enterprise > db.col.find({},{"title":1,_id:0}).limit(1).skip(1)
{ "title" : "MongoDB-2" }
MongoDB Enterprise >
复制代码

注:skip()方法默认参数为 0

2. MongoDB 排序

MongoDB sort()方法

在MongoDB中使用使用sort()方法对数据进行排序，sort()方法能够经过参数指定排序的字段

使用 1 和 -1 来指定排序的方式，其中 1 为升序排列，而-1是用于降序排列。

语法

sort()方法基本语法以下所示：

> db.COLLECTION_NAME.find().sort({KEY:1})
复制代码

col 集合中的数据以下：

MongoDB Enterprise > db.col.find()
{ "_id" : ObjectId("5a6e8eaef14a3f270ba2dd0c"), "title" : "MongoDB-1" }
{ "_id" : ObjectId("5a6e8ec8f14a3f270ba2dd0d"), "title" : "MongoDB-2" }
{ "_id" : ObjectId("5a6e8ecbf14a3f270ba2dd0e"), "title" : "MongoDB-3" }
{ "_id" : ObjectId("5a6e8ed5f14a3f270ba2dd0f"), "title" : "MongoDB-4" }
MongoDB Enterprise >
复制代码

其中 1 为升序排列，而-1是用于降序排列

如下实例演示了 col 集合中的数据按字段 title 的降序排列：

MongoDB Enterprise > db.col.find({},{"title":1,_id:0}).sort({"title":-1})
{ "title" : "MongoDB-4" }
{ "title" : "MongoDB-3" }
{ "title" : "MongoDB-2" }
{ "title" : "MongoDB-1" }
MongoDB Enterprise >
复制代码

注：若是没有指定sort()方法的排序方式，默认按照文档的升序排列。

3. MongoDB 索引

索引一般可以极大的提升查询的效率，若是没有索引，MongoDB在读取数据时必须扫描集合中的每一个文件并选取那些符合查询条件的记录。

这种扫描全集合的查询效率是很是低的，特别在处理大量的数据时，查询能够要花费几十秒甚至几分钟，这对网站的性能是很是致命的。

索引是特殊的数据结构，索引存储在一个易于遍历读取的数据集合中，索引是对数据库表中一列或多列的值进行排序的一种结构

ensureIndex() 方法

MongoDB使用 ensureIndex() 方法来建立索引。

语法

ensureIndex()方法基本语法格式以下所示：

> db.COLLECTION_NAME.ensureIndex({KEY:1})
复制代码

语法中 Key 值为你要建立的索引字段，1为指定按升序建立索引，若是你想按降序来建立索引指定为-1便可。

实例

> db.COLLECTION_NAME.ensureIndex({KEY:1})
复制代码

语法中 Key 值为你要建立的索引字段，1为指定按升序建立索引，若是你想按降序来建立索引指定为-1便可。

实例

MongoDB Enterprise > db.col.ensureIndex({"title":1})
{
	"createdCollectionAutomatically" : false,
	"numIndexesBefore" : 1,
	"numIndexesAfter" : 2,
	"ok" : 1
}
MongoDB Enterprise > 
复制代码

db.col.insert({title: 'MongoDB 教程', 
    description: 'MongoDB 是一个 Nosql 数据库',
    by: '搜云库教程-专一于开发技术的研究与知识分享',
    url: 'http://www.souyunku.com',
    tags: ['mongodb', 'database', 'NoSQL'],
    likes: 100
})
复制代码

ensureIndex() 方法中你也能够设置使用多个字段建立索引（关系型数据库中称做复合索引）。

MongoDB Enterprise > db.col.ensureIndex({"title":1,"description":1})
{
	"createdCollectionAutomatically" : false,
	"numIndexesBefore" : 3,
	"numIndexesAfter" : 4,
	"ok" : 1
}
复制代码

ensureIndex() 接收可选参数，可选参数列表以下：

实例

在后台建立索引：

建索引过程会阻塞其它数据库操做，background可指定之后台方式建立索引，即增长 "background" 可选参数。 "background" 默认值为false。

MongoDB Enterprise > db.col.ensureIndex({"url":1}, {background: true})
{
	"createdCollectionAutomatically" : false,
	"numIndexesBefore" : 5,
	"numIndexesAfter" : 6,
	"ok" : 1
}
MongoDB Enterprise > 

复制代码

4. MongoDB 聚合

MongoDB 聚合

MongoDB中聚合(aggregate)主要用于处理数据(诸如统计平均值,求和等)，并返回计算后的数据结果。有点相似sql语句中的 count(*)。

aggregate() 方法

删除以前的测试数据

MongoDB Enterprise > db.col.remove({})
WriteResult({ "nRemoved" : 5 })
MongoDB Enterprise >
复制代码

插入新的测试数据

db.col.insert({
	title: 'MongoDB 教程',
	description: 'MongoDB 是一个 Nosql 数据库',
	by_user: 'penglei',
	url: 'http://www.souyunku.com',
	tags: ['mongodb', 'database', 'NoSQL'],
	likes: 100
})
db.col.insert({
	title: 'MongoDB 教程',
	description: 'MongoDB 是一个 Nosql 数据库',
	by_user: 'penglei',
	url: 'http://www.souyunku.com',
	tags: ['mongodb', 'database', 'NoSQL'],
	likes: 200
})
db.col.insert({
	title: 'MongoDB 教程',
	description: 'MongoDB 是一个 Nosql 数据库',
	by_user: 'penglei',
	url: 'http://www.souyunku.com',
	tags: ['mongodb', 'database', 'NoSQL'],
	likes: 300
})
复制代码

MongoDB Enterprise > db.col.find()
{ "_id" : ObjectId("5a6ebfab5326a260464a4072"), "title" : "MongoDB 教程", "description" : "MongoDB 是一个 Nosql 数据库", "by_user" : "penglei", "url" : "http://www.souyunku.com", "tags" : [ "mongodb", "database", "NoSQL" ], "likes" : 100 }
{ "_id" : ObjectId("5a6ebfab5326a260464a4073"), "title" : "MongoDB 教程", "description" : "MongoDB 是一个 Nosql 数据库", "by_user" : "penglei", "url" : "http://www.souyunku.com", "tags" : [ "mongodb", "database", "NoSQL" ], "likes" : 200 }
{ "_id" : ObjectId("5a6ebfab5326a260464a4074"), "title" : "MongoDB 教程", "description" : "MongoDB 是一个 Nosql 数据库", "by_user" : "penglei", "url" : "http://www.souyunku.com", "tags" : [ "mongodb", "database", "NoSQL" ], "likes" : 300 }
MongoDB Enterprise > 
复制代码

MongoDB中聚合的方法使用aggregate()。

语法

aggregate() 方法的基本语法格式以下所示：

> db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION)
复制代码

MongoDB Enterprise > db.col.aggregate([{$group : {_id : "$by_user", num_tutorials : {$sum : 1}}}])
{
	"_id": "penglei",
	"num_tutorials": 3
}
MongoDB Enterprise > db.col.aggregate([{$group : {_id : "$by_user", totle : {$sum : 1}}}])
{
	"_id": "penglei",
	"totle": 3
}
MongoDB Enterprise > 
复制代码

以上实例相似sql语句：select by_user, count(*) from col group by by_user

在上面的例子中，咱们经过字段by_user字段对数据进行分组，并计算by_user字段相同值的总和。

下表展现了一些聚合的表达式:

管道的概念

管道在Unix和Linux中通常用于将当前命令的输出结果做为下一个命令的参数。

MongoDB的聚合管道将MongoDB文档在一个管道处理完毕后将结果传递给下一个管道处理。管道操做是能够重复的。

表达式：处理输入文档并输出。表达式是无状态的，只能用于计算当前聚合管道的文档，不能处理其它的文档。

这里咱们介绍一下聚合框架中经常使用的几个操做：

$project：修改输入文档的结构。能够用来重命名、增长或删除域，也能够用于建立计算结果以及嵌套文档。
match使用MongoDB的标准查询操做。
$limit：用来限制MongoDB聚合管道返回的文档数。
$skip：在聚合管道中跳过指定数量的文档，并返回余下的文档。
$unwind：将文档中的某一个数组类型字段拆分红多条，每条包含数组中的一个值。
$group：将集合中的文档分组，可用于统计结果。
$sort：将输入文档排序后输出。
$geoNear：输出接近某一地理位置的有序文档。

管道操做符实例

一、$project实例

MongoDB Enterprise > db.col.aggregate(
    { $project : {
        title : 1 ,
        by_user : 1 ,
    }}
 );
 
{ "_id" : ObjectId("5a6ebfab5326a260464a4072"), "title" : "MongoDB 教程", "by_user" : "penglei" }
{ "_id" : ObjectId("5a6ebfab5326a260464a4073"), "title" : "MongoDB 教程", "by_user" : "penglei" }
{ "_id" : ObjectId("5a6ebfab5326a260464a4074"), "title" : "MongoDB 教程", "by_user" : "penglei" }
MongoDB Enterprise > 
复制代码

这样的话结果中就只还有_id,tilte和by_user三个字段了，默认状况下_id字段是被包含的，若是要想不包含_id话能够这样:

MongoDB Enterprise > db.col.aggregate(
    { $project : {
        _id : 0 ,
        title : 1 ,
        by_user : 1
    }});
复制代码

{ "title" : "MongoDB 教程", "by_user" : "penglei" }
{ "title" : "MongoDB 教程", "by_user" : "penglei" }
{ "title" : "MongoDB 教程", "by_user" : "penglei" }
复制代码

2.$match实例

db.col.aggregate( [
				{ $match : { likes : { $gt : 90, $lte : 200 } } },
				{ $group: { _id: null, count: { $sum: 1 } } }
			   ] );
复制代码

group管道操做符进行处理。

MongoDB Enterprise > db.col.aggregate([{$group : {_id : "$by_user", num_tutorial : {$sum : 1}}}])
{ "_id" : "penglei", "num_tutorial" : 3 }
MongoDB Enterprise >
复制代码

以上实例相似sql语句：

select by_user as _id, count(*) as num_tutorial from mycol group by by_user
复制代码

按日、按月、按年、按周、按小时、按分钟聚合操做以下：

db.getCollection('m_msg_tb').aggregate(
[
    {$match:{m_id:10001,mark_time:{$gt:new Date(2017,8,0)}}},
    {$group: {
       _id: {$dayOfMonth:'$mark_time'},
        pv: {$sum: 1}
        }
    },
    {$sort: {"_id": 1}}
])
复制代码

时间关键字以下：

$dayOfYear: 返回该日期是这一年的第几天（整年 366 天）。
$dayOfMonth: 返回该日期是这一个月的第几天（1到31）。
$dayOfWeek: 返回的是这个周的星期几（1：星期日，7：星期六）。
$year: 返回该日期的年份部分。
$month：返回该日期的月份部分（ 1 到 12）。
$week：返回该日期是所在年的第几个星期（ 0 到 53）。
$hour：返回该日期的小时部分。
$minute: 返回该日期的分钟部分。
$second: 返回该日期的秒部分（以0到59之间的数字形式返回日期的第二部分，但能够是60来计算闰秒）。
$millisecond：返回该日期的毫秒部分（ 0 到 999）。
dateToString: { format: , date: } }。

5. MongoDB 主从复制（副本集）

MongoDB复制是将数据同步在多个服务器的过程。

复制提供了数据的冗余备份，并在多个服务器上存储数据副本，提升了数据的可用性，并能够保证数据的安全性。

复制还容许您从硬件故障和服务中断中恢复数据。

官方文档 docs.mongodb.com/manual/repl…

5.1 什么是复制?

保障数据的安全性
数据高可用性 (24*7)
灾难恢复
无需停机维护（如备份，重建索引，压缩）
分布式读取数据

5.2 MongoDB复制原理

mongodb的复制至少须要两个节点。其中一个是主节点，负责处理客户端请求，其他的都是从节点，负责复制主节点上的数据。

mongodb各个节点常见的搭配方式为：一主一从、一主多从。

主节点记录在其上的全部操做oplog，从节点按期轮询主节点获取这些操做，而后对本身的数据副本执行这些操做，从而保证从节点的数据与主节点一致。

MongoDB复制结构图以下所示：

以上结构图中，客户端从主节点读取数据，在客户端写入数据到主节点时，主节点与从节点进行数据交互保障数据的一致性。

5.3 副本集特征

N 个节点的集群
任何节点可做为主节点
全部写入操做都在主节点上
自动故障转移
自动恢复

5.4 MongoDB副本集设置

一、关闭正在运行的MongoDB服务器。

service mongod stop
复制代码

2.节点建点

首先须要去你选择的mongodb数据文件存放的文件夹新建三个数据库，用来模拟三台不通的机器，博主的路径以下

mkdir -p /data/db/node1
mkdir -p /data/db/node2
mkdir -p /data/db/node3
复制代码

3.启动三个数据库（dbpath），而且端口（－－port 1000x），集群名称（－－replSet gabriel），关闭日志选项（－－nojournal），守护进程方式启动,会自动拉起（－－fork），日志目录（－－logpath）

mongod --dbpath /data/db/node1 --port 10001 --replSet gabriel --nojournal --fork --logpath /data/db/node1.log
mongod --dbpath /data/db/node2 --port 10002 --replSet gabriel --nojournal --fork --logpath /data/db/node2.log
mongod --dbpath /data/db/node3 --port 10003 --replSet gabriel --nojournal --fork --logpath /data/db/node3.log
复制代码

4.顺便链接一个服务器，作初始化操做，这里博主连入10001端口

终端下进入

mongo localhost:10001
复制代码

进入后输入初始化方法

MongoDB Enterprise gabriel:OTHER> rs.initiate({_id:"gabriel",members:[
{_id:1,host:"localhost:10001"},
{_id:2,host:"localhost:10002"},
{_id:3,host:"localhost:10003"},
]})
复制代码

收到以下信息就成功了。

{
	"ok" : 1,
	"operationTime" : Timestamp(1517221411, 1),
	"$clusterTime" : {
		"clusterTime" : Timestamp(1517221411, 1),
		"signature" : {
			"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
			"keyId" : NumberLong(0)
		}
	}
}
MongoDB Enterprise gabriel:OTHER>
复制代码

此时会发现终端上的输出已经有了变化。

//从单个一个
>
//变成了
gabriel:OTHER>
复制代码

5.查询状态

MongoDB Enterprise gabriel:OTHER> rs.status()
{
	"set" : "gabriel",
	"date" : ISODate("2018-01-29T10:33:21.227Z"),
	"myState" : 1,
	"term" : NumberLong(1),
	"heartbeatIntervalMillis" : NumberLong(2000),
	"optimes" : {
		"lastCommittedOpTime" : {
			"ts" : Timestamp(1517221984, 1),
			"t" : NumberLong(1)
		},
		"readConcernMajorityOpTime" : {
			"ts" : Timestamp(1517221984, 1),
			"t" : NumberLong(1)
		},
		"appliedOpTime" : {
			"ts" : Timestamp(1517221994, 1),
			"t" : NumberLong(1)
		},
		"durableOpTime" : {
			"ts" : Timestamp(1517221994, 1),
			"t" : NumberLong(1)
		}
	},
	"members" : [
		{
			"_id" : 1,
			"name" : "localhost:10001",
			"health" : 1,
			"state" : 1,
			"stateStr" : "PRIMARY",
			"uptime" : 659,
			"optime" : {
				"ts" : Timestamp(1517221994, 1),
				"t" : NumberLong(1)
			},
			"optimeDate" : ISODate("2018-01-29T10:33:14Z"),
			"electionTime" : Timestamp(1517221422, 1),
			"electionDate" : ISODate("2018-01-29T10:23:42Z"),
			"configVersion" : 1,
			"self" : true
		},
		{
			"_id" : 2,
			"name" : "localhost:10002",
			"health" : 1,
			"state" : 2,
			"stateStr" : "SECONDARY",
			"uptime" : 589,
			"optime" : {
				"ts" : Timestamp(1517221994, 1),
				"t" : NumberLong(1)
			},
			"optimeDurable" : {
				"ts" : Timestamp(1517221984, 1),
				"t" : NumberLong(1)
			},
			"optimeDate" : ISODate("2018-01-29T10:33:14Z"),
			"optimeDurableDate" : ISODate("2018-01-29T10:33:04Z"),
			"lastHeartbeat" : ISODate("2018-01-29T10:33:20.972Z"),
			"lastHeartbeatRecv" : ISODate("2018-01-29T10:33:19.923Z"),
			"pingMs" : NumberLong(0),
			"syncingTo" : "localhost:10001",
			"configVersion" : 1
		},
		{
			"_id" : 3,
			"name" : "localhost:10003",
			"health" : 1,
			"state" : 2,
			"stateStr" : "SECONDARY",
			"uptime" : 589,
			"optime" : {
				"ts" : Timestamp(1517221994, 1),
				"t" : NumberLong(1)
			},
			"optimeDurable" : {
				"ts" : Timestamp(1517221984, 1),
				"t" : NumberLong(1)
			},
			"optimeDate" : ISODate("2018-01-29T10:33:14Z"),
			"optimeDurableDate" : ISODate("2018-01-29T10:33:04Z"),
			"lastHeartbeat" : ISODate("2018-01-29T10:33:20.972Z"),
			"lastHeartbeatRecv" : ISODate("2018-01-29T10:33:19.921Z"),
			"pingMs" : NumberLong(0),
			"syncingTo" : "localhost:10001",
			"configVersion" : 1
		}
	],
	"ok" : 1,
	"operationTime" : Timestamp(1517221994, 1),
	"$clusterTime" : {
		"clusterTime" : Timestamp(1517221994, 1),
		"signature" : {
			"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
			"keyId" : NumberLong(0)
		}
	}
}
复制代码

在返回中，参数set后面为集群名称，每一个members下面能够看到他们各自的状况，其中stateStr是角色，主节点为（PRIMARY）。

6.进入主节点插入数据，进入从节点查看数据

博主主节点在10001接口

mongo localhost:10001
复制代码

插入数据

MongoDB Enterprise gabriel:PRIMARY> use test
switched to db test
复制代码

db.col.insert({title: 'MongoDB 教程', 
    description: 'MongoDB 是一个 Nosql 数据库',
    by: '搜云库教程-专一于开发技术的研究与知识分享',
    url: 'http://www.souyunku.com',
    tags: ['mongodb', 'database', 'NoSQL'],
    likes: 100
})
复制代码

MongoDB Enterprise gabriel:PRIMARY> db.col.find()
{ "_id" : ObjectId("5a6ef998525d903d07a00cdf"), "title" : "MongoDB 教程", "description" : "MongoDB 是一个 Nosql 数据库", "by" : "搜云库教程-专一于开发技术的研究与知识分享", "url" : "http://www.souyunku.com", "tags" : [ "mongodb", "database", "NoSQL" ], "likes" : 100 }
MongoDB Enterprise gabriel:PRIMARY> 
复制代码

博主切换从节点10002

mongo localhost:10002
复制代码

切换到从节点，你会发现使用show dbs 会报错，是由于尚未开启权限，输入rs.slaveOk();就能够顺利访问了。

MongoDB Enterprise gabriel:SECONDARY> show dbs
2018-01-29T10:40:37.362+0000 E QUERY    [thread1] Error: listDatabases failed:{
	"operationTime" : Timestamp(1517222434, 1),
	"ok" : 0,
	"errmsg" : "not master and slaveOk=false",
	"code" : 13435,
	"codeName" : "NotMasterNoSlaveOk",
	"$clusterTime" : {
		"clusterTime" : Timestamp(1517222434, 1),
		"signature" : {
			"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
			"keyId" : NumberLong(0)
		}
	}
} :
_getErrorWithCode@src/mongo/shell/utils.js:25:13
Mongo.prototype.getDBs@src/mongo/shell/mongo.js:65:1
shellHelper.show@src/mongo/shell/utils.js:813:19
shellHelper@src/mongo/shell/utils.js:703:15
@(shellhelp2):1:1
MongoDB Enterprise gabriel:SECONDARY> 
复制代码

MongoDB Enterprise gabriel:SECONDARY> rs.slaveOk()
复制代码

再次查看

MongoDB Enterprise gabriel:SECONDARY> show dbs
admin   0.000GB
config  0.000GB
local   0.000GB
test    0.000GB
MongoDB Enterprise gabriel:SECONDARY> 
复制代码

切到test 库，查看数据已经同步过来了

MongoDB Enterprise gabriel:SECONDARY> use test
switched to db test
MongoDB Enterprise gabriel:SECONDARY> db.col.find()
{ "_id" : ObjectId("5a6ef998525d903d07a00cdf"), "title" : "MongoDB 教程", "description" : "MongoDB 是一个 Nosql 数据库", "by" : "搜云库教程-专一于开发技术的研究与知识分享", "url" : "http://www.souyunku.com", "tags" : [ "mongodb", "database", "NoSQL" ], "likes" : 100 }
MongoDB Enterprise gabriel:SECONDARY> 
复制代码

以上就是简单的主从复制创建过程，如今已经能够在从服务器看到主服务器插入的数据了。

切换从节点10003 同样的问题

删除从节点

rs.remove('ip:port')
复制代码

关闭主服务器后，再从新启动，会发现原来的从服务器变为了从服务器，新启动的服务器（原来的从服务器）变为了从服务器

6. MongoDB 自动故障转移

首先经过 rs.status() 查看，能够看到主节点是10001，主节点"name" : "localhost:10001", "stateStr" : "PRIMARY" 接下来中止 10001 主节点，测试故障切换

MongoDB Enterprise gabriel:PRIMARY>  rs.status()
{
	"set" : "gabriel",
	"date" : ISODate("2018-01-30T02:39:58.468Z"),
	"myState" : 1,
	"term" : NumberLong(1),
	"heartbeatIntervalMillis" : NumberLong(2000),
	"optimes" : {
		"lastCommittedOpTime" : {
			"ts" : Timestamp(1517279986, 1),
			"t" : NumberLong(1)
		},
		"readConcernMajorityOpTime" : {
			"ts" : Timestamp(1517279986, 1),
			"t" : NumberLong(1)
		},
		"appliedOpTime" : {
			"ts" : Timestamp(1517279996, 1),
			"t" : NumberLong(1)
		},
		"durableOpTime" : {
			"ts" : Timestamp(1517279996, 1),
			"t" : NumberLong(1)
		}
	},
	"members" : [
		{
			"_id" : 1,
			"name" : "localhost:10001",
			"health" : 1,
			"state" : 1,
			"stateStr" : "PRIMARY",
			"uptime" : 58656,
			"optime" : {
				"ts" : Timestamp(1517279996, 1),
				"t" : NumberLong(1)
			},
			"optimeDate" : ISODate("2018-01-30T02:39:56Z"),
			"electionTime" : Timestamp(1517221422, 1),
			"electionDate" : ISODate("2018-01-29T10:23:42Z"),
			"configVersion" : 1,
			"self" : true
		},
		{
			"_id" : 2,
			"name" : "localhost:10002",
			"health" : 1,
			"state" : 2,
			"stateStr" : "SECONDARY",
			"uptime" : 58586,
			"optime" : {
				"ts" : Timestamp(1517279996, 1),
				"t" : NumberLong(1)
			},
			"optimeDurable" : {
				"ts" : Timestamp(1517279986, 1),
				"t" : NumberLong(1)
			},
			"optimeDate" : ISODate("2018-01-30T02:39:56Z"),
			"optimeDurableDate" : ISODate("2018-01-30T02:39:46Z"),
			"lastHeartbeat" : ISODate("2018-01-30T02:39:58.289Z"),
			"lastHeartbeatRecv" : ISODate("2018-01-30T02:39:57.220Z"),
			"pingMs" : NumberLong(0),
			"syncingTo" : "localhost:10001",
			"configVersion" : 1
		},
		{
			"_id" : 3,
			"name" : "localhost:10003",
			"health" : 0,
			"state" : 8,
			"stateStr" : "(not reachable/healthy)",
			"uptime" : 0,
			"optime" : {
				"ts" : Timestamp(0, 0),
				"t" : NumberLong(-1)
			},
			"optimeDurable" : {
				"ts" : Timestamp(0, 0),
				"t" : NumberLong(-1)
			},
			"optimeDate" : ISODate("1970-01-01T00:00:00Z"),
			"optimeDurableDate" : ISODate("1970-01-01T00:00:00Z"),
			"lastHeartbeat" : ISODate("2018-01-30T02:39:58.304Z"),
			"lastHeartbeatRecv" : ISODate("2018-01-30T02:39:21.208Z"),
			"pingMs" : NumberLong(0),
			"lastHeartbeatMessage" : "Connection refused",
			"configVersion" : -1
		}
	],
	"ok" : 1,
	"operationTime" : Timestamp(1517279996, 1),
	"$clusterTime" : {
		"clusterTime" : Timestamp(1517279996, 1),
		"signature" : {
			"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
			"keyId" : NumberLong(0)
		}
	}
}
MongoDB Enterprise gabriel:PRIMARY>
复制代码

链接到主节点

mongo localhost:10001
复制代码

关闭主节点

mongo localhost:10001
复制代码

显示全部数据库

MongoDB Enterprise gabriel:PRIMARY> show dbs
admin   0.000GB
config  0.000GB
local   0.000GB
test    0.000GB
复制代码

切换到admin

MongoDB Enterprise gabriel:PRIMARY> use admin
switched to db admin
复制代码

中止数据库，必须进入 admin 库

MongoDB Enterprise gabriel:PRIMARY> db.shutdownServer()
复制代码

响应

2018-01-30T02:51:34.503+0000 I NETWORK  [thread1] trying reconnect to localhost:10001 (127.0.0.1) failed
2018-01-30T02:51:35.398+0000 I NETWORK  [thread1] Socket recv() Connection reset by peer 127.0.0.1:10001
2018-01-30T02:51:35.398+0000 I NETWORK  [thread1] SocketException: remote: (NONE):0 error: SocketException socket exception [RECV_ERROR] server [127.0.0.1:10001] 
2018-01-30T02:51:35.399+0000 I NETWORK  [thread1] reconnect localhost:10001 (127.0.0.1) failed failed 
2018-01-30T02:51:35.404+0000 I NETWORK  [thread1] trying reconnect to localhost:10001 (127.0.0.1) failed
2018-01-30T02:51:35.404+0000 W NETWORK  [thread1] Failed to connect to 127.0.0.1:10001, in(checking socket for error after poll), reason: Connection refused
2018-01-30T02:51:35.404+0000 I NETWORK  [thread1] reconnect localhost:10001 (127.0.0.1) failed failed 
MongoDB Enterprise >
复制代码

查看是否真的中止了,发现已经没有10001 节点进程了

root@souyunku-2:# ps -ef | grep mongo
root      5554     1  0 Jan29 ?        00:03:34 mongod --dbpath /data/db/node2 --port 10002 --replSet gabriel --nojournal --fork --logpath /data/db/node2.log
root     12284     1  0 02:43 ?        00:00:02 mongod --dbpath /data/db/node3 --port 10003 --replSet gabriel --nojournal --fork --logpath /data/db/node3.log
root     12436  5132  0 02:53 pts/1    00:00:00 grep --color=auto mongo
root@souyunku-2:# netstat -nltp
Active Internet connections (only servers)
Proto Recv-Q Send-Q Local Address           Foreign Address         State       PID/Program name
tcp        0      0 127.0.0.1:10002         0.0.0.0:*               LISTEN      5554/mongod     
tcp        0      0 127.0.0.1:10003         0.0.0.0:*               LISTEN      12284/mongod          
root@souyunku-2:/data/db#
复制代码

查看是否故障专业

root@souyunku-2:# mongo localhost:10001
复制代码

查看主从状态

MongoDB Enterprise gabriel:SECONDARY> rs.status()
{
	"set" : "gabriel",
	"date" : ISODate("2018-01-30T02:56:48.074Z"),
	"myState" : 2,
	"term" : NumberLong(2),
	"syncingTo" : "localhost:10003",
	"heartbeatIntervalMillis" : NumberLong(2000),
	"optimes" : {
		"lastCommittedOpTime" : {
			"ts" : Timestamp(1517280995, 1),
			"t" : NumberLong(2)
		},
		"readConcernMajorityOpTime" : {
			"ts" : Timestamp(1517280995, 1),
			"t" : NumberLong(2)
		},
		"appliedOpTime" : {
			"ts" : Timestamp(1517281005, 1),
			"t" : NumberLong(2)
		},
		"durableOpTime" : {
			"ts" : Timestamp(1517280995, 1),
			"t" : NumberLong(2)
		}
	},
	"members" : [
		{
			"_id" : 1,
			"name" : "localhost:10001",
			"health" : 0,
			"state" : 8,
			"stateStr" : "(not reachable/healthy)",
			"uptime" : 0,
			"optime" : {
				"ts" : Timestamp(0, 0),
				"t" : NumberLong(-1)
			},
			"optimeDurable" : {
				"ts" : Timestamp(0, 0),
				"t" : NumberLong(-1)
			},
			"optimeDate" : ISODate("1970-01-01T00:00:00Z"),
			"optimeDurableDate" : ISODate("1970-01-01T00:00:00Z"),
			"lastHeartbeat" : ISODate("2018-01-30T02:56:47.605Z"),
			"lastHeartbeatRecv" : ISODate("2018-01-30T02:51:34.519Z"),
			"pingMs" : NumberLong(0),
			"lastHeartbeatMessage" : "Connection refused",
			"configVersion" : -1
		},
		{
			"_id" : 2,
			"name" : "localhost:10002",
			"health" : 1,
			"state" : 2,
			"stateStr" : "SECONDARY",
			"uptime" : 59660,
			"optime" : {
				"ts" : Timestamp(1517281005, 1),
				"t" : NumberLong(2)
			},
			"optimeDate" : ISODate("2018-01-30T02:56:45Z"),
			"syncingTo" : "localhost:10003",
			"configVersion" : 1,
			"self" : true
		},
		{
			"_id" : 3,
			"name" : "localhost:10003",
			"health" : 1,
			"state" : 1,
			"stateStr" : "PRIMARY",
			"uptime" : 784,
			"optime" : {
				"ts" : Timestamp(1517281005, 1),
				"t" : NumberLong(2)
			},
			"optimeDurable" : {
				"ts" : Timestamp(1517281005, 1),
				"t" : NumberLong(2)
			},
			"optimeDate" : ISODate("2018-01-30T02:56:45Z"),
			"optimeDurableDate" : ISODate("2018-01-30T02:56:45Z"),
			"lastHeartbeat" : ISODate("2018-01-30T02:56:46.486Z"),
			"lastHeartbeatRecv" : ISODate("2018-01-30T02:56:47.147Z"),
			"pingMs" : NumberLong(0),
			"electionTime" : Timestamp(1517280703, 1),
			"electionDate" : ISODate("2018-01-30T02:51:43Z"),
			"configVersion" : 1
		}
	],
	"ok" : 1,
	"operationTime" : Timestamp(1517281005, 1),
	"$clusterTime" : {
		"clusterTime" : Timestamp(1517281005, 1),
		"signature" : {
			"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
			"keyId" : NumberLong(0)
		}
	}
}
MongoDB Enterprise gabriel:SECONDARY> 
复制代码

发现 "name" : "localhost:10001","stateStr" : "(not reachable/healthy)", 健康状态已是“没法访问状态了”

主节点已经切换成 10003 节点了

"_id" : 3,
"name" : "localhost:10003",
"health" : 1,
"state" : 1,
"stateStr" : "PRIMARY",
复制代码

重启节点10001

mongod --dbpath /data/db/node1 --port 10001 --replSet gabriel --nojournal --fork --logpath /data/db/node1.log
复制代码

参考：

Runoob 教程：http://www.runoob.com/mongodb/mongodb-tutorial.html
Tutorials 教程：Pointhttps://www.tutorialspoint.com/mongodb/mongodb_advantages.htm
MongoDB 官网地址：https://www.mongodb.com
MongoDB 官方英文文档：https://docs.mongodb.com/manual
MongoDB 各平台下载地址：https://www.mongodb.com/download-center#community
MongoDB 安装 https://docs.mongodb.com/manual/tutorial/install-mongodb-enterprise-on-ubuntu

Contact

做者：鹏磊
出处：www.ymq.io/2018/01/29/…
Email：admin@souyunku.com
版权归做者全部，转载请注明出处
Wechat：关注公众号，搜云库，专一于开发技术的研究与知识分享