Mongodb主从复制/ 副本集/分片集群介绍

以你之姓@ 2024-02-19 16:03 95阅读 0赞

在 MongoDB 中,有两种数据冗余方式,一种 是 Master-Slave 模式（主从复制）,一种是 Replica Sets 模式（副本集）。

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 </td> 
 <td> <code>Mongodb一共有三种集群搭建的方式：</code> <code>Replica Set（副本集）、</code> <code>Sharding（切片）</code> <code>Master-Slaver（主从）【目前已不推荐使用了！！！】</code> &nbsp; <code>其中，Sharding集群也是三种集群中最复杂的。</code> <code>副本集比起主从可以实现故障转移！！非常使用！</code> &nbsp; <code>mongoDB目前已不推荐使用主从模式，取而代之的是副本集模式。副本集其实一种互为主从的关系，可理解为主主。</code> <code>副本集指将数据复制，多份保存，不同服务器保存同一份数据，在出现故障时自动切换。对应的是数据冗余、备份、镜像、读写分离、高可用性等关键词；</code> <code>而分片则指为处理大量数据，将数据分开存储，不同服务器保存不同的数据，它们的数据总和即为整个数据集。追求的是高性能。</code> &nbsp; <code>在生产环境中，通常是这两种技术结合使用，分片+副本集。</code> </td> 
 </tr> 
 </tbody> 
</table>

**一、先说说mongodb主从复制配置**

主从复制是[MongoDB][]最常用的复制方式,也是一个简单的[数据库][Link 1]同步备份的集群技术,这种方式很灵活.可用于备份,故障恢复,读扩展等.  
最基本的设置方式就是建立一个主节点和一个或多个从节点,每个从节点要知道主节点的地址。采用双机备份后主节点挂掉了后从节点可以接替主机继续服务。所以这种模式比单节点的高可用性要好很多。

![907596-20170603163125914-453548285.png][]

配置主从复制的注意点

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 </td> 
 <td> <code>1）在数据库集群中要明确的知道谁是主服务器,主服务器只有一台.</code> <code>2）从服务器要知道自己的数据源也就是对应的主服务是谁.</code> <code>3）--master用来确定主服务器,--slave 和 --</code><code>source</code> <code>来控制从服务器</code> </td> 
 </tr> 
 </tbody> 
</table>

可以在mongodb.conf配置文件里指明主从关系，这样启动mongodb的时候只要跟上配置文件就行，就不需要通过--master和--slave来指明主从了。

下面简单记录下Mongodb主从复制的部署过程

![907596-20170603163930680-935037407.png][]

主从复制的原理

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 </td> 
 <td> <code>在主从结构中，主节点的操作记录成为oplog（operation log）。oplog存储在一个系统数据库</code><code>local</code><code>的集合oplog.$main中，这个集合的每个文档都代表主节点上执行的一个操作。 </code> <code>从服务器会定期从主服务器中获取oplog记录，然后在本机上执行！对于存储oplog的集合，MongoDB采用的是固定集合，也就是说随着操作过多，新的操作会覆盖旧的操作！</code> &nbsp; <code>主从复制的其他设置项</code> <code>--only&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 从节点指定复制某个数据库,默认是复制全部数据库 </code> <code>--slavedelay&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 从节点设置主数据库同步数据的延迟(单位是秒) </code> <code>--fastsync&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 从节点以主数据库的节点快照为节点启动从数据库 </code> <code>--autoresync&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 从节点如果不同步则从新同步数据库(即选择当通过热添加了一台从服务器之后，从服务器选择是否更新主服务器之间的数据) </code> <code>--oplogSize&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 主节点设置oplog的大小(主节点操作记录存储到</code><code>local</code><code>的oplog中)</code> </td> 
 </tr> 
 </tbody> 
</table>

在上面slave-node从节点的local数据库中，存在一个集合sources。这个集合就保存了这个服务器的主服务器是谁

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 </td> 
 <td> <code>[root@slave-node mongodb]</code><code># mongo 182.48.115.236:27017</code> <code>......</code> <code>&gt; show dbs</code> <code>admin&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 0.000GB</code> <code>local</code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <code>0.000GB</code> <code>master_slave&nbsp; 0.000GB</code> <code>wangshibo&nbsp;&nbsp;&nbsp;&nbsp; 0.000GB</code> <code>&gt; use </code><code>local</code> <code>switched to db </code><code>local</code> <code>&gt; show collections</code> <code>me</code> <code>sources</code> <code>startup_log</code> <code>&gt; db.sources.</code><code>find</code><code>()</code> <code>{ </code><code>"_id"</code> <code>: ObjectId(</code><code>"593277a5105051e5648605a3"</code><code>), </code><code>"host"</code> <code>: </code><code>"182.48.115.238:27017"</code><code>, </code><code>"source"</code> <code>: </code><code>"main"</code><code>, </code><code>"syncedTo"</code> <code>: Timestamp(1496481652, 1) }</code> <code>&gt;</code> </td> 
 </tr> 
 </tbody> 
</table>

**二、Mongodb副本集（Replica Sets） （可以参考：[搭建高可用mongodb集群][mongodb]）**

mongodb 不推荐主从复制,推荐建立副本集(Replica Set)来保证1个服务挂了,可以有其他服务顶上,程序正常运行,几个服务的数据都是一样的,后台自动同步。主从复制其实就是一个单副本的应用，没有很好的扩展性饿容错性。然而副本集具有多个副本保证了容错性，就算一个副本挂掉了还有很多个副本存在，并且解决了"主节点挂掉后，整个集群内会自动切换"的问题。副本集比传统的Master-Slave主从复制有改进的地方就是它可以进行故障的自动转移,如果我们停掉复制集中的一个成员,那么剩余成员会再自动选举一个成员,作为主库。  
Replica Set 使用的是 n 个 mongod 节点,构建具备自动的容错功能(auto-failover),自动恢复的(auto-recovery)的高可用方案。使用 Replica Set 来实现读写分离。通过在连接时指定或者在主库指定 slaveOk,由Secondary 来分担读的压力,Primary 只承担写操作。对于 Replica Set 中的 secondary 节点默认是不可读的。

1）关于副本集的概念

2）副本集的结构及原理

MongoDB 的副本集不同于以往的主从模式。  
在集群Master故障的时候,副本集可以自动投票,选举出新的Master,并引导其余的Slave服务器连接新的Master,而这个过程对于应用是透明的。可以说MongoDB的副本集  
是自带故障转移功能的主从复制。  
相对于传统主从模式的优势  
传统的主从模式,需要手工指定集群中的 Master。如果 Master 发生故障,一般都是人工介入,指定新的 Master。 这个过程对于应用一般不是透明的,往往伴随着应用重  
新修改配置文件,重启应用服务器等。而 MongoDB 副本集,集群中的任何节点都可能成为 Master 节点。一旦 Master 节点故障,则会在其余节点中选举出一个新的 Master 节点。 并引导剩余节点连接到新的 Master 节点。这个过程对于应用是透明的。

![907596-20170604001737664-2049802701.png][]

一个副本集即为服务于同一数据集的多个 MongoDB 实例,其中一个为主节点,其余的都为从节点。主节 点上能够完成读写操作,从节点仅能用于读操作。主节点需要记录所有改变数据库状态的操作,这些记录 保存在 oplog 中,这个文件存储在 local 数据库,各个从节点通过此 oplog 来复制数据并应用于本地,保持 本地的数据与主节点的一致。oplog 具有幂等性,即无论执行几次其结果一致,这个比 mysql 的二进制日 志更好用。  
集群中的各节点还会通过传递心跳信息来检测各自的健康状况。当主节点故障时,多个从节点会触发一次 新的选举操作,并选举其中的一个成为新的主节点(通常谁的优先级更高,谁就是新的主节点),心跳信 息默认每 2 秒传递一次。

![907596-20170604001821227-991171740.png][]

![907596-20170604013129524-1035525546.png][]

