手把手教你 MongoDB 的安裝與詳細使用（二）

時間 2020-07-21

標籤手把手 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 使用 (<) 和 (>) 查詢 - $lt 和 $gt

手把手教你 MongoDB 的安裝與詳細使用（一）node

http://www.ymq.io/2018/01/29/MongoDB-2/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：用於過濾數據，只輸出符合條件的文檔。$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 } } }
               ] );

$match用於獲取 likes 大於70小於或等於90記錄，而後將符合條件的記錄送到下一階段$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： { $dateToString: { format: , date: } }。

5. MongoDB 主從複製（副本集）

MongoDB複製是將數據同步在多個服務器的過程。

複製提供了數據的冗餘備份，並在多個服務器上存儲數據副本，提升了數據的可用性，並能夠保證數據的安全性。

複製還容許您從硬件故障和服務中斷中恢復數據。

官方文檔 https://docs.mongodb.com/manual/replication/

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...
Tutorials 教程：Pointhttps://www.tutorialspoint.co...
MongoDB 官網地址：https://www.mongodb.com
MongoDB 官方英文文檔：https://docs.mongodb.com/manual
MongoDB 各平臺下載地址：https://www.mongodb.com/downl...
MongoDB 安裝 https://docs.mongodb.com/manu...

Contact

做者：鵬磊
出處：http://www.ymq.io/2018/01/29/MongoDB-2
Email：admin@souyunku.com
版權歸做者全部，轉載請註明出處
Wechat：關注公衆號，搜雲庫，專一於開發技術的研究與知識分享

相關標籤/搜索

每日一句

每一个你不满意的现在，都有一个你没有努力的曾经。