mongodb数据库分片

本文涉及的产品
云数据库 MongoDB,独享型 2核8GB
推荐场景:
构建全方位客户视图
简介: --配置config server[mongodb@rudy_01 2.6]$ mkdir 27018[mongodb@rudy_01 2.
--配置config server
[mongodb@rudy_01 2.6]$ mkdir 27018
[mongodb@rudy_01 2.6]$ mkdir log/27018

--mongo配置文件
dbpath=/usr/local/mongodb/2.6/27018
fork=1
logpath=/usr/local/mongodb/2.6/log/27018/mongo.log
port=27018
maxConns=100
oplogSize=100
logappend=true
directoryperdb=1

--启动配置服务器,配置服务器一定要先启动
 mongod -f /usr/local/mongodb/2.6/27018/mongodb.conf 


 --mongos路由配置文件
 port=4000
 configdb=rudy_01:27018
 fork=1
 logpath=/usr/local/mongodb/2.6/log/4000/mongo.log
 chunkSize=1

 --启动mongos路由
 mongos -f /usr/local/mongodb/2.6/mongos.conf 



--配置shard server
[mongodb@rudy_01 2.6]$ mkdir 27019
[mongodb@rudy_01 2.6]$ mkdir 27020
[mongodb@rudy_01 2.6]$ mkdir 27021
[mongodb@rudy_01 2.6]$ mkdir log/27019
[mongodb@rudy_01 2.6]$ mkdir log/27020
[mongodb@rudy_01 2.6]$ mkdir log/27021

--配置保个节点的配置文件
dbpath=/usr/local/mongodb/2.6/27019
fork=1
logpath=/usr/local/mongodb/2.6/log/27019/mongo.log
port=27019
maxConns=100
oplogSize=100
logappend=true
directoryperdb=1


dbpath=/usr/local/mongodb/2.6/27020
fork=1
logpath=/usr/local/mongodb/2.6/log/27020/mongo.log
port=27020
maxConns=100
oplogSize=100
logappend=true
directoryperdb=1


dbpath=/usr/local/mongodb/2.6/27021
fork=1
logpath=/usr/local/mongodb/2.6/log/27021/mongo.log
port=27021
maxConns=100
oplogSize=100
logappend=true
directoryperdb=1

--启动数据库
mongod -f /usr/local/mongodb/2.6/27019/mongodb.conf
mongod -f /usr/local/mongodb/2.6/27020/mongodb.conf
mongod -f /usr/local/mongodb/2.6/27021/mongodb.conf


--配置sharding
--登陆到路由节点
mongo admin --port 4000 
--添加shard节点
db.runCommand({"addshard":"rudy_01:27019"})
db.runCommand({"addshard":"rudy_01:27020"})
db.runCommand({"addshard":"rudy_01:27021"})
--设置分片集合名称
db.runCommand({"enablesharding":"test"})
db.runCommand({"shardcollection":"test.personalinfo",key:{_id:1}})


--验证sharding
for (var i=1;i<=100000;i++){
db.personalinfo.insert({age:i,name:"rudy"+i,addr:"上海宝山区"+i+"路",country:"中国"});
}
--查看文档状态,可知数据已经被分片处理
db.personalinfo.stats()
mongos> db.personalinfo.stats()
{
        "sharded" : true,
        "systemFlags" : 1,
        "userFlags" : 1,
        "ns" : "test.personalinfo",
        "count" : 100000,
        "numExtents" : 18,
        "size" : 11200000,
        "storageSize" : 33546240,
        "totalIndexSize" : 3270400,
        "indexSizes" : {
                "_id_" : 3270400
        },
        "avgObjSize" : 112,
        "nindexes" : 1,
        "nchunks" : 12,
        "shards" : {
                "shard0000" : {
                        "ns" : "test.personalinfo",
                        "count" : 36540,
                        "size" : 4092480,
                        "avgObjSize" : 112,
                        "storageSize" : 11182080,
                        "numExtents" : 6,
                        "nindexes" : 1,
                        "lastExtentSize" : 8388608,
                        "paddingFactor" : 1,
                        "systemFlags" : 1,
                        "userFlags" : 1,
                        "totalIndexSize" : 1193696,
                        "indexSizes" : {
                                "_id_" : 1193696
                        },
                        "ok" : 1
                },
                "shard0001" : {
                        "ns" : "test.personalinfo",
                        "count" : 31994,
                        "size" : 3583328,
                        "avgObjSize" : 112,
                        "storageSize" : 11182080,
                        "numExtents" : 6,
                        "nindexes" : 1,
                        "lastExtentSize" : 8388608,
                        "paddingFactor" : 1,
                        "systemFlags" : 0,
                        "userFlags" : 1,
                        "totalIndexSize" : 1046528,
                        "indexSizes" : {
                                "_id_" : 1046528
                        },
                        "ok" : 1
                },
                "shard0002" : {
                        "ns" : "test.personalinfo",
                        "count" : 31466,
                        "size" : 3524192,
                        "avgObjSize" : 112,
                        "storageSize" : 11182080,
                        "numExtents" : 6,
                        "nindexes" : 1,
                        "lastExtentSize" : 8388608,
                        "paddingFactor" : 1,
                        "systemFlags" : 0,
                        "userFlags" : 1,
                        "totalIndexSize" : 1030176,
                        "indexSizes" : {
                                "_id_" : 1030176
                        },
                        "ok" : 1
                }
        },
        "ok" : 1
}



--列出所有的shard server
db.runCommand({listshards:1})

--查看数据库文档分片的详细信息
db.printShardingStatus()

--判断是否是分片
db.runCommand({isdbgrid:1})


--对未分片的集合进行分片
--构建测试数据
for (var i=1;i<=100000;i++){
db.user.insert({age:i,name:"未分片的id:"+i,country:"中国"});
}
--查看文档状态
db.user.status()

--对文档进行分片
use admin
db.runCommand({"shardcollection":"test.user","key":{_id:1}})


--移除一个分片数据库,要多执行几次,查看数据库的进程状态,直到提示已完成
use admin
db.runCommand({"removeshard":"rudy_01:27021"})

--注意最后一个移除主机上的count=0,size=0 
mongos> db.user.stats()
{
        "sharded" : true,
        "systemFlags" : 1,
        "userFlags" : 1,
        "ns" : "test.user",
        "count" : 100000,
        "numExtents" : 19,
        "size" : 11200000,
        "storageSize" : 44871680,
        "totalIndexSize" : 3981712,
        "indexSizes" : {
                "_id_" : 3981712
        },
        "avgObjSize" : 112,
        "nindexes" : 1,
        "nchunks" : 22,
        "shards" : {
                "shard0000" : {
                        "ns" : "test.user",
                        "count" : 48499,
                        "size" : 5431888,
                        "avgObjSize" : 112,
                        "storageSize" : 22507520,
                        "numExtents" : 7,
                        "nindexes" : 1,
                        "lastExtentSize" : 11325440,
                        "paddingFactor" : 1,
                        "systemFlags" : 1,
                        "userFlags" : 1,
                        "totalIndexSize" : 1945888,
                        "indexSizes" : {
                                "_id_" : 1945888
                        },
                        "ok" : 1
                },
                "shard0001" : {
                        "ns" : "test.user",
                        "count" : 51501,
                        "size" : 5768112,
                        "avgObjSize" : 112,
                        "storageSize" : 11182080,
                        "numExtents" : 6,
                        "nindexes" : 1,
                        "lastExtentSize" : 8388608,
                        "paddingFactor" : 1,
                        "systemFlags" : 0,
                        "userFlags" : 1,
                        "totalIndexSize" : 2027648,
                        "indexSizes" : {
                                "_id_" : 2027648
                        },
                        "ok" : 1
                },
                "shard0002" : {
                        "ns" : "test.user",
                        "count" : 0,
                        "size" : 0,
                        "storageSize" : 11182080,
                        "numExtents" : 6,
                        "nindexes" : 1,
                        "lastExtentSize" : 8388608,
                        "paddingFactor" : 1,
                        "systemFlags" : 0,
                        "userFlags" : 1,
                        "totalIndexSize" : 8176,
                        "indexSizes" : {
                                "_id_" : 8176
                        },
                        "ok" : 1
                }
        },
        "ok" : 1
}
mongos> 

--新增分片数据库,
db.runCommand({addshard:"rudy_01:27021"})
--注意新添加的分片中不能存在已经分片的数据库,如果有要删除,否则会报错
"errmsg" : "can't add shard rudy_01:27021 because a local database 'test' exists in another shard0000:rudy_01:27019"
--此时登陆到相应的主机删除数据库则可
use test
db.runCommand( { dropDatabase: 1 } )

相关实践学习
MongoDB数据库入门
MongoDB数据库入门实验。
快速掌握 MongoDB 数据库
本课程主要讲解MongoDB数据库的基本知识,包括MongoDB数据库的安装、配置、服务的启动、数据的CRUD操作函数使用、MongoDB索引的使用(唯一索引、地理索引、过期索引、全文索引等)、MapReduce操作实现、用户管理、Java对MongoDB的操作支持(基于2.x驱动与3.x驱动的完全讲解)。 通过学习此课程,读者将具备MongoDB数据库的开发能力,并且能够使用MongoDB进行项目开发。 &nbsp; 相关的阿里云产品:云数据库 MongoDB版 云数据库MongoDB版支持ReplicaSet和Sharding两种部署架构,具备安全审计,时间点备份等多项企业能力。在互联网、物联网、游戏、金融等领域被广泛采用。 云数据库MongoDB版(ApsaraDB for MongoDB)完全兼容MongoDB协议,基于飞天分布式系统和高可靠存储引擎,提供多节点高可用架构、弹性扩容、容灾、备份回滚、性能优化等解决方案。 产品详情: https://www.aliyun.com/product/mongodb
目录
相关文章
|
2天前
|
存储 JSON NoSQL
学习 MongoDB:打开强大的数据库技术大门
MongoDB 是一个基于分布式文件存储的文档数据库,由 C++ 编写,旨在为 Web 应用提供可扩展的高性能数据存储解决方案。它与 MySQL 类似,但使用文档结构而非表结构。核心概念包括:数据库(Database)、集合(Collection)、文档(Document)和字段(Field)。MongoDB 使用 BSON 格式存储数据,支持多种数据类型,如字符串、整数、数组等,并通过二进制编码实现高效存储和传输。BSON 文档结构类似 JSON,但更紧凑,适合网络传输。
27 15
|
10天前
|
存储 NoSQL 关系型数据库
阿里云数据库MongoDB版助力信也科技 打造互联网金融企业样板
我们的风控系统引入阿里云数据库MongoDB版后,解决了特征类字段灵活加减的问题,大大提高了开发效率,极大的提升了业务用户体验,获得了非常好的效果
阿里云数据库MongoDB版助力信也科技 打造互联网金融企业样板
|
1月前
|
NoSQL Cloud Native atlas
探索云原生数据库:MongoDB Atlas 的实践与思考
【10月更文挑战第21天】本文探讨了MongoDB Atlas的核心特性、实践应用及对云原生数据库未来的思考。MongoDB Atlas作为MongoDB的云原生版本,提供全球分布式、完全托管、弹性伸缩和安全合规等优势,支持快速部署、数据全球化、自动化运维和灵活定价。文章还讨论了云原生数据库的未来趋势,如架构灵活性、智能化运维和混合云支持,并分享了实施MongoDB Atlas的最佳实践。
|
2月前
|
NoSQL Cloud Native atlas
探索云原生数据库:MongoDB Atlas 的实践与思考
【10月更文挑战第20天】本文探讨了MongoDB Atlas的核心特性、实践应用及对未来云原生数据库的思考。MongoDB Atlas作为云原生数据库服务,具备全球分布、完全托管、弹性伸缩和安全合规等优势,支持快速部署、数据全球化、自动化运维和灵活定价。文章还讨论了实施MongoDB Atlas的最佳实践和职业心得,展望了云原生数据库的发展趋势。
|
2月前
|
存储 NoSQL MongoDB
MongoDB 数据库引用
10月更文挑战第20天
23 1
|
2月前
|
存储 关系型数据库 MySQL
一个项目用5款数据库?MySQL、PostgreSQL、ClickHouse、MongoDB区别,适用场景
一个项目用5款数据库?MySQL、PostgreSQL、ClickHouse、MongoDB——特点、性能、扩展性、安全性、适用场景比较
|
3月前
|
存储 NoSQL 关系型数据库
非关系型数据库-MongoDB技术(二)
非关系型数据库-MongoDB技术(二)
|
3月前
|
NoSQL 关系型数据库 MongoDB
非关系型数据库-MongoDB技术(一)
非关系型数据库-MongoDB技术(一)
|
2月前
|
存储 NoSQL Shell
MongoDB 创建数据库
10月更文挑战第12天
84 4
|
2月前
|
存储 NoSQL MongoDB
基于阿里云数据库MongoDB版,微财数科“又快又稳”服务超7000万客户
选择MongoDB主要基于其灵活的数据模型、高性能、高可用性、可扩展性、安全性和强大的分析能力。
下一篇
DataWorks