客户端连接到副本集后，不关心具体哪一台机器是否挂掉。主服务器负责整个副本集的读写，副本集定期同步数据备份。一旦主节点挂掉，副本节点就会选举一个新的主服务器。这一切对于应用服务器不需要关心。

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 </td> 
 <td> <code>心跳检测：</code> <code>整个集群需要保持一定的通信才能知道哪些节点活着哪些节点挂掉。mongodb节点会向副本集中的其他节点每两秒就会发送一次pings包，如果其他节点在10秒钟</code> <code>之内没有返回就标示为不能访问。每个节点内部都会维护一个状态映射表，表明当前每个节点是什么角色、日志时间戳等关键信息。如果是主节点，除了维护映射表</code> <code>外还需要检查自己能否和集群中内大部分节点通讯，如果不能则把自己降级为secondary只读节点。</code> &nbsp; <code>数据同步</code> <code>副本集同步分为初始化同步和keep复制。初始化同步指全量从主节点同步数据，如果主节点数据量比较大同步时间会比较长。而keep复制指初始化同步过后，节点</code> <code>之间的实时同步一般是增量同步。初始化同步不只是在第一次才会被处罚，有以下两种情况会触发：</code> <code>1）secondary第一次加入，这个是肯定的。</code> <code>2）secondary落后的数据量超过了oplog的大小，这样也会被全量复制。</code> </td> 
 </tr> 
 </tbody> 
</table>

![907596-20170604012944508-1544910602.png][]

副本集中的副本节点在主节点挂掉后通过心跳机制检测到后，就会在集群内发起主节点的选举机制，自动选举出一位新的主服务器。

副本集包括三种节点:主节点、从节点、仲裁节点。

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 </td> 
 <td> <code>1）主节点负责处理客户端请求,读、写数据, 记录在其上所有操作的 oplog;</code> <code>2）从节点定期轮询主节点获取这些操作,然后对自己的数据副本执行这些操作,从而保证从节点的数据与主节点一致。默认情况下,从节点不支持外部读取,但可以设置;</code> <code>&nbsp;&nbsp;&nbsp;</code><code>副本集的机制在于主节点出现故障的时候,余下的节点会选举出一个新的主节点,从而保证系统可以正常运行。</code> <code>3）仲裁节点不复制数据,仅参与投票。由于它没有访问的压力,比较空闲,因此不容易出故障。由于副本集出现故障的时候,存活的节点必须大于副本集节点总数的一半,</code> <code>&nbsp;&nbsp;&nbsp;</code><code>否则无法选举主节点,或者主节点会自动降级为从节点,整个副本集变为只读。因此,增加一个不容易出故障的仲裁节点,可以增加有效选票,降低整个副本集不可用的</code> <code>&nbsp;&nbsp;&nbsp;</code><code>风险。仲裁节点可多于一个。也就是说只参与投票，不接收复制的数据，也不能成为活跃节点。</code> </td> 
 </tr> 
 </tbody> 
</table>

官方推荐MongoDB副本节点最少为3台， 建议副本集成员为奇数，最多12个副本节点,最多7个节点参与选举。限制副本节点的数量,主要是因为一个集群中过多的副本节点,增加了复制的成本,反而拖累了集群  
的整体性能。 太多的副本节点参与选举,也会增加选举的时间。而官方建议奇数的节点,是为了避免脑裂 的发生。

3）副本集的工作流程

4）副本集选举的过程和注意点

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 </td> 
 <td> <code>Mongodb副本集选举采用的是Bully算法，这是一种协调者(主节点)竞选算法,主要思想是集群的每个成员都可以声明它是主节点并通知其他节点。</code> <code>别的节点可以选择接受这个声称或是拒绝并进入主节点竞争，被其他所有节点接受的节点才能成为主节点。 </code> <code>节点按照一些属性来判断谁应该胜出，这个属性可以是一个静态 ID,也可以是更新的度量像最近一次事务ID(最新的节点会胜出) </code> &nbsp; <code>副本集的选举过程大致如下:</code> <code>1）得到每个服务器节点的最后操作时间戳。每个 mongodb 都有 oplog 机制会记录本机的操作,方便和主服 务器进行对比数据是否同步还可以用于错误恢复。</code> <code>2）如果集群中大部分服务器 down 机了,保留活着的节点都为 secondary 状态并停止,不选举了。</code> <code>3）如果集群中选举出来的主节点或者所有从节点最后一次同步时间看起来很旧了,停止选举等待人来操作。</code> <code>4）如果上面都没有问题就选择最后操作时间戳最新(保证数据是最新的)的服务器节点作为主节点。</code> &nbsp; &nbsp; <code>副本集选举的特点：</code> <code>选举还有个前提条件,参与选举的节点数量必须大于副本集总节点数量的一半（建议副本集成员为奇数。最多12个副本节点,最多7个节点参与选举）</code> <code>如果已经小于一半了所有节点保持只读状态。集合中的成员一定要有大部分成员(即超过一半数量)是保持正常在线状态,3个成员的副本集,需要至少2个从属节点是正常状态。</code> <code>如果一个从属节点挂掉,那么当主节点down掉 产生故障切换时,由于副本集中只有一个节点是正常的,少于一半,则选举失败。</code> <code>4个成员的副本集,则需要3个成员是正常状态(先关闭一个从属节点,然后再关闭主节点,产生故障切换,此时副本集中只有2个节点正常,则无法成功选举出新主节点)。</code> </td> 
 </tr> 
 </tbody> 
</table>

5）副本集数据过程

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 </td> 
 <td> <code>Primary节点写入数据，Secondary通过读取Primary的oplog得到复制信息，开始复制数据并且将复制信息写入到自己的oplog。如果某个操作失败，则备份节点</code> <code>停止从当前数据源复制数据。如果某个备份节点由于某些原因挂掉了，当重新启动后，就会自动从oplog的最后一个操作开始同步，同步完成后，将信息写入自己的</code> <code>oplog，由于复制操作是先复制数据，复制完成后再写入oplog，有可能相同的操作会同步两份，不过MongoDB在设计之初就考虑到这个问题，将oplog的同一个操作</code> <code>执行多次，与执行一次的效果是一样的。简单的说就是：</code> &nbsp; <code>当Primary节点完成数据操作后，Secondary会做出一系列的动作保证数据的同步：</code> <code>1）检查自己</code><code>local</code><code>库的oplog.rs集合找出最近的时间戳。</code> <code>2）检查Primary节点</code><code>local</code><code>库oplog.rs集合，找出大于此时间戳的记录。</code> <code>3）将找到的记录插入到自己的oplog.rs集合中，并执行这些操作。</code> &nbsp; <code>副本集的同步和主从同步一样，都是异步同步的过程，不同的是副本集有个自动故障转移的功能。其原理是：slave端从primary端获取日志，然后在自己身上完全顺序</code> <code>的执行日志所记录的各种操作（该日志是不记录查询操作的），这个日志就是</code><code>local</code><code>数据 库中的oplog.rs表，默认在64位机器上这个表是比较大的，占磁盘大小的5%，</code> <code>oplog.rs的大小可以在启动参数中设 定：--oplogSize 1000,单位是M。</code> &nbsp; <code>注意：在副本集的环境中，要是所有的Secondary都宕机了，只剩下Primary。最后Primary会变成Secondary，不能提供服务。</code> </td> 
 </tr> 
 </tbody> 
</table>

