主从复制是一个简单的数据库同步备份的集群技术
master.conf
dbpath=E:\ms\master
port=1000
master=true
master.bat
mongod --config master.conf
slave.conf
dbpath=E:\p\slave
port=1001
slave=true
source=127.0.0.1:1000
slave.bat
mongod --config slave.conf
rs.slaveOk();
登录从服务器
use local;
show collections;
db.sources.find();
//{ "host" : "127.0.0.1:8000", "source" : "main", "syncedTo" : Timestamp(1524728329, 1) }
db.sources.insert({host:'127.0.0.1:8000'});//挂载主节点
db.sources.remove({host:'127.0.0.1:8000'});//删除已经挂载的主节点
A服务器
dbpath=E:\repl\repl1
port=2001
replSet=group
B服务器
dbpath=E:\repl\repl2
port=2002
replSet=group
C服务器
dbpath=E:\repl\repl3
port=2003
replSet=group
use admin;
var conf=
{
"_id" : "group",
"members" : [
{ "_id" : 0, "host" : "127.0.0.1:2001" },
{ "_id" : 1, "host" : "127.0.0.1:2002" },
{ "_id" : 2, "host" : "127.0.0.1:2003" }
]
}
rs.initiate(conf);
rs.status();
一般情况下作为副本节点是不能进行数据库操作的,但是在读取密集的系统中读写分离是必要的
rs.slaveOk();
它被存储在本地数据库local中,会记录每一个操作。 如果希望在故障恢复的时候尽可能更多,可以把这个size设置的大一点
--oplogSize 1024
use local;
db.oplog.rs.find().limit(2);
在Mongodb里面存在另一种集群,就是分片技术,可以满足MongoDB数据量大量增长的需求。 当MongoDB存储海量的数据时,一台机器可能不足以存储数据,也可能不足以提供可接受的读写吞吐量。这时,我们就可以通过在多台机器上分割数据,使得数据库系统能存储和处理更多的数据。
路由根据片键把不同的文档保存到不同的分片中
mkdir E:\repl\db2001
mongod --port 2001 --dbpath=/data/db2001 --shardsvr --replSet=shard1
mkdir E:\repl/db2002
mongod --port 2002 --dbpath=/data/db2002 --shardsvr --replSet=shard1
# mongo localhost:2001
rs.initiate({_id: 'shard1', members: [{_id: 0, host: 'localhost:2001'}, {_id: 1, host: 'localhost:2002'}]})
rs.isMaster() #查看主从关系
mkdir E:\repl\db2003
mongod --port 2003 --dbpath=E:\repl\db2003 --shardsvr --replSet=shard2
mkdir E:\repl\db2004
mongod --port 2004 --dbpath=E:\repl\db2004 --shardsvr --replSet=shard2
# mongo localhost:2003
rs.initiate({_id: 'shard2', members: [{_id: 0, host: 'localhost:2003'}, {_id: 1, host: 'localhost:2004'}]})
rs.isMaster() #查看主从关系
mkdir E:\repl\db2005
mongod --port 2005 --dbpath=E:\repl\db2005 --shardsvr --replSet=config
mkdir E:\repl\db2006
mongod --port 2006 --dbpath=E:\repl\db2006 --shardsvr --replSet=config
# mongo localhost:2005
rs.initiate({_id: 'config', members: [{_id: 0, host: 'localhost:2005'}, {_id: 1, host: 'localhost:2006'}]})
rs.isMaster() #查看主从关系
路由器调用mongos命令
mongos --port 2006 --configdb config/localhost:2005,localhost:2006
mongo localhost:2006
use admin
> db.runCommand({ addshard: 'shard1/localhost:2001,localhost:2002'})
> db.runCommand({ addshard: 'shard2/localhost:2003,localhost:2004'})
use admin;
> db.runCommand({ enablesharding: 'school'})
> db.runCommand({ shardcollection: 'school.students', key: {name: 1}})