高可用的MongoDB集群
<h1>1.序言</h1><div class="page" title="Page 3">
<div class="layoutArea">
<div class="column">
<p> MongoDB 是一个可扩展的高性能,开源,模式自由,面向文档的数据库。 它使用 C++编写。MongoDB 包含一下特点:</p>
<ul>
<li>
<p>l 面向集合的存储:适合存储对象及JSON形式的数据。</p>
</li>
<li>
<p>l 动态查询:Mongo 支持丰富的查询方式,查询指令使用 JSON 形式的标记,可轻易查询文档中内嵌的对象及数组。</p>
</li>
<li>
<p>l 完整的索引支持:包括文档内嵌对象及数组。Mongo 的查询优化器会分析查询表达式,并生成一个高效的查询计划。</p>
</li>
<li>
<p>l 查询监视:Mongo包含一个监控工具用于分析数据库操作性能。</p>
</li>
<li>
<p>l 复制及自动故障转移:Mongo 数据库支持服务器之间的数据复制,支持主-从模式及服务器之间的相互复制。复制的主要目的是提供冗余及自动故障转移。</p>
</li>
<li>
<p>l 高效的传统存储方式:支持二进制数据及大型对象(如:照片或图片)。</p>
</li>
<li>
<p>l 自动分片以支持云级别的伸缩性:自动分片功能支持水平的数据库集群,可动态添加额外的机器。</p>
</li>
</ul>
<h1>2.背景</h1>
<p> MongoDB 的主要目标是在键值对存储方式(提供了高性能和高度伸缩性) 以及传统的 RDBMS(关系性数据库)系统,集两者的优势于一身。Mongo 使用 一下场景:</p>
<div class="page" title="Page 3">
<div class="layoutArea">
<div class="column">
<ul>
<li>l 网站数据:Mongo 非常适合实时的插入,更新与查询,并具备网站实时数据存储所需的复制及高度伸缩性。</li>
</ul>
<ul>
<li>l 缓存:由于性能很高,Mongo 也适合作为信息基础设施的缓存层。在系统重启之后,由 Mongo 搭建的持久化缓存可以避免下层的数据源过载。 </li>
</ul>
<ul>
<li>l 大尺寸,低价值的数据:使用传统的关系数据库存储一些数据时可能会比较贵,在此之前,很多程序员往往会选择传统的文件进行存储。</li>
</ul>
<ul>
<li>l 高伸缩性的场景:Mongo非常适合由数十或数百台服务器组成的数据库</li>
</ul>
<ul>
<li>l 用于对象及JSON数据的存储:Mongo的BSON数据格式非常适合文档格式化的存储及查询。</li>
</ul>
</div>
</div>
</div>
<div class="page" title="Page 4">
<div class="layoutArea">
<div class="column">
<p> <span style="color: rgba(255, 0, 0, 1)"><strong>注:这里需要说明下,本文旨在介绍高可用的 MongoDB 集群;这里不讨论 Hadoop 平台的 HDFS。可根据公司实际业务需求,选择合适的存储系统。</strong></span></p>
<p> 当然 MongDB 也有不适合的场景:</p>
<ul>
<li>
<p>l 高度事务性的系统:例如银行或会计系统。传统的关系型数据库目前还是更适用于需要大量原子性复制事物的应用程序。</p>
</li>
<li>
<p>l 传统的商业智能应用:针对特定问题的 BI 数据库会对产生高度优化的查询方式。对于此类应用,数据仓库可能时更适合的选择(如Hadoop套件中的Hive)。</p>
</li>
<li>
<p>l 需要SQL的问题。 </p>
</li>
</ul>
<h1>3.搭建</h1>
<h2>3.1环境准备</h2>
</div>
</div>
</div>
<p> 在 Mongo 的官网下载 Linux 版本安装包,然后解压到对应的目录下;由于资源有限,我们采用 Replica Sets + Sharding 方式来配置高可用。结构图如下所示:</p>
<p><img src="//images0.cnblogs.com/blog/666745/201502/281502412994595.png" alt=""> </p>
<div class="page" title="Page 4">
<div class="layoutArea">
<div class="column">
<p> 这里我说明下这个图所表达的意思。</p>
<ul>
<li>l Shard服务器:使用Replica Sets确保每个数据节点都具有备份、自动容错转移、自动恢复的能力。</li>
</ul>
</div>
</div>
</div>
<div class="page" title="Page 5">
<div class="layoutArea">
<div class="column">
<ul>
<li>
<p>l 配置服务器:使用使用3个配置服务器确保元数据完整性。</p>
</li>
<li>
<p>l 路由进程:使用3个路由进程实现平衡,提高客户端接入性能</p>
</li>
<li>
<p>l 3 个分片进程:Shard11,Shard12,Shard13 组成一个副本集,提供Sharding 中 shard1 的功能。</p>
</li>
<li>
<p>l 3 个分片进程:Shard21,Shard22,Shard23 组成一个副本集,提供Sharding 中 Shard2 的功能。</p>
</li>
<li>l 3个配置服务器进程和3个路由器进程。</li>
</ul>
<p> 构建一个 mongoDB Sharding Cluster 需要三种角色:shard 服务器(ShardServer)、配置服务器(config Server)、路由进程(Route Process)</p>
<p> <strong><em>Shard 服务器</em></strong></p>
<p> shard 服务器即存储实际数据的分片,每个 shard 可以是一个 mongod 实例, 也可以是一组 mongod 实例构成的 Replica Sets.为了实现每个 Shard 内部的故障 自动转换,MongoDB 官方建议每个 shard 为一组 Replica Sets.<br>
<em><strong>配置服务器
</strong></em></p>
<p> 为了将一个特定的 collection 存储在多个 shard 中,需要为该 collection 指定
一个 shard key,决定该条记录属于哪个 chunk,配置服务器可以存储以下信息,
每个shard节点的配置信息,每个chunk的shard key范围,chunk在各shard
的分布情况,集群中所有 DB 和 collection 的 sharding 配置信息。<br>
<em><strong> 路由进程
</strong></em></p>
<p> 它是一个前段路由,客户端由此接入,首先询问配置服务器需要到哪个 shard
上查询或保存记录,然后连接相应的 shard 执行操作,最后将结果返回给客户端,客
户端只需要将原本发给 mongod 的查询或更新请求原封不动地发给路由进程,而
不必关心所操作的记录存储在哪个 shard 上。
</p>
<p>按照架构图,理论上是需要 16 台机器的,由于资源有限,用目录来替代物理机(有风险,若其中某台机器宕机,配置在该机器的服务都会 down 掉),下面给出配置表格: </p>
<div class="page" title="Page 5">
<table style="height: 84px; width: 542px"><colgroup><col><col><col> </colgroup>
<tbody>
<tr>
<td>
<div class="layoutArea">
<div class="column">
<p>服务器</p>
</div>
</div>
</td>
<td>
<div class="layoutArea">
<div class="column">
<p>Host</p>
</div>
</div>
</td>
<td>
<div class="layoutArea">
<div class="column">
<p>服务和端口</p>
</div>
</div>
</td>
</tr>
<tr>
<td>
<div class="layoutArea">
<div class="column">
<p>1</p>
</div>
</div>
</td>
<td>
<div class="layoutArea">
<div class="column">
<p>10.211.55.28</p>
</div>
</div>
</td>
<td>
<div class="layoutArea">
<div class="column">
<p>Shard11:10011 Shard21:10021 ConfigSvr:10031 Mongos:10040</p>
</div>
</div>
</td>
</tr>
</tbody>
</table>
</div>
<div class="page" title="Page 6">
<table style="height: 114px; width: 542px"><colgroup><col><col><col> </colgroup>
<tbody>
<tr>
<td>
<div class="layoutArea">
<div class="column">
<p>2</p>
</div>
</div>
</td>
<td>
<div class="layoutArea">
<div class="column">
<p>10.211.55.28</p>
</div>
</div>
</td>
<td>
<div class="layoutArea">
<div class="column">
<p>Shard12:10012 Shard22:10022 ConfigSvr:10032 Mongos:10042</p>
</div>
</div>
</td>
</tr>
<tr>
<td>
<div class="layoutArea">
<div class="column">
<p>3 </p>
</div>
</div>
</td>
<td>
<div class="layoutArea">
<div class="column">
<p>10.211.55.28</p>
</div>
</div>
</td>
<td>
<div class="layoutArea">
<div class="column">
<p>Shard13:10013 Shard23:10023 ConfigSvr:10033 Mongos:10043</p>
</div>
</div>
</td>
</tr>
</tbody>
</table>
<div class="page" title="Page 6">
<div class="layoutArea">
<div class="column">
<h2>3.2.环境变量<br>
</h2>
<div class="page" title="Page 6">
<div class="layoutArea">
<div class="column">
<p> 下面给出 MongoDB 的环境变量配置,输入命令并配置: </p>
<div class="cnblogs_code">
<pre># <span style="color: rgba(0, 0, 255, 1)">vi</span> /etc/<span style="color: rgba(0, 0, 0, 1)">profile
export MONGO_HOME</span>=/root/mongodb-linux-x86_64-<span style="color: rgba(128, 0, 128, 1)">2.6</span>.<span style="color: rgba(128, 0, 128, 1)">7</span><span style="color: rgba(0, 0, 0, 1)">
export PATH</span>=$PATH:$MONGO_HOME/bin</pre>
</div>
<p> 然后保存退出，输入以下命令配置文件立即生效：</p>
<div class="cnblogs_code">
<pre># . /etc/profile</pre>
</div>
<div class="page" title="Page 6">
<div class="layoutArea">
<div class="column">
<h2>3.3.配置 Shard+Replica Sets<br>
</h2>
<div class="page" title="Page 6">
<div class="layoutArea">
<div class="column">
<p> 我们分别启动 Shard1 的所有进程,并设置副本集为:shard1。下面给出启动 Shard1 的脚本文件。 </p>
<ul>
<li>l shard11.conf </li>
</ul>
<div class="cnblogs_code">
<pre>dbpath=/mongodb/data/shard11 <br>logpath=/mongodb/log/shard11.log <br>pidfilepath=/mongodb/pid/shard11.pid <br>directoryperdb=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
logappend</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
replSet</span>=<span style="color: rgba(0, 0, 0, 1)">shard1
port</span>=<span style="color: rgba(128, 0, 128, 1)">10011</span><span style="color: rgba(0, 0, 0, 1)">
fork</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
shardsvr</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
journal</span>=<span style="color: rgba(0, 0, 255, 1)">true</span></pre>
</div>
<div class="page" title="Page 7">
<div class="layoutArea">
<div class="column">
<div class="page" title="Page 7">
<div class="layoutArea">
<div class="column">
<ul>
<li>l shard12.conf </li>
</ul>
<div class="cnblogs_code">
<pre>dbpath=/mongodb/data/shard12 <br>logpath=/mongodb/log/shard12.log <br>pidfilepath=/mongodb/pid/<span style="color: rgba(0, 0, 0, 1)">shard12.pid
directoryperdb</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
logappend</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
replSet</span>=<span style="color: rgba(0, 0, 0, 1)">shard1
port</span>=<span style="color: rgba(128, 0, 128, 1)">10012</span><span style="color: rgba(0, 0, 0, 1)">
fork</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
shardsvr</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
journal</span>=<span style="color: rgba(0, 0, 255, 1)">true</span></pre>
</div>
<ul>
<li>l shard13.conf </li>
</ul>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
<div class="cnblogs_code">
<pre>dbpath=/mongodb/data/<span style="color: rgba(0, 0, 0, 1)">shard13
logpath</span>=/mongodb/log/<span style="color: rgba(0, 0, 0, 1)">shard13.log
pidfilepath</span>=/mongodb/pid/<span style="color: rgba(0, 0, 0, 1)">shard13.pid
directoryperdb</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
logappend</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
replSet</span>=<span style="color: rgba(0, 0, 0, 1)">shard1
port</span>=<span style="color: rgba(128, 0, 128, 1)">10013</span><span style="color: rgba(0, 0, 0, 1)">
fork</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
shardsvr</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
journal</span>=<span style="color: rgba(0, 0, 255, 1)">true</span></pre>
</div>
<ul>
<li>l shard21.conf </li>
</ul>
<div class="cnblogs_code">
<pre>dbpath=/mongodb/data/<span style="color: rgba(0, 0, 0, 1)">shard21
logpath</span>=/mongodb/log/<span style="color: rgba(0, 0, 0, 1)">shard21.log
pidfilepath</span>=/mongodb/pid/<span style="color: rgba(0, 0, 0, 1)">shard21.pid
directoryperdb</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
logappend</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
replSet</span>=<span style="color: rgba(0, 0, 0, 1)">shard2
port</span>=<span style="color: rgba(128, 0, 128, 1)">10021</span><span style="color: rgba(0, 0, 0, 1)">
fork</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
shardsvr</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
journal</span>=<span style="color: rgba(0, 0, 255, 1)">true</span></pre>
</div>
<ul>
<li>l shard22.conf </li>
</ul>
<p> </p>
<div class="cnblogs_code">
<pre>dbpath=/mongodb/data/<span style="color: rgba(0, 0, 0, 1)">shard22
logpath</span>=/mongodb/log/<span style="color: rgba(0, 0, 0, 1)">shard22.log
pidfilepath</span>=/mongodb/pid/<span style="color: rgba(0, 0, 0, 1)">shard22.pid
directoryperdb</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
logappend</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
replSet</span>=<span style="color: rgba(0, 0, 0, 1)">shard2
port</span>=<span style="color: rgba(128, 0, 128, 1)">10022</span><span style="color: rgba(0, 0, 0, 1)">
fork</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
shardsvr</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
journal</span>=<span style="color: rgba(0, 0, 255, 1)">true</span></pre>
</div>
<ul>
<li>l shard23.conf </li>
</ul>
<div class="cnblogs_code">
<pre>dbpath=/mongodb/data/<span style="color: rgba(0, 0, 0, 1)">shard23
logpath</span>=/mongodb/log/<span style="color: rgba(0, 0, 0, 1)">shard23.log
pidfilepath</span>=/mongodb/pid/<span style="color: rgba(0, 0, 0, 1)">shard23.pid
directoryperdb</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
logappend</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
replSet</span>=<span style="color: rgba(0, 0, 0, 1)">shard2
port</span>=<span style="color: rgba(128, 0, 128, 1)">10023</span><span style="color: rgba(0, 0, 0, 1)">
fork</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
shardsvr</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
journal</span>=<span style="color: rgba(0, 0, 255, 1)">true</span></pre>
</div>
<div class="page" title="Page 9">
<div class="layoutArea">
<div class="column">
<ul>
<li>l config1.conf </li>
</ul>
<div class="cnblogs_code">
<pre>dbpath=/mongodb/config/config1 <br>logpath=/mongodb/log/config1.log <br>pidfilepath=/mongodb/pid/<span style="color: rgba(0, 0, 0, 1)">config1.pid
directoryperdb</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
logappend</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
port</span>=<span style="color: rgba(128, 0, 128, 1)">10031</span><span style="color: rgba(0, 0, 0, 1)">
fork</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
configsvr</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
journal</span>=<span style="color: rgba(0, 0, 255, 1)">true</span></pre>
</div>
<ul>
<li>l config2.conf </li>
</ul>
<div class="cnblogs_code">
<pre>dbpath=/mongodb/config/<span style="color: rgba(0, 0, 0, 1)">config2
logpath</span>=/mongodb/log/<span style="color: rgba(0, 0, 0, 1)">config2.log
pidfilepath</span>=/mongodb/pid/<span style="color: rgba(0, 0, 0, 1)">config2.pid
directoryperdb</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
logappend</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
port</span>=<span style="color: rgba(128, 0, 128, 1)">10032</span><span style="color: rgba(0, 0, 0, 1)">
fork</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
configsvr</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
journal</span>=<span style="color: rgba(0, 0, 255, 1)">true</span></pre>
</div>
<ul>
<li>l config3.conf </li>
</ul>
<div class="cnblogs_code">
<pre>dbpath=/mongodb/config/<span style="color: rgba(0, 0, 0, 1)">config3
logpath</span>=/mongodb/log/<span style="color: rgba(0, 0, 0, 1)">config3.log
pidfilepath</span>=/mongodb/pid/<span style="color: rgba(0, 0, 0, 1)">config3.pid
directoryperdb</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
logappend</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
port</span>=<span style="color: rgba(128, 0, 128, 1)">10033</span><span style="color: rgba(0, 0, 0, 1)">
fork</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
configsvr</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
journal</span>=<span style="color: rgba(0, 0, 255, 1)">true</span></pre>
</div>
<div class="page" title="Page 10">
<div class="layoutArea">
<div class="column">
<ul>
<li>route.conf </li>
</ul>
<div class="cnblogs_code">
<pre>configdb=mongo:<span style="color: rgba(128, 0, 128, 1)">10031</span>,mongo:<span style="color: rgba(128, 0, 128, 1)">10032</span>,mongo:<span style="color: rgba(128, 0, 128, 1)">10033</span> <br>pidfilepath=/mongodb/pid/<span style="color: rgba(0, 0, 0, 1)">route.pid
port</span>=<span style="color: rgba(128, 0, 128, 1)">10040</span><span style="color: rgba(0, 0, 0, 1)">
chunkSize</span>=<span style="color: rgba(128, 0, 128, 1)">1</span><span style="color: rgba(0, 0, 0, 1)">
logpath</span>=/mongodb/log/<span style="color: rgba(0, 0, 0, 1)">route.log
logappend</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
fork</span>=<span style="color: rgba(0, 0, 255, 1)">true</span></pre>
</div>
<ul>
<li>route2.conf </li>
</ul>
<div class="cnblogs_code">
<pre>configdb=mongo:<span style="color: rgba(128, 0, 128, 1)">10031</span>,mongo:<span style="color: rgba(128, 0, 128, 1)">10032</span>,mongo:<span style="color: rgba(128, 0, 128, 1)">10033</span><span style="color: rgba(0, 0, 0, 1)">
pidfilepath</span>=/mongodb/pid/<span style="color: rgba(0, 0, 0, 1)">route.pid
port</span>=<span style="color: rgba(128, 0, 128, 1)">10042</span><span style="color: rgba(0, 0, 0, 1)">
chunkSize</span>=<span style="color: rgba(128, 0, 128, 1)">1</span><span style="color: rgba(0, 0, 0, 1)">
logpath</span>=/mongodb/log/<span style="color: rgba(0, 0, 0, 1)">route2.log
logappend</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
fork</span>=<span style="color: rgba(0, 0, 255, 1)">true</span></pre>
</div>
<ul>
<li>route3.conf </li>
</ul>
<div class="cnblogs_code">
<pre>configdb=mongo:<span style="color: rgba(128, 0, 128, 1)">10031</span>,mongo:<span style="color: rgba(128, 0, 128, 1)">10032</span>,mongo:<span style="color: rgba(128, 0, 128, 1)">10033</span><span style="color: rgba(0, 0, 0, 1)">
pidfilepath</span>=/mongodb/pid/<span style="color: rgba(0, 0, 0, 1)">route3.pid
port</span>=<span style="color: rgba(128, 0, 128, 1)">10043</span><span style="color: rgba(0, 0, 0, 1)">
chunkSize</span>=<span style="color: rgba(128, 0, 128, 1)">1</span><span style="color: rgba(0, 0, 0, 1)">
logpath</span>=/mongodb/log/<span style="color: rgba(0, 0, 0, 1)">route3.log
logappend</span>=<span style="color: rgba(0, 0, 255, 1)">true</span><span style="color: rgba(0, 0, 0, 1)">
fork</span>=<span style="color: rgba(0, 0, 255, 1)">true</span></pre>
</div>
<div class="page" title="Page 11">
<div class="layoutArea">
<div class="column">
<p><strong><span style="color: rgba(255, 0, 0, 1)"> 注:配置文件中的目录必须存在,不存在需创建。 </span></strong></p>
<div class="page" title="Page 11">
<div class="layoutArea">
<div class="column">
<h2>3.4.启动批处理 </h2>
<p> 下面给出启动批处理的脚本，内容如下：</p>
<div class="cnblogs_code">
<div class="page" title="Page 11">
<div class="section">mongod -f /etc/shard11.conf</div>
<div class="section">mongod -f /etc/shard12.conf</div>
<div class="section">mongod -f /etc/shard13.conf</div>
<div class="section">mongod -f /etc/shard21.conf</div>
<div class="section">mongod -f /etc/shard22.conf</div>
<div class="section">mongod -f /etc/shard23.conf</div>
<div class="section">mongod -f /etc/config1.conf</div>
<div class="section">mongod -f /etc/config2.conf</div>
<div class="section">mongod -f /etc/config3.conf</div>
<div class="section">mongos -f /etc/route.conf</div>
<div class="section">mongos -f /etc/route2.conf</div>
<div class="section">mongos -f /etc/route3.conf </div>
</div>
</div>
<div class="page" title="Page 11">
<div class="layoutArea">
<div class="column">
<h2>3.5.参数说明<br>
</h2>
<div class="page" title="Page 11">
<div class="layoutArea">
<div class="column">
<p>dbpath:数据存放目录<br>
logpath:日志存放路径
logappend:以追加的方式记录日志<br>
replSet:replica set 的名字<br>
port:mongodb 进程所使用的端口号,默认为 27017
fork:以后台方式运行进程</p>
</div>
</div>
</div>
<div class="page" title="Page 12">
<div class="layoutArea">
<div class="column">
<p>journal:写日志<br>
smallfiles:当提示空间不够时添加此参数<br>
其他参数<br>
pidfilepath:进程文件,方便停止 mongodb
directoryperdb:为每一个数据库按照数据库名建立文件夹存放
bind_ip:mongodb 所绑定的 ip 地址<br>
oplogSize:mongodb 操作日志文件的最大大小。单位为 Mb,默认为硬盘剩余
空间的 5%<br>
noprealloc:不预先分配存储<br>
shardsvr:分片<br>
configsvr:配置服务节点<br>
configdb:配置 config 节点到 route 节点 </p>
<div class="page" title="Page 12">
<div class="layoutArea">
<div class="column">
<h2>3.6.配置分片的表和片键 </h2>
<div class="page" title="Page 12">
<div class="layoutArea">
<div class="column">
<p> 首先,我们需要登录到路由节点,这里我们登录到其中一个 10040 端口下的节点。输入如下命令: </p>
</div>
</div>
</div>
</div>
</div>
</div>
<div class="cnblogs_code">
<pre>mongo mongo:<span style="color: rgba(128, 0, 128, 1)">10040</span><span style="color: rgba(0, 0, 0, 1)">
use admin <br>db.runCommand({addshard:</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">shard1/mongo:10011,mongo:10012,mongo:10013</span><span style="color: rgba(128, 0, 0, 1)">"</span>}) <br>db.runCommand({addshard:<span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">shard2/mongo:10021,mongo:10022,mongo:10023</span><span style="color: rgba(128, 0, 0, 1)">"</span>}) <br>db.runCommand({ listshards:<span style="color: rgba(128, 0, 128, 1)">1</span> }) #列出 shard 个数 <br>db.runCommand({enablesharding:<span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">friends</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(0, 0, 0, 1)">}); #创建 friends 库
db.runCommand( { shardcollection : </span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">friends.user</span><span style="color: rgba(128, 0, 0, 1)">"</span>,key : {<span style="color: rgba(0, 0, 255, 1)">id</span>: <span style="color: rgba(128, 0, 128, 1)">1</span>},unique : <span style="color: rgba(0, 0, 255, 1)">true</span> } ) # 使用 user 表来做分片,片键为 <span style="color: rgba(0, 0, 255, 1)">id</span> 且唯一</pre>
</div>
<div class="page" title="Page 12">
<div class="layoutArea">
<div class="column">
<h2>3.7.验证 </h2>
<div class="page" title="Page 12">
<div class="layoutArea">
<div class="column">
<p> 至此,整个集群的搭建完成,下面我们测试集群的高可用性。下面给出截图:</p>
<p> 首先是查看集群的状态图 ：</p>
<p><img src="//images0.cnblogs.com/blog/666745/201502/281625326279926.png" alt=""></p>
<div class="page" title="Page 13">
<div class="layoutArea">
<div class="column">
<p> 可以看到,集群中存有数据,这是我之前为了测试存的数据,注意,Mongo 只有数据达到一定量才会分片,所有我插入的数据比较大,每次测试都是 10w 的记录插入。</p>
<p> 下面,我 kill 掉 shard11 服务,看会发生什么情况?截图如下: </p>
<p><img src="//images0.cnblogs.com/blog/666745/201502/281626073461687.png" alt=""></p>
<div class="page" title="Page 14">
<div class="layoutArea">
<div class="column">
<p> 这里我已经 kill 了 shard11 的进程服务。接下来,我们在 10040 端口的路由 节点输入:db.user.stats()查看状态,显示运行正常。截图如下所示: </p>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
<p><span style="color: rgba(0, 0, 0, 1)"><strong><img src="//images0.cnblogs.com/blog/666745/201502/281626441274616.png" alt=""></strong></span></p>
<p> </p>
<div class="page" title="Page 15">
<div class="layoutArea">
<div class="column">
<p> 同样可以在该路由节点插入 10w 条记录,看是否成功,下面给出插入脚本, 内容如下: </p>
<div class="cnblogs_code">
<pre><span style="color: rgba(0, 0, 255, 1)">for</span>(var i=<span style="color: rgba(128, 0, 128, 1)">1</span>;i<=<span style="color: rgba(128, 0, 128, 1)">100000</span>;i++)db.user.save({<span style="color: rgba(0, 0, 255, 1)">id</span>:i,value1:<span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">1234567890</span><span style="color: rgba(128, 0, 0, 1)">"</span>,value2:<span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">1234567890</span><span style="color: rgba(128, 0, 0, 1)">"</span>,value3:<span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">123 4567890</span><span style="color: rgba(128, 0, 0, 1)">"</span>,value4:<span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">1234567890</span><span style="color: rgba(128, 0, 0, 1)">"</span>});</pre>
</div>
<h1>4.总结</h1>
<p> 这片文章就分享到这里，若在研究的过程中有什么问题可以加群讨论或发送邮件给我，我会尽我所能为您解答，与君共勉！</p>
</div>
</div>
</div>
<p> </p>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
</div>
<div id="MySignature" role="contentinfo">
<div>
<b class="b1"></b><b class="b2 d1"></b><b class="b3 d1"></b><b class="b4 d1"></b>
<div class="b d1 k">
联系方式：
<br/>
邮箱：smartloli.org@gmail.com
<br/>
<strong style="color: green">QQ群（Hive与AI实战【新群】）：935396818</strong>
<br/>
QQ群（Hadoop - 交流社区1）：424769183
<br/>
QQ群（Kafka并不难学）：825943084
<br/>
温馨提示：请大家加群的时候写上加群理由（姓名＋公司/学校），方便管理员审核，谢谢！
<br/>
<h3>热爱生活，享受编程，与君共勉！</h3>
</div>
<b class="b4b d1"></b><b class="b3b d1"></b><b class="b2b d1"></b><b class="b1b"></b>
</div>
<br>
<div>
<b class="b1"></b><b class="b2 d1"></b><b class="b3 d1"></b><b class="b4 d1"></b>
<div class="b d1 k">
<h3>公众号：</h3>
<h3><img style="width: 8%; margin-left: 10px" src="https://www.cnblogs.com/images/cnblogs_com/smartloli/1324636/t_qr.png"></h3>
</div>
<b class="b4b d1"></b><b class="b3b d1"></b><b class="b2b d1"></b><b class="b1b"></b>
</div>
<br>
<div>
<b class="b1"></b><b class="b2 d1"></b><b class="b3 d1"></b><b class="b4 d1"></b>
<div class="b d1 k">
<h3>作者：哥不是小萝莉 ［关于我］［犒赏］</h3>
<h3>出处：http://www.cnblogs.com/smartloli/</h3>
<h3>转载请注明出处，谢谢合作！</h3>
</div>
<b class="b4b d1"></b><b class="b3b d1"></b><b class="b2b d1"></b><b class="b1b"></b>
</div><br><br>
来源：https://www.cnblogs.com/smartloli/p/4305739.html
頁:
[1]