6）MongoDB 同步延迟问题

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 </td> 
 <td> <code>当你的用户抱怨修改过的信息不改变,删除掉的数据还在显示,你掐指一算,估计是数据库主从不同步。与其他提供数据同步的数据库一样,MongoDB 也会遇到同步延迟的问题,</code> <code>在MongoDB的Replica Sets模式中,同步延迟也经常是困扰使用者的一个大问题。</code> &nbsp; <code>什么是同步延迟?</code> <code>首先,要出现同步延迟,必然是在有数据同步的场合,在 MongoDB 中,有两种数据冗余方式,一种是Master-Slave 模式,一种是Replica Sets模式。这两个模式本质上都是</code> <code>在一个节点上执行写操作, 另外的节点将主节点上的写操作同步到自己这边再进行执行。在MongoDB中,所有写操作都会产生 oplog,oplog 是每修改一条数据都会生成一条,如果你采用一个批量 update 命令更新了 N 多条数据, 那么抱歉,oplog 会有很多条,而不是一条。所以同步延迟就是写操作在主节点上执行完后,从节点还没有把 oplog 拿过来再执行一次。而这个写操作的量越大,主节点与从节点的差别也就越大,同步延迟也就越大了。</code> &nbsp; <code>同步延迟带来的问题</code> <code>首先,同步操作通常有两个效果,一是读写分离,将读操作放到从节点上来执行,从而减少主节点的 压力。对于大多数场景来说,读多写少是基本特性,所以这一点是很有用的。</code> <code>另一个作用是数据备份, 同一个写操作除了在主节点执行之外,在从节点上也同样执行,这样我们就有多份同样的数据,一旦 主节点的数据因为各种天灾人祸无法恢复的时候,我们至少还有从节点可以依赖。但是主从延迟问题 可能会对上面两个效果都产生不好的影响。</code> &nbsp; <code>如果主从延迟过大,主节点上会有很多数据更改没有同步到从节点上。这时候如果主节点故障,就有 两种情况:</code> <code>1）主节点故障并且无法恢复,如果应用上又无法忍受这部分数据的丢失,我们就得想各种办法将这部 数据更改找回来,再写入到从节点中去。可以想象,即使是有可能,那这也绝对是一件非常恶心的活。</code> <code>2）主节点能够恢复,但是需要花的时间比较长,这种情况如果应用能忍受,我们可以直接让从节点提 供服务,只是对用户来说,有一段时间的数据丢失了,而如果应用不能接受数据的不一致,那么就只能下线整个业务,等主节点恢复后再提供服务了。</code> &nbsp; <code>如果你只有一个从节点,当主从延迟过大时,由于主节点只保存最近的一部分 oplog,可能会导致从 节点青黄不接,不得不进行 resync 操作,全量从主节点同步数据。</code> <code>带来的问题是：当从节点全量同步的时候,实际只有主节点保存了完整的数据,这时候如果主节点故障,很可能全 部数据都丢掉了。</code> </td> 
 </tr> 
 </tbody> 
</table>

