MongoDB——MongoDB分片集群(Sharded Cluster)

Posted 611`

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了MongoDB——MongoDB分片集群(Sharded Cluster)相关的知识,希望对你有一定的参考价值。

MongoDB分片的概念

  • 分片 (sharding)是一种跨多台机器分布数据的方法,MongoDB使用分片来支持具有非常大的数据集高吞吐量操作的部署。
  • 换句话说:分片(sharding)是指将数据拆分,将其分散存在不同的机器上的过程。有时也用分区(partitioning)来表示这个概念。将数据分散到不同的机器上,不需要功能强大的大型计算机就可以储存更多的数据,处理更多的负载。
  • 具有大型数据集或高吞吐量应用程序的数据库系统可以会挑战单个服务器的容量。例如,高查询率会耗尽服务器的CPU容量。工作集大小大于系统的RAM会强调磁盘驱动器的I/O容量。
  • 有两种解决系统增长的方法:垂直扩展和水平扩展
    1. 垂直扩展意味着增加单个服务器的容量,例如使用更强大的CPU,添加更多RAM或增加存储空间量。可用技术的局限性可能会限制单个机器对于给定工作负载而言足够强大。此外,基于云的提供商基于可用的硬件配置具有硬性上限。结果,垂直缩放有实际的最大值。
    2. 水平扩展意味着划分系统数据集并加载多个服务器,添加其他服务器以根据需要增加容量。虽然单个机器的总体速度或容量可能不高,但每台机器处理整个工作负载的子集,可能是供比单个高速大容量服务器更高的效率扩展部署容量只需要根据需要添加额外的服务器,这可能比单个机器的高端硬件的总体成本更低。权衡是基础架构和部署维护的复杂性增加。
  • MongoDB支持通过分片进行水平扩展

分片集群包含的组件

  • MongoDB分片群集包含以下组件:
    1. 分片(存储)︰每个分片包含分片数据的子集。每个分片都可以部署为副本集。
    2. mongos(路由) :mongos充当查询路由器,在客户端应用程序和分片集群之间提供接口。
    3. config servers(调度的配置):配置服务器存储群集的元数据和配置设置。从MongoDB 3.4开始,必须将配置服务器部署为副本集(CSRS)
  • 下图描述了分片集群中组件的交互:
    在这里插入图片描述
  • MongoDB在集合级别对数据进行分片,将集合数据分布在集群中的分片上。

分片集群架构目标

  • 两个分片节点副本集(3+3)+一个配置节点副本集(3)+两个路由节点(2),共11个服务节点。
    在这里插入图片描述

安装MongoDB

[root@mongodb ~]# vim /etc/yum.repos.d/mongodb-org-5.0.repo
[mongodb-org-5.0]
name=MongoDB Repository
baseurl=https://repo.mongodb.org/yum/redhat/$releasever/mongodb-org/5.0/x86_64/
gpgcheck=0
enabled=1
gpgkey=https://www.mongodb.org/static/pgp/server-5.0.asc

[root@mongodb ~]# yum install -y mongodb-org

MongoDB分片集群搭建

  • sharding.clusterRole(群集角色
ValueDescription
configsvr将此实例作为配置服务器启动.
shardsvr将此实例作为副本启动.

第一套副本集

  • 准备存放数据和日志的目录
[root@pakho ~]# mkdir -p /mongodb/sharded_cluster/myshardrs01_27018/log
[root@pakho ~]# mkdir -p /mongodb/sharded_cluster/myshardrs01_27018/data/db

[root@pakho ~]# mkdir -p /mongodb/sharded_cluster/myshardrs01_27118/log
[root@pakho ~]# mkdir -p /mongodb/sharded_cluster/myshardrs01_27118/data/db

[root@pakho ~]# mkdir -p /mongodb/sharded_cluster/myshardrs01_27218/log
[root@pakho ~]# mkdir -p /mongodb/sharded_cluster/myshardrs01_27218/data/db
  • 新建或修改配置文件27018
[root@pakho ~]# vim /mongodb/sharded_cluster/myshardrs01_27018/mongod.conf
systemLog:
  # MongoDB发送所有日志输出的目标指定为文件
  destination: file
  # 当mongos或mongod实例重新启动时,mongos或mongod会将新条目附加到现有日志文件的末尾。
  logAppend: true
  # mongod或mongos应向其发送所有诊断日志记录信息的日志文件的路径
  path: /mongodb/sharded_cluster/myshardrs01_27018/log/mongod.log

storage:
  # mongod实例存储其数据的目录。storage.dbPath设置仅使用mongod。
  dbPath: /mongodb/sharded_cluster/myshardrs01_27018/data/db
  journal:
    # 启用或禁用持久化日志以确保数据文件保持有效和可恢复
    enabled: true

processManagement:
  # 启用在后台运行mongos或mongod进程的守护进程模式
  fork: true
  # 指定用于保存mongod或mongos进程的进程ID的文件位置其中mongos或mongod将写入其PID
  pidFilePath: /mongodb/sharded_cluster/myshardrs01_27018/log/mongod.pid
  timeZoneInfo: /usr/share/zoneinfo

net:
  # 服务实例绑定所有ip,有副作用,副本集初始化的时候,节点名字会自动设置为本地域名,而不是ip
  # bindIpAll: true
  # 服务实例绑定的IP
  bindIp: 0.0.0.0
  port: 27018

replication:
  # 二进制日志文件,到达2048MB,之前的日志将丢弃
  oplogSizeMB: 2048
  # 副本集的名称
  replSetName: myshardrs01
sharding:
  # 分片角色
  clusterRole: shardsvr
  • 新建或修改配置文件27118
[root@pakho ~]# vim /mongodb/sharded_cluster/myshardrs01_27118/mongod.conf
systemLog:
  # MongoDB发送所有日志输出的目标指定为文件
  destination: file
  # 当mongos或mongod实例重新启动时,mongos或mongod会将新条目附加到现有日志文件的末尾。
  logAppend: true
  # mongod或mongos应向其发送所有诊断日志记录信息的日志文件的路径
  path: /mongodb/sharded_cluster/myshardrs01_27118/log/mongod.log

storage:
  # mongod实例存储其数据的目录。storage.dbPath设置仅使用mongod。
  dbPath: /mongodb/sharded_cluster/myshardrs01_27118/data/db
  journal:
    # 启用或禁用持久化日志以确保数据文件保持有效和可恢复
    enabled: true

processManagement:
  # 启用在后台运行mongos或mongod进程的守护进程模式
  fork: true
  # 指定用于保存mongod或mongos进程的进程ID的文件位置其中mongos或mongod将写入其PID
  pidFilePath: /mongodb/sharded_cluster/myshardrs01_27118/log/mongod.pid
  timeZoneInfo: /usr/share/zoneinfo

net:
  # 服务实例绑定所有ip,有副作用,副本集初始化的时候,节点名字会自动设置为本地域名,而不是ip
  # bindIpAll: true
  # 服务实例绑定的IP
  bindIp: 0.0.0.0
  port: 27118

replication:
  # 二进制日志文件,到达2048MB,之前的日志将丢弃
  oplogSizeMB: 2048
  # 副本集的名称
  replSetName: myshardrs01
sharding:
  # 分片角色
  clusterRole: shardsvr
  • 新建或修改配置文件27218
[root@pakho ~]# vim /mongodb/sharded_cluster/myshardrs01_27218/mongod.conf
systemLog:
  # MongoDB发送所有日志输出的目标指定为文件
  destination: file
  # 当mongos或mongod实例重新启动时,mongos或mongod会将新条目附加到现有日志文件的末尾。
  logAppend: true
  # mongod或mongos应向其发送所有诊断日志记录信息的日志文件的路径
  path: /mongodb/sharded_cluster/myshardrs01_27218/log/mongod.log

storage:
  # mongod实例存储其数据的目录。storage.dbPath设置仅使用mongod。
  dbPath: /mongodb/sharded_cluster/myshardrs01_27218/data/db
  journal:
    # 启用或禁用持久化日志以确保数据文件保持有效和可恢复
    enabled: true

processManagement:
  # 启用在后台运行mongos或mongod进程的守护进程模式
  fork: true
  # 指定用于保存mongod或mongos进程的进程ID的文件位置其中mongos或mongod将写入其PID
  pidFilePath: /mongodb/sharded_cluster/myshardrs01_27218/log/mongod.pid
  timeZoneInfo: /usr/share/zoneinfo

net:
  # 服务实例绑定所有ip,有副作用,副本集初始化的时候,节点名字会自动设置为本地域名,而不是ip
  # bindIpAll: true
  # 服务实例绑定的IP
  bindIp: 0.0.0.0
  port: 27218

replication:
  # 二进制日志文件,到达2048MB,之前的日志将丢弃
  oplogSizeMB: 2048
  # 副本集的名称
  replSetName: myshardrs01
sharding:
  # 分片角色
  clusterRole: shardsvr
  • 启动第一套副本集:一主一副本一仲裁
#依次启动三个Mongod服务
[root@mongodb ~]# mongod -f /mongodb/sharded_cluster/myshardrs01_27018/mongod.conf
about to fork child process, waiting until server is ready for connections.
forked process: 1761
child process started successfully, parent exiting

[root@mongodb ~]# mongod -f /mongodb/sharded_cluster/myshardrs01_27118/mongod.conf
about to fork child process, waiting until server is ready for connections.
forked process: 1818
child process started successfully, parent exiting

[root@mongodb ~]# mongod -f /mongodb/sharded_cluster/myshardrs01_27218/mongod.conf
about to fork child process, waiting until server is ready for connections.
forked process: 1871
child process started successfully, parent exiting
  • 查看服务是否启动
[root@mongodb ~]# ps -ef | grep -v grep | grep mongodb
  • 初始化副本集和创建主节点
    • 使用客户端命令连接任意一个节点,但这里尽量要连接主节点
[root@mongodb ~]# mongo --host 192.168.100.10 --port 27018

#查看当前复制集状态
> rs.status()
{
	"ok" : 0, #还未初始化
	"errmsg" : "no replset config has been received",
	"code" : 94,
	"codeName" : "NotYetInitialized"
}

> use admin
#配置复制集
> config={_id:"myshardrs01",members:[{_id:0,host:"192.168.100.10:27018"},{_id:1,host:"192.168.100.10:27118"},{_id:2,host:"192.168.100.10:27218"}]}
{
	"_id" : "myshardrs01",
	"members" : [
		{
			"_id" : 0,
			"host" : "192.168.100.10:27018"
		},
		{
			"_id" : 1,
			"host" : "192.168.100.10:27118"
		},
		{
			"_id" : 2,
			"host" : "192.168.100.10:27218"
		}
	]
}
#复制集初始化
> rs.initiate(config)
{ "ok" : 1 }
myshardrs01:SECONDARY>
myshardrs01:PRIMARY>

第二套副本集

  • 准备存放数据和日志的目录
[root@mongodb ~]# mkdir -p /mongodb/sharded_cluster/myshardrs02_27318/log
[root@mongodb ~]# mkdir -p /mongodb/sharded_cluster/myshardrs02_27318/data/db

[root@mongodb ~]# mkdir -p /mongodb/sharded_cluster/myshardrs02_27418/log
[root@mongodb ~]# mkdir -p /mongodb/sharded_cluster/myshardrs02_27418/data/db

[root@mongodb ~]# mkdir -p /mongodb/sharded_cluster/myshardrs02_27518/log
[root@mongodb ~]# mkdir -p /mongodb/sharded_cluster/myshardrs02_27518/data/db
  • 新建或修改配置文件27318
[root@mongodb ~]# vim /mongodb/sharded_cluster/myshardrs02_27318/mongod.conf
systemLog:
  # MongoDB发送所有日志输出的目标指定为文件
  destination: file
  # 当mongos或mongod实例重新启动时,mongos或mongod会将新条目附加到现有日志文件的末尾。
  logAppend: true
  # mongod或mongos应向其发送所有诊断日志记录信息的日志文件的路径
  path: /mongodb/sharded_cluster/myshardrs02_27318/log/mongod.log

storage:
  # mongod实例存储其数据的目录。storage.dbPath设置仅使用mongod。
  dbPath: /mongodb/sharded_cluster/myshardrs02_27318/data/db
  journal:
    # 启用或禁用持久化日志以确保数据文件保持有效和可恢复
    enabled: true

processManagement:
  # 启用在后台运行mongos或mongod进程的守护进程模式
  fork: true
  # 指定用于保存mongod或mongos进程的进程ID的文件位置其中mongos或mongod将写入其PID
  pidFilePath: /mongodb/sharded_cluster/myshardrs02_27318/log/mongod.pid
  timeZoneInfo: /usr/share/zoneinfo

net:
  # 服务实例绑定所有ip,有副作用,副本集初始化的时候,节点名字会自动设置为本地域名,而不是ip
  # bindIpAll: true
  # 服务实例绑定的IP
  bindIp: 0.0.0.0
  port: 27318

replication:
  # 二进制日志文件,到达2048MB,之前的日志将丢弃
  oplogSizeMB: 2048
  # 副本集的名称
  replSetName: myshardrs02
sharding:
  # 分片角色
  clusterRole: shardsvr
  • 新建或修改配置文件27418
[root@mongodb ~]# vim /mongodb/sharded_cluster/myshardrs02_27418/mongod.conf
systemLog:
  # MongoDB发送所有日志输出的目标指定为文件
  destination: file
  # 当mongos或mongod实例重新启动时,mongos或mongod会将新条目附加到现有日志文件的末尾。
  logAppend: true
  # mongod或mongos应向其发送所有诊断日志记录信息的日志文件的路径
  path: /mongodb/sharded_cluster/myshardrs02_27418/log/mongod.log

storage:
  # mongod实例存储其数据的目录。storage.dbPath设置仅使用mongod。
  dbPath: /mongodb/sharded_cluster/myshardrs02_27418/data/db
  journal:
    # 启用或禁用持久化日志以确保数据文件保持有效和可恢复
    enabled: true

processManagement:
  # 启用在后台运行mongos或mongod进程的守护进程模式
  fork: true
  # 指定用于保存mongod或mongos进程的进程ID的文件位置其中mongos或mongod将写入其PID
  pidFilePath: /mongodb/sharded_cluster/myshardrs02_27418/log/mongod.pid
  timeZoneInfo: /usr/share/zoneinfo

net:
  # 服务实例绑定所有ip,有副作用,副本集初始化的时候,节点名字会自动设置为本地域名,而不是ip
  # bindIpAll: true
  # 服务实例绑定的IP
  bindIp: 0.0.0.0
  port: 27418

replication:
  # 二进制日志文件,到达2048MB,之前的日志将丢弃
  oplogSizeMB: 2048
  # 副本集的名称
  replSetName: myshardrs02
sharding:
  # 分片角色
  clusterRole: shardsvr
  • 新建或修改配置文件27518
[root@mongodb ~]# vim /mongodb/sharded_cluster/myshardrs02_27518/mongod.conf
systemLog:
  # MongoDB发送所有日志输出的目标指定为文件
  destination: file
  # 当mongos或mongod实例重新启动时,mongos或mongod会将新条目附加到现有日志文件的末尾。
  logAppend: true
  # mongod或mongos应向其发送所有诊断日志记录信息的日志文件的路径
  path: /mongodb/sharded_cluster/myshardrs02_27518/log/mongod.log

storage:
  # mongod实例存储其数据的目录。storage.dbPath设置仅使用mongod。
  dbPath: /mongodb/sharded_cluster/myshardrs02_27518/data/db
  journal:
    # 启用或禁用持久化日志以确保数据文件保持有效和可恢复
    enabled: true

processManagement:
  # 启用在后台运行mongos或mongod进程的守护进程模式
  fork: true
  # 指定用于保存mongod或mongos进程的进程ID的文件位置其中mongos或mongod将写入其PID
  pidFilePath: /mongodb/sharded_cluster/myshardrs02_27518/log/mongod.pid
  timeZoneInfo: /usr/share/zoneinfo

net:
  # 服务实例绑定所有ip,有副作用,副本集初始化的时候,节点名字会自动设置为本地域名,而不是ip
  # bindIpAll: true
  # 服务实例绑定的IP
  bindIp: 0.0.0.0
  port: 27518

replication:
  # 二进制日志文件,到达2048MB,之前的日志将丢弃
  oplogSizeMB: 2048
  # 副本集的名称
  replSetName: myshardrs02
sharding:
  # 分片角色
  clusterRole: shardsvr
  • 启动第二套副本集:一主一副本一仲裁
#依次启动三个Mongod服务
[root@mongodb ~]# mongod -f /mongodb/sharded_cluster/myshardrs02_27318/mongod.conf
about to fork child process, waiting until server is ready for connections.
forked process: 1964
child process started successfully, parent exiting

[root@mongodb ~]# mongod -f /mongodb/sharded_cluster/myshardrs02_27418/mongod.conf
about to fork child process, waiting until server is ready for connections.
forked process: 2017
child process started successfully, parent exiting

[root@mongodb ~]# mongod -f /mongodb/sharded_cluster/myshardrs02_27518/mongod.conf
about to fork child process, waiting until server is ready for connections.
forked process: 2070
child process started successfully, parent exiting
  • 查看服务是否启动
#此时已启动6个Mongo服务
[root@mongodb ~]# ps -ef | grep -v grep | grep mongodb
  • 初始化副本集和创建主节点
    • 使用客户端命令连接任意一个节点,但这里尽量要连接主节点
[root@mongodb ~]# mongo --host 192.168.100.10 --port 27318
> rs.status()
{
	"ok" : 0,
	"errmsg" : "no replset config has been received",
	"code" : 94,
	"codeName" : "NotYetInitialized"
}

> config={_id:"myshardrs02",members:[{_id:0,host:"192.168.100.10:27318"},{_id:1,host:"192.168.100.10:27418"},{_id:2,host:"192.168.100.10:27518"}]}
{
	"_id" : "myshardrs02",
	"members" : [
		{
			"_id" : 0,
			"host" : "192.168.100.10:27318"
		},
		{
			"_id" : 1,
			"host" : "192.168.100.10:27418"
		},
		{
			"_id" : 2,
			"host" : "192.168.100.10:27518"
		}
	]
}

#复制集初始化
> rs.initiate(config)
{ "ok" : 1 }
myshardrs02:OTHER> 
myshardrs02:PRIMARY>

配置节点副本集创建

  • 准备存放数据和日志的目录
[root@mongodb ~]# mkdir -p /mongodb/sharded_cluster/myconfigrs_27019/log
[root@mongodb ~]# mkdir -p /mongodb/sharded_cluster/myconfigrs_27019/data/db

[root@mongodb ~]# mkdir -p /mongodb/sharded_cluster/myconfigrs_27119/log
[root@mongodb ~]# mkdir -p /mongodb/sharded_cluster/myconfigrs_27119/data/db

[root@mongodb ~]# mkdir -p /mongodb/sharded_cluster/myconfigrs_27219/log
[root@mongodb ~]# mkdir -p /mongodb/sharded_cluster/myconfigrs_27219/data/db
  • 新建或修改配置文件27019
[root@mongodb ~]# vim /mongodb/sharded_cluster/myconfigrs_27019/mongod.conf
systemLog:
  # MongoDB发送所有日志输出的目标指定为文件
  destination: file
  # 当mongos或mongod实例重新启动时,mongos或mongod会将新条目附加到现有日志文件的末尾。
  logAppend: true
  # mongod或mongos应向其发送所有诊断日志记录信息的日志文件的路径
  path: /mongodb/sharded_cluster/myconfigrs_27019/log/mongod.log

storage:
  # mongod实例存储其数据的目录。storage.dbPath设置仅使用mongod。
  dbPath: /mongodb/sharded_cluster/myconfigrs_27019/data/db
  journal:
    # 启用或禁用持久化日志以确保数据文件保持有效和可恢复
    enabled: true

processManagement:
  # 启用在后台运行mongos或mongod进程的守护进程模式
  fork: true
  # 指定用于保存mongod或mongos进程的进程ID的文件位置其中mongos或mongod将写入其PID
  pidFilePath: /mongodb/sharded_cluster/myconfigrs_27019/log/mongod.pid
  timeZoneInfo: /usr/share/zoneinfo

net:
  # 服务实例绑定所有ip,有副作用,副本集初始化的时候,节点名字会自动设置为本地域名,而不是ip
  # bindIpAll: true
  # 服务实例绑定的IP
  bindIp: 0.0.0.0
  port: 27019

replication:
  # 二进制日志文件,到达2048MB,之前的日志将丢弃
  oplogSizeMB: 2048
  # 副本集的名称
  replSetName: myconfigrs
sharding:
  # 分片角色
  clusterRole: configsvr
  • 新建或修改配置文件27119
[root@mongodb ~]# vim /mongodb/sharded_cluster/myconfigrs_27119/mongod.conf
systemLog:
  # MongoDB发送所有日志输出的目标指定为文件
  destination: file
  # 当mongos或mongod实例重新启动时,mongos或mongod会将新条目附加到现有日志文件的末尾。
  logAppend: true
  # mongod或mongos应向其发送所有诊断日志记录信息的日志文件的路径
  path: /mongodb/sharded_cluster/myconfigrs_27119/log/mongod.log

storage:
  # mongod实例存储其数据的目录。storage.dbPath设置仅使用mongod。
  dbPath: /mongodb/sharded_cluster/myconfigrs_27119/data/db
  journal:
    # 启用或禁用持久化日志以确保数据文件保持有效和可恢复
    enabled: true

processManagement:
  # 启用在后台运行mongos或mongod进程的守护进程模式
  fork: true
  # 指定用于保存mongod或mongos进程的进程ID的文件位置其中mongos或mongod将写入其PID
  pidFilePath: /mongodb/sharded_cluster/myconfigrs_27119/log/mongod.pid
  timeZoneInfo: /usr/share/zoneinfo

net:
  # 服务实例绑定所有ip,有副作用,副本集初始化的时候,节点名字会自动设置为本地域名,而不是ip
  # bindIpAll: true
  # 服务实例绑定的IP
  bindIp: 0.0.0.0
  port: 27119

replication:
  # 二进制日志文件,到达2048MB,之前的日志将丢弃
  oplogSizeMB: 2048
  # 副本集的名称
  replSetName: myconfigrs
sharding:
  # 分片角色
  clusterRole: configsvr
  • 新建或修改配置文件27219
[root@mongodb ~]# vim /mongodb/sharded_cluster/myconfigrs_27219/mongod.conf
systemLog:
  # MongoDB发送所有日志输出的目标指定为文件
  destination: file
  # 当mongos或mongod实例重新启动时,mongos或mongod会将新条目附加到现有日志文件的末尾。
  logAppend: true
  # mongod或mongos应向其发送所有诊断日志记录信息的日志文件的路径
  path: /mongodb/sharded_cluster/myconfigrs_27219/log/mongod.log

storage:
  # mongod实例存储其数据的目录。storage.dbPath设置仅使用mongod。
  dbPath: /mongodb/sharded_cluster/myconfigrs_27219/data/db
  journal:
    # 启用或禁用持久化日志以确保数据文件保持有效和可恢复
    enabled: true

processManagement:
  # 启用在后台运行mongos或mongod进程的守护进程模式
  fork: true
  # 指定用于保存mongod或mongos进程的进程ID的文件位置其中mongos或mongod将写入其PID
  pidFilePath: /mongodb/sharded_cluster/myconfigrs_27219/log/mongod.pid
  timeZoneInfo: /usr/share/zoneinfo

net:
  # 服务实例绑定所有ip,有副作用,副本集初始化的时候,节点名字会自动设置为本地域名,而不是ip
  # bindIpAll: true
  # 服务实例绑定的IP
  bindIp: 0.0.0.0
  port: 27219

replication:
  # 二进制日志文件,到达2048MB,之前的日志将丢弃
  oplogSizeMB: 2048
  # 副本集的名称
  replSetName: myconfigrs
sharding:
  # 分片角色
  clusterRole: configsvr
  • 启动配置副本集:一主两副本
#依次启动三个Mongod服务
[root@mongodb ~]# mongod -f /mongodb/sharded_cluster/myconfigrs_27019/mongod.conf
about to fork child process, waiting until server is ready for connections.
forked process: 2145
child process started successfully, parent exiting

[root@mongodb ~]# mongod -f /mongodb/sharded_cluster/myconfigrs_27119/mongod.conf
about to fork child process, waiting until server is ready for connections.
forked process: 2202
child process started successfully, parent exiting

[root@mongodb ~]# mongod -f /mongodb/sharded_cluster/myconfigrs_27219/mongod.conf
about to fork child process, waiting until server is ready for connections.
forked process: 2259
child process started successfully, parent exiting
  • 查看服务是否启动
#此时已启动9个Mongo服务
[root@mongodb ~]# ps -ef | grep -v grep | grep mongodb
  • 初始化副本集和创建主节点
    • 使用客户端命令连接任意一个节点,但这里尽量要连接主节点
[root@mongodb ~]# mongo --host 192.168.100.10 --port 27019

#配置复制集
> config={_id:"myconfigrs",members:[{_id:0,host:"192.168.100.10:27019"},{_id:1,host:"192.168.100.10:27119"},{_id:2,host:"192.168.100.10:27219"}]}
{
	"_id" : "myconfigrs",
	"members" : [
		{
			"_id" : 0,
			"host" : "192.168.100.10:27019"
		},
		{
			"_id" : 1,
			"host" : "192.168.100.10:27119"
		},
		{
			"_id" : 2,
			"host" : "192.168.100.10:27219"
		}
	]
}

#初始化复制集
> rs.initiate(config)
{
	"ok" : 1,
	"$gleStats" : {
		"lastOpTime" : Timestamp(1626430211, 1),
		"electionId" : ObjectId("000000000000000000000000")
	},
	"lastCommittedOpTime" : Timestamp(0, 0)
}
myconfigrs:SECONDARY> 
myconfigrs:PRIMARY>

路由节点的创建和操作

第一个路由节点的创建和连接

  • 准备日志存放目录
[root@mongodb ~]# mkdir -p /mongodb/sharded_cluster/mymongos_27017/log
  • 新建或修改配置文件
[root@mongodb ~]# vim /mongodb/sharded_cluster/mymongos_27017/mongos.conf
systemLog:
  # MongoDB发送所有日志输出的目标指定为文件
  destination: file
  # 当mongos或mongod实例重新启动时,mongos或mongod会将新条目附加到现有日志文件的末尾。
  logAppend: true
  # mongod或mongos应向其发送所有诊断日志记录信息的日志文件的路径
  path: /mongodb/sharded_cluster/mymongos_27017/log/mongod.log

processManagement:
  # 启用在后台运行mongos或mongod进程的守护进程模式
  fork: true
  # 指定用于保存mongod或mongos进程的进程ID的文件位置其中mongos或mongod将写入其PID
  pidFilePath: /mongodb/sharded_cluster/mymongos_27017/log/mongod.pid
  timeZoneInfo: /usr/share/zoneinfo

net:
  # 服务实例绑定所有ip,有副作用,副本集初始化的时候,节点名字会自动设置为本地域名,而不是ip
  # bindIpAll: true
  # 服务实例绑定的IP
  bindIp: 0.0.0.0
  port: 27017

sharding:
  # 指定配置节点副本集
  configDB: myconfigrs/192.168.100.10:27019,192.168.100.10:27119,192.168.100.10:27219
  • 启动Mongos
    • 如果启动失败,可以查看log目录下的日志,查看失败原因
[root@mongodb ~]# mongos -f /mongodb/sharded_cluster/mymongos_27017/mongos.conf 
about to fork child process, waiting until server is ready for connections.
forked process: 2376
child process started successfully, parent exiting
  • 客户端登陆Mongos
[root@mongodb ~]# mongo --host 192.168.100.10 --port 27017
mongos>

路由节点进行分片操作

mongos> use admin
#添加第一套分片副本
mongos> db.runCommand ({ addshard : "myshardrs01/192.168.100.10:27018,192.168.100.10:27118,192.168.100.10:27218",name:"shard1"})
{
	"shardAdded" : "shard1",
	"ok" : 1,
	"$clusterTime" : {
		"clusterTime" : Timestamp(1626433783, 4),
		"signature" : {
			"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
			"keyId" : NumberLong(0)
		}
	},
	"operationTime" : Timestamp(1626433783, 4)
}

#添加第二套分片副本
mongos> db.runCommand ({ addshard : "myshardrs02/192.168.100.10:27318,192.168.100.10:27418,192.168.100.10:27518",name:"shard2"})
{
	"shardAdded" : "shard2",
	"ok" : 1,
	"$clusterTime" : {
		"clusterTime" : Timestamp(1626434057, 4),
		"signature" : {
			"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
			"keyId" : NumberLong(0)
		}
	},
	"operationTime" : Timestamp(1626434057, 4)
}

#列出分片
mongos> db.runCommand ({ listshards : 1 })
{
	"shards" : [
		{
			"_id" : "shard1",
			"host" : "myshardrs01/192.168.100.10:27018,192.168.100.10:27118,192.168.100.10:27218",
			"state" : 1,
			"topologyTime" : Timestamp(1626433783, 1)
		},
		{
			"_id" : "shard2",
			"host" : "myshardrs02/192.168.100.10:27318,192.168.100.10:27418,192.168.100.10:27518",
			"state" : 1,
			"topologyTime" : Timestamp(1626434057, 2)
		}
	],
	"ok" : 1,
	"$clusterTime" : {
		"clusterTime" : Timestamp(1626434108, 4),
		"signature" : {
			"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
			"keyId" : NumberLong(0)
		}
	},
	"operationTime" : Timestamp(1626434108, 4)
}

#整体状态查看
mongos> sh.status()

在这里插入图片描述

  • 如果添加分片失败,需要先手动移除分片,检查添加分片的信息的正确性后,再次添加分片。
  • 移除分片参考
use admin
db.runCommand({ removeShard: "myshardrs02" })
  • 如果只剩下最后一个shard,是无法删除的!
    • 移除时会自动转移分片数据,需要一个时间过程
    • 完成后,再次执行删除分片命令才能真正删除

开启分片功能

sh.enableSharding("库名")、sh.shardCollection("库名.集合名",{"key":1})
  • 在mongos上的articledb数据库配置sharding
mongos> use admin
switched to db admin

#开启分片功能
mongos> sh.enableSharding("articledb"<

以上是关于MongoDB——MongoDB分片集群(Sharded Cluster)的主要内容,如果未能解决你的问题,请参考以下文章

MongoDB——MongoDB分片集群(Sharded Cluster)两种搭建方式

Docker——基于Docker搭建MongoDB分片集群

mongoDB分片集群

MongoDB——MongoDB分片集群(Sharded Cluster)

MongoDB分片集群搭建

mongoDB mongoDB分片集群