**7）Mongodb副本集环境部署记录**

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 </td> 
 <td> <code>1）机器环境</code> <code>182.48.115.236&nbsp;&nbsp;&nbsp; master-node(主节点)</code> <code>182.48.115.237&nbsp;&nbsp;&nbsp; slave-node1(从节点)</code> <code>182.48.115.238&nbsp;&nbsp;&nbsp; slave-node2(从节点)</code> &nbsp; <code>MongoDB 安装目录:</code><code>/usr/local/mongodb</code> <code>MongoDB 数据库目录:</code><code>/usr/local/mongodb/data</code> <code>MongoDB 日志目录:</code><code>/usr/local/mongodb/log/mongo</code><code>.log </code> <code>MongoDB 配置文件:</code><code>/usr/local/mongodb/mongodb</code><code>.conf</code> &nbsp; <code>mongodb安装可以参考：http:</code><code>//www</code><code>.cnblogs.com</code><code>/kevingrace/p/5752382</code><code>.html</code> &nbsp; <code>对以上三台服务器部署Mongodb的副本集功能，定义副本集名称为:hqmongodb</code> <code>关闭三台服务器的iptables防火墙和selinux</code> &nbsp; <code>2）确保三台副本集服务器上的配置文件完全相同（即三台机器的mongodb.conf配置一样，除了配置文件中绑定的ip不一样）。下面操作在三台节点机上都要执行：</code> &nbsp; <code>编写配置文件</code> <code>[root@master-node ~]</code><code># cat /usr/local/mongodb/mongodb.conf</code> <code>port=27017</code> <code>bind_ip = 182.48.115.236&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>//</code><code>这个最好配置成本机的ip地址。否则后面进行副本集初始化的时候可能会失败！&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code> <code>dbpath=</code><code>/usr/local/mongodb/data</code> <code>logpath=</code><code>/usr/local/mongodb/log/mongo</code><code>.log</code> <code>pidfilepath=</code><code>/usr/local/mongodb/mongo</code><code>.pid</code> <code>fork=</code><code>true</code> <code>logappend=</code><code>true</code> <code>shardsvr=</code><code>true</code> <code>directoryperdb=</code><code>true</code> <code>#auth=true</code> <code>#keyFile =/usr/local/mongodb/keyfile</code> <code>replSet =hqmongodb</code> &nbsp; <code>编写启动脚本（各个节点需要将脚本中的ip改为本机自己的ip地址）</code> <code>[root@master-node ~]</code><code># cat /usr/local/mongodb/mongodb.conf</code> <code>port=27017</code> <code>dbpath=</code><code>/usr/local/mongodb/data</code> <code>logpath=</code><code>/usr/local/mongodb/log/mongo</code><code>.log</code> <code>pidfilepath=</code><code>/usr/local/mongodb/mongo</code><code>.pid</code> <code>fork=</code><code>true</code> <code>logappend=</code><code>true</code> <code>shardsvr=</code><code>true</code> <code>directoryperdb=</code><code>true</code> <code>#auth=true</code> <code>#keyFile =/usr/local/mongodb/keyfile</code> <code>replSet =hqmongodb</code> <code>[root@master-node ~]</code><code># cat /etc/init.d/mongodb</code> <code>#!/bin/sh</code> <code># chkconfig: - 64 36</code> <code># description:mongod</code> <code>case</code> <code>$1 </code><code>in</code> <code>start)</code> <code>/usr/local/mongodb/bin/mongod</code> <code>--maxConns 20000 --config </code><code>/usr/local/mongodb/mongodb</code><code>.conf</code> <code>;;</code> <code>stop)</code> <code>/usr/local/mongodb/bin/mongo</code> <code>182.48.115.236:27017</code><code>/admin</code> <code>--</code><code>eval</code> <code>"db.shutdownServer()"</code> <code>#/usr/local/mongodb/bin/mongo 182.48.115.236:27017/admin --eval "db.auth('system', '123456');db.shutdownServer()"</code> <code>;;</code> <code>status)</code> <code>/usr/local/mongodb/bin/mongo</code> <code>182.48.115.236:27017</code><code>/admin</code> <code>--</code><code>eval</code> <code>"db.stats()"</code> <code>#/usr/local/mongodb/bin/mongo 182.48.115.236:27017/admin --eval "db.auth('system', '123456');db.stats()"</code> <code>;; </code><code>esac</code> &nbsp; <code>启动mongodb</code> <code>[root@master-node ~]</code><code># ulimit -SHn 655350</code> &nbsp; <code>[root@master-node ~]</code><code># /etc/init.d/mongodb start</code> <code>about to fork child process, waiting </code><code>until</code> <code>server is ready </code><code>for</code> <code>connections.</code> <code>forked process: 28211</code> <code>child process started successfully, parent exiting</code> <code>[root@master-node ~]</code><code># ps -ef|grep mongodb</code> <code>root&nbsp;&nbsp;&nbsp;&nbsp; 28211&nbsp;&nbsp;&nbsp;&nbsp; 1&nbsp; 2 00:30 ?&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 00:00:00 </code><code>/usr/local/mongodb/bin/mongod</code> <code>--maxConns 20000 --config </code><code>/usr/local/mongodb/mongodb</code><code>.conf</code> <code>root&nbsp;&nbsp;&nbsp;&nbsp; 28237 27994&nbsp; 0 00:30 pts</code><code>/2</code>&nbsp;&nbsp;&nbsp; <code>00:00:00 </code><code>grep</code> <code>mongodb</code> &nbsp; <code>[root@master-node ~]</code><code># lsof -i:27017</code> <code>COMMAND&nbsp;&nbsp; PID USER&nbsp;&nbsp; FD&nbsp;&nbsp; TYPE DEVICE SIZE</code><code>/OFF</code> <code>NODE NAME</code> <code>mongod&nbsp; 28211 root&nbsp;&nbsp;&nbsp; 7u&nbsp; IPv4 684206&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 0t0&nbsp; TCP *:27017 (LISTEN)</code> <code>－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－</code> <code>如果启动mongodb的时候报错如下：</code> <code>about to fork child process, waiting </code><code>until</code> <code>server is ready </code><code>for</code> <code>connections.</code> <code>forked process: 14229</code> <code>ERROR: child process failed, exited with error number 100</code> &nbsp; <code>这算是一个Mongod 启动的一个常见错误，非法关闭的时候，lock 文件没有干掉，第二次启动的时候检查到有lock 文件的时候，就报这个错误了。</code> <code>解决方法：进入mongod启动时指定的data目录下删除lock文件，然后执行</code><code>"./mongod&nbsp; --repair"</code><code>就行了。即</code> <code># rm -rf /usr/local/mongodb/data/mongod.lock&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //由于我的测试环境下没有数据，我将data数据目录下的文件全部清空，然后--repair</code> <code># /usr/local/mongodb/bin/mongod --repair</code> &nbsp; <code>然后再启动mongodb就ok了！</code> <code>－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－</code> &nbsp; <code>3）对master-node主节点进行配置（182.48.115.236）&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>//</code><code>其实，刚开始这三个节点中的任何一个都可以用来初始化为开始的主节点。这里选择以master-node为主节点</code> <code>[root@master-node ~]</code><code># mongo 182.48.115.236:27017&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //登陆到mongodb数据库中执行下面命令操作。由于配置文件中绑定了ip，所以要用这个绑定的ip登陆</code> <code>....</code> &nbsp; <code>3.1）初始化副本集,设置本机为主节点 PRIMARY</code> &nbsp; <code>&gt; rs.initiate()</code> <code>{ </code> <code>&nbsp;&nbsp;</code><code>"info2"</code> <code>: </code><code>"no configuration specified. Using a default configuration for the set"</code><code>,</code> <code>&nbsp;&nbsp;</code><code>"me"</code> <code>: </code><code>"182.48.115.236:27017"</code><code>,</code> <code>&nbsp;&nbsp;</code><code>"ok"</code> <code>: 1</code> <code>}</code> <code>hqmongodb:OTHER&gt; rs.conf()</code> <code>{ </code> <code>&nbsp;&nbsp;</code><code>"_id"</code> <code>: </code><code>"hqmongodb"</code><code>,</code> <code>&nbsp;&nbsp;</code><code>"version"</code> <code>: 1,</code> <code>&nbsp;&nbsp;</code><code>"protocolVersion"</code> <code>: NumberLong(1),</code> <code>&nbsp;&nbsp;</code><code>"members"</code> <code>: [</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"_id"</code> <code>: 0,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"host"</code> <code>: </code><code>"182.48.115.236:27017"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"arbiterOnly"</code> <code>: </code><code>false</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"buildIndexes"</code> <code>: </code><code>true</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"hidden"</code> <code>: </code><code>false</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"priority"</code> <code>: 1,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"tags"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"slaveDelay"</code> <code>: NumberLong(0),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"votes"</code> <code>: 1</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>],</code> <code>&nbsp;&nbsp;</code><code>"settings"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"chainingAllowed"</code> <code>: </code><code>true</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"heartbeatIntervalMillis"</code> <code>: 2000,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"heartbeatTimeoutSecs"</code> <code>: 10,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"electionTimeoutMillis"</code> <code>: 10000,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"catchUpTimeoutMillis"</code> <code>: 2000,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"getLastErrorModes"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"getLastErrorDefaults"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"w"</code> <code>: 1,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"wtimeout"</code> <code>: 0</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"replicaSetId"</code> <code>: ObjectId(</code><code>"5932f142a55dc83eca86ea86"</code><code>)</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>}</code> &nbsp; <code>3.2）添加副本集从节点。（发现在执行上面的两个命令后，前缀已经改成</code><code>"hqmongodb:PRIMARY"</code><code>了，即已经将其自己设置为主节点 PRIMARY了）</code> <code>hqmongodb:PRIMARY&gt; rs.add(</code><code>"182.48.115.237:27017"</code><code>)</code> <code>{ </code><code>"ok"</code> <code>: 1 }</code> <code>hqmongodb:PRIMARY&gt; rs.add(</code><code>"182.48.115.238:27017"</code><code>)</code> <code>{ </code><code>"ok"</code> <code>: 1 }</code> &nbsp; <code>3.3）设置节点优先级</code> <code>hqmongodb:PRIMARY&gt; cfg = rs.conf()&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>//</code><code>查看节点顺序</code> <code>{ </code> <code>&nbsp;&nbsp;</code><code>"_id"</code> <code>: </code><code>"hqmongodb"</code><code>,</code> <code>&nbsp;&nbsp;</code><code>"version"</code> <code>: 3,</code> <code>&nbsp;&nbsp;</code><code>"protocolVersion"</code> <code>: NumberLong(1),</code> <code>&nbsp;&nbsp;</code><code>"members"</code> <code>: [</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"_id"</code> <code>: 0,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"host"</code> <code>: </code><code>"182.48.115.236:27017"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"arbiterOnly"</code> <code>: </code><code>false</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"buildIndexes"</code> <code>: </code><code>true</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"hidden"</code> <code>: </code><code>false</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"priority"</code> <code>: 1,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"tags"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"slaveDelay"</code> <code>: NumberLong(0),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"votes"</code> <code>: 1</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"_id"</code> <code>: 1,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"host"</code> <code>: </code><code>"182.48.115.237:27017"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"arbiterOnly"</code> <code>: </code><code>false</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"buildIndexes"</code> <code>: </code><code>true</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"hidden"</code> <code>: </code><code>false</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"priority"</code> <code>: 1,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"tags"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"slaveDelay"</code> <code>: NumberLong(0),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"votes"</code> <code>: 1</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"_id"</code> <code>: 2,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"host"</code> <code>: </code><code>"182.48.115.238:27017"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"arbiterOnly"</code> <code>: </code><code>false</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"buildIndexes"</code> <code>: </code><code>true</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"hidden"</code> <code>: </code><code>false</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"priority"</code> <code>: 1,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"tags"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"slaveDelay"</code> <code>: NumberLong(0),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"votes"</code> <code>: 1</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>],</code> <code>&nbsp;&nbsp;</code><code>"settings"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"chainingAllowed"</code> <code>: </code><code>true</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"heartbeatIntervalMillis"</code> <code>: 2000,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"heartbeatTimeoutSecs"</code> <code>: 10,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"electionTimeoutMillis"</code> <code>: 10000,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"catchUpTimeoutMillis"</code> <code>: 2000,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"getLastErrorModes"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"getLastErrorDefaults"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"w"</code> <code>: 1,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"wtimeout"</code> <code>: 0</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"replicaSetId"</code> <code>: ObjectId(</code><code>"5932f142a55dc83eca86ea86"</code><code>)</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>}</code> &nbsp; <code>hqmongodb:PRIMARY&gt; cfg.members[0].priority = 1</code> <code>1</code> <code>hqmongodb:PRIMARY&gt; cfg.members[1].priority = 1</code> <code>1</code> <code>hqmongodb:PRIMARY&gt; cfg.members[2].priority = 2&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>//</code><code>设置_ID 为 2 的节点为主节点。即当当前主节点发生故障时，该节点就会转变为主节点接管服务</code> <code>2</code> <code>hqmongodb:PRIMARY&gt; rs.reconfig(cfg)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>//</code><code>使配置生效</code> <code>{ </code><code>"ok"</code> <code>: 1 }</code> &nbsp; &nbsp; <code>说明:</code> <code>MongoDB副本集通过设置priority 决定优先级,默认优先级为1,priority值是0到100之间的数字,数字越大优先级越高,priority=0,则此节点永远不能成为主节点 primay。</code> <code>cfg.members[0].priority =1 参数,中括号里的数字是执行rs.conf()查看到的节点顺序, 第一个节点是0,第二个节点是 1,第三个节点是 2,以此类推。优先级最高的那个</code> <code>被设置为主节点。</code> &nbsp; <code>4）分别对两台从节点进行配置</code> &nbsp; <code>slave-node1节点操作（182.48.115.237）</code> <code>[root@slave-node1 ~]</code><code># mongo 182.48.115.237:27017</code> <code>.....</code> <code>hqmongodb:SECONDARY&gt; db.getMongo().setSlaveOk()&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>//</code><code>设置从节点为只读.注意从节点的前缀现在是SECONDARY。看清楚才设置</code> &nbsp; <code>slave-node2节点操作（182.48.115.238）</code> <code>[root@slave-node2 ~]</code><code># mongo 182.48.115.238:27017</code> <code>......</code> <code>hqmongodb:SECONDARY&gt; db.getMongo().setSlaveOk()&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>//</code><code>从节点的前缀是SECONDARY，看清楚才设置。执行这个，否则后续从节点同步数据时会报错：</code><code>"errmsg"</code> <code>: </code><code>"not master and slaveOk=false"</code><code>,</code> &nbsp; <code>5）设置数据库账号,开启登录验证(这一步可以直接跳过，即不开启登陆验证，只是为了安全着想)</code> <code>5.1）设置数据库账号</code> <code>在master-node主节点服务器182.48.115.236上面操作</code> <code>[root@master-node ]</code><code># mongo 182.48.115.236:27017</code> <code>......</code> <code>－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－</code> <code>如果执行命令后出现报错： </code><code>"errmsg"</code> <code>: </code><code>"not master and slaveOk=false"</code><code>,</code> <code>这是正常的，因为SECONDARY是不允许读写的，如果非要解决，方法如下：</code> <code>&gt; rs.slaveOk();&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>//</code><code>执行这个命令然后，再执行其它命令就不会出现这个报错了</code> <code>－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－</code> <code>hqmongodb:PRIMARY&gt; show dbs</code> <code>local</code>&nbsp; <code>0.000GB&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code> <code>hqmongodb:PRIMARY&gt; use admin&nbsp;&nbsp;&nbsp;&nbsp; </code><code>//mongodb3</code><code>.0没有admin数据库了，需要手动创建。admin库下添加的账号才是管理员账号</code> <code>switched to db admin&nbsp;&nbsp;&nbsp; </code> <code>hqmongodb:PRIMARY&gt; show collections</code> &nbsp; <code>＃添加两个管理员账号,一个系统管理员:system 一个数据库管理员:administrator</code> <code>＃先添加系统管理员账号,用来管理用户</code> <code>hqmongodb:PRIMARY&gt; db.createUser({user:</code><code>"system"</code><code>,</code><code>pwd</code><code>:</code><code>"123456"</code><code>,roles:[{role:</code><code>"root"</code><code>,db:</code><code>"admin"</code><code>}]})</code> <code>Successfully added user: { </code> <code>&nbsp;&nbsp;</code><code>"user"</code> <code>: </code><code>"system"</code><code>,</code> <code>&nbsp;&nbsp;</code><code>"roles"</code> <code>: [</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"role"</code> <code>: </code><code>"root"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"db"</code> <code>: </code><code>"admin"</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>]</code> <code>}</code> <code>hqmongodb:PRIMARY&gt; db.auth(</code><code>'system'</code><code>,</code><code>'123456'</code><code>)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>//</code><code>添加管理员用户认证,认证之后才能管理所有数据库</code> <code>1</code> &nbsp; <code>#添加数据库管理员,用来管理所有数据库</code> <code>hqmongodb:PRIMARY&gt; db.createUser({user:</code><code>'administrator'</code><code>, </code><code>pwd</code><code>:</code><code>'123456'</code><code>, roles:[{ role: </code><code>"userAdminAnyDatabase"</code><code>, db: </code><code>"admin"</code><code>}]});</code> <code>Successfully added user: { </code> <code>&nbsp;&nbsp;</code><code>"user"</code> <code>: </code><code>"administrator"</code><code>,</code> <code>&nbsp;&nbsp;</code><code>"roles"</code> <code>: [</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"role"</code> <code>: </code><code>"userAdminAnyDatabase"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"db"</code> <code>: </code><code>"admin"</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>]</code> <code>}</code> <code>hqmongodb:PRIMARY&gt; db.auth(</code><code>'administrator'</code><code>,</code><code>'123456'</code><code>)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>//</code><code>添加管理员用户认证,认证之后才能管理所有数据库</code> <code>1</code> &nbsp; <code>hqmongodb:PRIMARY&gt; db</code> <code>admin</code> <code>hqmongodb:PRIMARY&gt; show collections</code> <code>system.</code><code>users</code> <code>system.version</code> <code>hqmongodb:PRIMARY&gt; db.system.</code><code>users</code><code>.</code><code>find</code><code>()</code> <code>{ </code><code>"_id"</code> <code>: </code><code>"admin.system"</code><code>, </code><code>"user"</code> <code>: </code><code>"system"</code><code>, </code><code>"db"</code> <code>: </code><code>"admin"</code><code>, </code><code>"credentials"</code> <code>: { </code><code>"SCRAM-SHA-1"</code> <code>: { </code><code>"iterationCount"</code> <code>: 10000, </code><code>"salt"</code> <code>: </code><code>"uTGH9NI6fVUFXd2u7vu3Pw=="</code><code>, </code><code>"storedKey"</code> <code>: </code><code>"qJBR7dlqj3IgnWpVbbqBsqo6ECs="</code><code>, </code><code>"serverKey"</code> <code>: </code><code>"pTQhfZohNh760BED7Zn1Vbety4k="</code> <code>} }, </code><code>"roles"</code> <code>: [ { </code><code>"role"</code> <code>: </code><code>"root"</code><code>, </code><code>"db"</code> <code>: </code><code>"admin"</code> <code>} ] }</code> <code>{ </code><code>"_id"</code> <code>: </code><code>"admin.administrator"</code><code>, </code><code>"user"</code> <code>: </code><code>"administrator"</code><code>, </code><code>"db"</code> <code>: </code><code>"admin"</code><code>, </code><code>"credentials"</code> <code>: { </code><code>"SCRAM-SHA-1"</code> <code>: { </code><code>"iterationCount"</code> <code>: 10000, </code><code>"salt"</code> <code>: </code><code>"zJ3IIgYCe4IjZm0twWnK2Q=="</code><code>, </code><code>"storedKey"</code> <code>: </code><code>"2UCFc7KK1k5e4BgWbkTKGeuOVB4="</code><code>, </code><code>"serverKey"</code> <code>: </code><code>"eYHK/pBpf8ntrER1A8fiI+GikBY="</code> <code>} }, </code><code>"roles"</code> <code>: [ { </code><code>"role"</code> <code>: </code><code>"userAdminAnyDatabase"</code><code>, </code><code>"db"</code> <code>: </code><code>"admin"</code> <code>} ] }</code> &nbsp; <code>退出，用刚才创建的账号进行登录</code> <code>[root@master-node ～]</code><code># mongo 182.48.115.236:27017 -u system -p 123456 --authenticationDatabase admin</code> <code>[root@master-node ～]</code><code># mongo 182.48.115.236:27017 -u administrator -p 123456&nbsp; --authenticationDatabase admin</code> &nbsp; <code>5.2）开启登录验证</code> <code>在master-node主节点服务器182.48.115.236上面操作</code> <code>[root@master-node ~]</code><code># cd /usr/local/mongodb/&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //切换到mongodb主目录</code> <code>[root@master-node mongodb]</code><code># openssl rand -base64 21 &gt; keyfile&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //创建一个 keyfile(使用 openssl 生成 21 位 base64 加密的字符串)</code> <code>[root@master-node mongodb]</code><code># chmod 600 /usr/local/mongodb/keyfile</code> <code>[root@master-node mongodb]</code><code># cat /usr/local/mongodb/keyfile&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //查看刚才生成的字符串,做记录,后面要用到</code> <code>RavtXslz</code><code>/WTDwwW2JiNvK4OBVKxU</code> &nbsp; <code>注意:上面的数字 21,最好是 3 的倍数,否则生成的字符串可能含有非法字符,认证失败。</code> &nbsp; <code>5.3）设置配置文件</code> <code>分别在所有节点上面操作（即三个节点的配置文件上都要修改）</code> <code>[root@master-node ~]</code><code># vim /usr/local/mongodb/mongodb.conf&nbsp;&nbsp;&nbsp;&nbsp; //添加下面两行内容</code> <code>......</code> <code>auth=</code><code>true</code> <code>keyFile =</code><code>/usr/local/mongodb/keyfile</code> &nbsp; <code>启动脚本使用下面的代码(注释原来的,启用之前注释掉的)</code> <code>[root@master-node ~]</code><code># cat /etc/init.d/mongodb</code> <code>#!/bin/sh</code> <code># chkconfig: - 64 36</code> <code># description:mongod</code> <code>case</code> <code>$1 </code><code>in</code> <code>start)</code> <code>/usr/local/mongodb/bin/mongod</code> <code>--maxConns 20000 --config </code><code>/usr/local/mongodb/mongodb</code><code>.conf</code> <code>;;</code> <code>stop)</code> <code>#/usr/local/mongodb/bin/mongo 182.48.115.236:27017/admin --eval "db.shutdownServer()"</code> <code>/usr/local/mongodb/bin/mongo</code> <code>182.48.115.236:27017</code><code>/admin</code> <code>--</code><code>eval</code> <code>"db.auth('system', '123456');db.shutdownServer()"</code> <code>;;</code> <code>status)</code> <code>#/usr/local/mongodb/bin/mongo 182.48.115.236:27017/admin --eval "db.stats()"</code> <code>/usr/local/mongodb/bin/mongo</code> <code>182.48.115.236:27017</code><code>/admin</code> <code>--</code><code>eval</code> <code>"db.auth('system', '123456');db.stats()"</code> <code>;; </code><code>esac</code> &nbsp; <code>5.4）设置权限验证文件</code> <code>先进入master-node主节点服务器182.48.115.236,查看 </code> <code>[root@master-node ~]</code><code># cat /usr/local/mongodb/keyfile</code> <code>RavtXslz</code><code>/WTDwwW2JiNvK4OBVKxU</code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <code>//</code><code>查看刚才生成的字符串,做记录</code> &nbsp; <code>再分别进入两台从节点服务器182.48.115.237</code><code>/238</code> <code>[root@slave-node1 ~]</code><code># vim /usr/local/mongodb/keyfile&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //将主节点生成的权限验证字符码复制到从节点的权限验证文件里</code> <code>RavtXslz</code><code>/WTDwwW2JiNvK4OBVKxU</code> <code>[root@slave-node1 ~]</code><code># chmod 600 /usr/local/mongodb/keyfile</code> &nbsp; <code>[root@slave-node2 ~]</code><code># vim /usr/local/mongodb/keyfile </code> <code>[root@slave-node2 ~]</code><code># cat /usr/local/mongodb/keyfile</code> <code>RavtXslz</code><code>/WTDwwW2JiNvK4OBVKxU</code> <code>[root@slave-node2 ~]</code><code># chmod 600 /usr/local/mongodb/keyfile</code> &nbsp; <code>6）验证副本集</code> <code>分别重启三台副本集服务器（三台节点都要重启）</code> <code>[root@master-node ~]</code><code># ps -ef|grep mongodb</code> <code>root&nbsp;&nbsp;&nbsp;&nbsp; 28964&nbsp;&nbsp;&nbsp;&nbsp; 1&nbsp; 1 02:22 ?&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 00:00:31 </code><code>/usr/local/mongodb/bin/mongod</code> <code>--maxConns 20000 --config </code><code>/usr/local/mongodb/mongodb</code><code>.conf</code> <code>root&nbsp;&nbsp;&nbsp;&nbsp; 29453 28911&nbsp; 0 03:04 pts</code><code>/0</code>&nbsp;&nbsp;&nbsp; <code>00:00:00 </code><code>grep</code> <code>mongodb</code> <code>[root@master-node ~]</code><code># kill -9 28964</code> <code>[root@master-node ~]</code><code># /etc/init.d/mongodb start</code> <code>about to fork child process, waiting </code><code>until</code> <code>server is ready </code><code>for</code> <code>connections.</code> <code>forked process: 29457</code> <code>child process started successfully, parent exiting</code> <code>[root@master-node ~]</code><code># lsof -i:27017</code> <code>COMMAND&nbsp;&nbsp; PID USER&nbsp;&nbsp; FD&nbsp;&nbsp; TYPE DEVICE SIZE</code><code>/OFF</code> <code>NODE NAME</code> <code>mongod&nbsp; 29457 root&nbsp;&nbsp;&nbsp; 7u&nbsp; IPv4 701471&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 0t0&nbsp; TCP slave-node1:27017 (LISTEN)</code> <code>mongod&nbsp; 29457 root&nbsp;&nbsp; 29u&nbsp; IPv4 701526&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 0t0&nbsp; TCP slave-node1:27017-&gt;master-node:39819 (ESTABLISHED)</code> <code>mongod&nbsp; 29457 root&nbsp;&nbsp; 30u&nbsp; IPv4 701573&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 0t0&nbsp; TCP slave-node1:27017-&gt;master-node:39837 (ESTABLISHED)</code> <code>mongod&nbsp; 29457 root&nbsp;&nbsp; 31u&nbsp; IPv4 701530&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 0t0&nbsp; TCP slave-node1:36768-&gt;master-node:27017 (ESTABLISHED)</code> <code>mongod&nbsp; 29457 root&nbsp;&nbsp; 32u&nbsp; IPv4 701549&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 0t0&nbsp; TCP slave-node1:36786-&gt;master-node:27017 (ESTABLISHED)</code> <code>mongod&nbsp; 29457 root&nbsp;&nbsp; 33u&nbsp; IPv4 701574&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 0t0&nbsp; TCP slave-node1:27017-&gt;master-node:39838 (ESTABLISHED)</code> &nbsp; <code>然后登陆mongodb</code> <code>[root@master-node ~]</code><code># mongo 182.48.115.236:27017 -u system -p 123456 --authenticationDatabase admin</code> <code>.......</code> <code>hqmongodb:PRIMARY&gt; rs.status()&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>//</code><code>副本集状态查看.也可以省略上面添加登陆验证的步骤，不做验证，直接查看集群状态。集群状态中可以看出哪个节点目前是主节点</code> <code>{ </code> <code>&nbsp;&nbsp;</code><code>"set"</code> <code>: </code><code>"hqmongodb"</code><code>,</code> <code>&nbsp;&nbsp;</code><code>"date"</code> <code>: ISODate(</code><code>"2017-06-03T19:06:59.708Z"</code><code>),</code> <code>&nbsp;&nbsp;</code><code>"myState"</code> <code>: 1,</code> <code>&nbsp;&nbsp;</code><code>"term"</code> <code>: NumberLong(2),</code> <code>&nbsp;&nbsp;</code><code>"heartbeatIntervalMillis"</code> <code>: NumberLong(2000),</code> <code>&nbsp;&nbsp;</code><code>"optimes"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"lastCommittedOpTime"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"ts"</code> <code>: Timestamp(1496516810, 1),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"t"</code> <code>: NumberLong(2)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"appliedOpTime"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"ts"</code> <code>: Timestamp(1496516810, 1),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"t"</code> <code>: NumberLong(2)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"durableOpTime"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"ts"</code> <code>: Timestamp(1496516810, 1),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"t"</code> <code>: NumberLong(2)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;</code><code>"members"</code> <code>: [</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"_id"</code> <code>: 0,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"name"</code> <code>: </code><code>"182.48.115.236:27017"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"health"</code> <code>: 1,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"state"</code> <code>: 1,&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>//state</code><code>的值为1的节点就是主节点</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"stateStr"</code> <code>: </code><code>"PRIMARY"</code><code>,&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>//</code><code>主节点PRIMARY标记</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"uptime"</code> <code>: 138,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"optime"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"ts"</code> <code>: Timestamp(1496516810, 1),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"t"</code> <code>: NumberLong(2)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"optimeDate"</code> <code>: ISODate(</code><code>"2017-06-03T19:06:50Z"</code><code>),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"infoMessage"</code> <code>: </code><code>"could not find member to sync from"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"electionTime"</code> <code>: Timestamp(1496516709, 1),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"electionDate"</code> <code>: ISODate(</code><code>"2017-06-03T19:05:09Z"</code><code>),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"configVersion"</code> <code>: 4,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"self"</code> <code>: </code><code>true</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"_id"</code> <code>: 1,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"name"</code> <code>: </code><code>"182.48.115.237:27017"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"health"</code> <code>: 1,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"state"</code> <code>: 2,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"stateStr"</code> <code>: </code><code>"SECONDARY"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"uptime"</code> <code>: 116,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"optime"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"ts"</code> <code>: Timestamp(1496516810, 1),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"t"</code> <code>: NumberLong(2)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"optimeDurable"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"ts"</code> <code>: Timestamp(1496516810, 1),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"t"</code> <code>: NumberLong(2)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"optimeDate"</code> <code>: ISODate(</code><code>"2017-06-03T19:06:50Z"</code><code>),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"optimeDurableDate"</code> <code>: ISODate(</code><code>"2017-06-03T19:06:50Z"</code><code>),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"lastHeartbeat"</code> <code>: ISODate(</code><code>"2017-06-03T19:06:59.533Z"</code><code>),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"lastHeartbeatRecv"</code> <code>: ISODate(</code><code>"2017-06-03T19:06:59.013Z"</code><code>),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"pingMs"</code> <code>: NumberLong(0),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"syncingTo"</code> <code>: </code><code>"182.48.115.236:27017"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"configVersion"</code> <code>: 4</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"_id"</code> <code>: 2,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"name"</code> <code>: </code><code>"182.48.115.238:27017"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"health"</code> <code>: 1,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"state"</code> <code>: 2,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"stateStr"</code> <code>: </code><code>"SECONDARY"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"uptime"</code> <code>: 189,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"optime"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"ts"</code> <code>: Timestamp(1496516810, 1),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"t"</code> <code>: NumberLong(2)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"optimeDurable"</code> <code>: { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"ts"</code> <code>: Timestamp(1496516810, 1),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"t"</code> <code>: NumberLong(2)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"optimeDate"</code> <code>: ISODate(</code><code>"2017-06-03T19:06:50Z"</code><code>),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"optimeDurableDate"</code> <code>: ISODate(</code><code>"2017-06-03T19:06:50Z"</code><code>),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"lastHeartbeat"</code> <code>: ISODate(</code><code>"2017-06-03T19:06:59.533Z"</code><code>),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"lastHeartbeatRecv"</code> <code>: ISODate(</code><code>"2017-06-03T19:06:59.013Z"</code><code>),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"pingMs"</code> <code>: NumberLong(0),</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"syncingTo"</code> <code>: </code><code>"182.48.115.236:27017"</code><code>,</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>"configVersion"</code> <code>: 4</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>},</code> <code>&nbsp;&nbsp;</code><code>],</code> <code>&nbsp;&nbsp;</code><code>"ok"</code> <code>: 1</code> <code>}</code> &nbsp; <code>注意上面命令结果中的state,如果这个值为 1,说明是主控节点(master);如果是2，说明是从属节点slave。在上面显示的当前主节点写入数据，到从节点上查看发现数据会同步。</code> <code>&nbsp;</code>&nbsp; <code>当主节点出现故障的时候,在两个从节点上会选举出一个新的主节点,故障恢复之后,之前的主节点会变为从节点。从上面集群状态中开看出，当前主节点是master-node，那么关闭它的mongodb，再次查看集群状态，就会发现主节点变为之前设置的slave-node2，即182.48.115.238了！</code> <code>至此,Linux 下 MongoDB 副本集部署完成。</code> &nbsp; <code>-------------------------------------------------------------------------------------------</code> <code>添加数据,来需要验证的--------------------</code> <code>1）主从服务器数据是否同步,从服务器没有读写权限</code> <code>a:向主服务器写入数据 ok 后台自动同步到从服务器,从服务器有数据</code> <code>b:向从服务器写入数据 </code><code>false</code> <code>从服务器不能写</code> <code>c:主服务器读取数据 ok</code> <code>d:从服务器读取数据 </code><code>false</code> <code>从服务器不能读</code> &nbsp; <code>2）关闭主服务器,从服务器是否能顶替</code> <code>&nbsp;</code><code>mongo 的命令行执行 rs.status() 发现 PRIMARY 替换了主机了</code> &nbsp; <code>3）关闭的服务器,再恢复,以及主从切换</code> <code>&nbsp;</code><code>a:直接启动关闭的服务,rs.status()中会发现,原来挂掉的主服务器重启后变成从服务器了</code> <code>&nbsp;</code><code>b:额外删除新的服务器 rs.remove(</code><code>"localhost:9933"</code><code>); rs.status()</code> <code>&nbsp;</code><code>c:额外增加新的服务器 rs.add({_id:0,host:</code><code>"localhost:9933"</code><code>,priority:1});</code> <code>&nbsp;</code><code>d:让新增的成为主服务器 rs.stepDown(),注意之前的 priority 投票</code> &nbsp; <code>4）从服务器读写</code> <code>&nbsp;</code><code>db.getMongo().setSlaveOk();</code> <code>&nbsp;</code><code>db.getMongo().slaveOk();</code><code>//</code><code>从库只读,没有写权限,这个方法 java 里面不推荐了</code> <code>&nbsp;</code><code>db.setReadPreference(ReadPreference.secondaryPreferred());</code><code>//</code> <code>在 复 制 集 中 优 先 读</code> <code>&nbsp;</code><code>secondary,如果 secondary 访问不了的时候就从 master 中读</code> <code>&nbsp;</code><code>db.setReadPreference(ReadPreference.secondary());</code><code>//</code> <code>只 从 secondary 中 读 , 如 果</code> <code>&nbsp;</code><code>secondary 访问不了的时候就不能进行查询</code> &nbsp; <code>日志查看--------------------------- </code> <code>&nbsp;</code><code>MongoDB 的 Replica Set 架构是通过一个日志来存储写操作的,这个日志就叫做”oplog”,</code> <code>&nbsp;</code><code>它存在于”</code><code>local</code><code>”数据库中,oplog 的大小是可以通过 mongod 的参数”—oplogSize”来改变</code> <code>&nbsp;</code><code>oplog 的日志大小。</code> <code>&nbsp;</code><code>&gt; use </code><code>local</code> <code>&nbsp;</code><code>switched to db </code><code>local</code> <code>&nbsp;</code><code>&gt; db.oplog.rs.</code><code>find</code><code>()</code> <code>&nbsp;</code><code>{ </code><code>"ts"</code> <code>: { </code><code>"t"</code> <code>: 1342511269000, </code><code>"i"</code> <code>: 1 }, </code><code>"h"</code> <code>: NumberLong(0), </code><code>"op"</code> <code>: </code><code>"n"</code><code>, </code><code>"ns"</code> <code>: </code><code>""</code><code>, </code><code>"o"</code> <code>:</code> <code>&nbsp;</code><code>{ </code><code>"msg"</code> <code>: </code><code>"initiating set"</code> <code>} }</code> <code>&nbsp;</code>&nbsp; <code>&nbsp;</code><code>字段说明:</code> <code>&nbsp;</code><code>ts: 某个操作的时间戳</code> <code>&nbsp;</code><code>op</code><code>: 操作类型,如下:</code> <code>&nbsp;</code><code>i: insert</code> <code>&nbsp;</code><code>d: delete</code> <code>&nbsp;</code><code>u: update</code> <code>&nbsp;</code><code>ns: 命名空间,也就是操作的 collection name</code> <code>-------------------------------------------------------------------------------------------</code> <code>其它注意细节：</code> <code>rs.remove(</code><code>"ip:port"</code><code>);&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code>//</code><code>删除副本</code> <code>单服务器,启动时添加--auth&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 参数开启验证。</code> &nbsp; <code>副本集服务器,开启--auth 参数的同时,必须指定 keyfile 参数,节点之间的通讯基于该 keyfile,key 长度必须在 6 到 1024 个字符之间,</code> <code>最好为 3 的倍数,不能含有非法字符。</code> &nbsp; <code>重新设置副本集 </code> <code>rs.stepDown() </code> <code>cfg = rs.conf()</code> <code>cfg.members[n].host= </code><code>'new_host_name:prot'</code> <code>rs.reconfig(cfg)</code> &nbsp; <code>副本集所有节点服务器总数必须为奇数,服务器数量为偶数的时候,需要添加一个仲裁节 点,仲裁节点不参与数副本集,只有选举权。</code> &nbsp; <code>rs.addArb(</code><code>"182.48.115.239:27017"</code><code>) </code><code>#添加仲裁节点</code> </td> 
 </tr> 
 </tbody> 
</table>

**三、Mongodb分片集群（Sharding）**

Sharding cluster是一种可以水平扩展的模式,在数据量很大时特给力,实际大规模应用一般会采用这种架构去构建。sharding分片很好的解决了单台服务器磁盘空间、内存、cpu等硬件资源的限制问题，把数据水平拆分出去，降低单节点的访问压力。每个分片都是一个独立的数据库，所有的分片组合起来构成一个逻辑上的完整的数据库。因此，分片机制降低了每个分片的数据操作量及需要存储的数据量，达到多台服务器来应对不断增加的负载和数据的效果。

1）Sharding分区概念

**为何需要水平分片**  
1）减少单机请求数,将单机负载,提高总负载  
2）减少单机的存储空间,提高总存空间

![907596-20170604035137258-762254443.png][]

mongodb sharding 服务器架构

![907596-20170604035229055-909393426.png][]

简单注解:

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 </td> 
 <td> <code>分片集群主要由三种组件组成:mongos,config server,shard</code> <code>1) mongos&nbsp; (路由进程, 应用程序接入 mongos 再查询到具体分片)</code> <code>数据库集群请求的入口,所有的请求都通过 mongos 进行协调,不需要在应用程序添加一个路由选择器,mongos 自己就是一个请求分发中心,它负责把对应的数据请求</code> <code>请求转发到对应的 shard 服务器上。在生产环境通常有多个 mongos 作为请求的入口,防止其中一个挂掉所有的 mongodb 请求都没有办法操作。</code> &nbsp; <code>2) config server&nbsp; (路由表服务。 每一台都具有全部 chunk 的路由信息)</code> <code>顾名思义为配置服务器,存储所有数据库元信息(路由、分片)的配置。mongos 本身没有物理存储分片服务器和数据路由信息,只是缓存在内存里,配置服务器则实际存储</code> <code>这些数据。mongos 第一次启动或者关掉重启就会从 config server 加载配置信息,以后如果配置服务器信息变化会通知到所有的 mongos 更新自己的状态,这样 </code> <code>mongos 就能继续准确路由。在生产环境通常有多个 config server 配置服务器,因为它存储了分片路由的元数据,这个可不能丢失!就算挂掉其中一台,只要还有存货, </code> <code>mongodb 集群就不会挂掉。</code> &nbsp; <code>3) shard&nbsp; (为数据存储分片。 每一片都可以是复制集(replica </code><code>set</code><code>))</code> <code>这就是传说中的分片了。如图所示,一台机器的一个数据表 Collection1 存储了 1T 数据,压力太大了!在分给 4 个机器后, 每个机器都是 256G,则分摊了集中在一台</code> <code>机器的压力。事实上,上图4个分片如果没有副本集(replica </code><code>set</code><code>)是个不完整架构,假设其中的一个分片挂掉那四 分之一的数据就丢失了,所以在高可用性的分片架构还</code> <code>需要对于每一个分片构建 replica </code><code>set</code> <code>副本集保 证分片的可靠性。生产环境通常是 2 个副本 + 1 个仲裁。</code> </td> 
 </tr> 
 </tbody> 
</table>

2）Sharding分区的原理

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 </td> 
 <td> <code>分片,是指将数据拆分,将其分散到不同的机器上。这样的好处就是,不需要功能强大的大型计算机也可以存储更多的数据,处理更大的负载。mongoDB 的分片,</code> <code>是将collection 的数据进行分割,然后将不同的部分分别存储到不同的机器上。当 collection 所占空间过大时,我们需要增加一台新的机器,分片会自动</code> <code>将 collection 的数据分发到新的机器上。</code> </td> 
 </tr> 
 </tbody> 
</table>

**mongoDB sharding分片的原理**

![907596-20170604042221071-857890203.png][]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 </td> 
 <td> <code>人脸：&nbsp;&nbsp;&nbsp; </code> <code>代表客户端，客户端肯定说，你数据库分片不分片跟我没关系，我叫你干啥就干啥，没什么好商量的。</code> &nbsp; <code>mongos： </code> <code>首先我们要了解”片键“的概念，也就是说拆分集合的依据是什么？按照什么键值进行拆分集合。mongos就是一个路由服务器，它会根据管理员设置的</code><code>"片键"</code> <code>将数据分摊到自己管理的mongod集群，数据和片的对应关系以及相应的配置信息保存在</code><code>"config服务器"</code><code>上。</code> <code>客户端只需要对 mongos 进行操作就行了,至于如何进行分片,不需要 客户端参与,由 mongos 和 config 来完成。</code> &nbsp; <code>mongod:&nbsp;&nbsp; </code> <code>一个普通的数据库实例或者副本集，如果不分片的话，我们会直接连上mongod。</code> &nbsp; <code>分片是指将数据拆分,将其分散存在不同机器上的过程.有时也叫分区.将数据分散在不同的机器上MongoDB支持自动分片,可以摆脱手动分片的管理.集群自动切分数据,做负载均衡</code> </td> 
 </tr> 
 </tbody> 
</table>

分片集群的构造如下：

![907596-20170604042624993-668182824.png][]

分片集群由以下3个服务组成：  
Shards Server: 每个shard由一个或多个mongod进程组成，用于存储数据  
Config Server: 用于存储集群的Metadata信息，包括每个Shard的信息和chunks信息  
Route Server: 用于提供路由服务，由Client连接，使整个Cluster看起来像单个DB服务器

[MongoDB]: http://lib.csdn.net/base/mongodb
[Link 1]: http://lib.csdn.net/base/mysql
[907596-20170603163125914-453548285.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/6db918e9acf84201b578c7e3dec3ceb2.png
[907596-20170603163930680-935037407.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/8a87df9a76454f1ead48b5d5be6d8b31.png
[mongodb]: http://www.lanceyan.com/tech/mongodb/mongodb_cluster_1.html
[907596-20170604001737664-2049802701.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/07f7297809d4466d827abc6947266ed7.png
[907596-20170604001821227-991171740.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/2c818f038f814ae79cb5f2a963a67666.png
[907596-20170604013129524-1035525546.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/0129a8fb242d408e89c36174ebc7c205.png
[907596-20170604012944508-1544910602.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/4e1b8aabafd44dfca399de9b2fb0f0fc.png
[907596-20170604035137258-762254443.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/26e8cb64de194c5a832fc7c712f7f49f.png
[907596-20170604035229055-909393426.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/8120554f27ff4374a9a1016836ca8175.png
[907596-20170604042221071-857890203.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/96100652d80b4400a1aa9d15ca5655df.png
[907596-20170604042624993-668182824.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/639ec762c1bd4a12990798192aa28f57.png