MongoDB-集群搭建

條件有限，只在一臺機器上模擬部署一下，相關參數就不寫在配置文件里了，直接使用命令指定參數
這裡我模擬三個伺服器分別為 serverA，serverB，serverC
我是通過修改/etc/hosts 將他們d綁定到 127.0.0.1
# cat /etc/hosts
127.0.0.1   localhost localhost.localdomain localhost4 localhost4.localdomain4
::1         localhost localhost.localdomain localhost6 localhost6.localdomain6
127.0.0.1   serverA serverB serverC

首先說明一下集群規劃：
2個副本集用來分片
3個mongos路由服務
3個config配置伺服器

如果是三台不同的伺服器，完全可以用相同的埠號，這裡都在同一個機器上，分配一下埠號：

整體規劃圖：

創建各自數據文件目錄
# mkdir -p /data/serverA /data/serverB /data/serverC
# mkdir -p /data/serverA/config /data/serverB/config /data/serverC/config
# mkdir -p /data/serverA/rs0 /data/serverA/rs1 /data/serverB/rs0 /data/serverB/rs1 /data/serverC/rs0 /data/serverC/rs1

然後分別啟動分片伺服器副本集，配置伺服器，路由伺服器

啟動serverA 伺服器相關mongo服務
mongod --shardsvr --replSet rs0 --port 27100 --dbpath /data/serverA/rs0 --logpath /data/serverA/rs0.log --logappend --directoryperdb --fork
mongod --shardsvr --replSet rs1 --port 28100 --dbpath /data/serverA/rs1 --logpath /data/serverA/rs1.log --logappend --directoryperdb --fork

mongod --configsvr --port 20000 --dbpath /data/serverA/config --logpath /data/serverA/config.log --logappend --directoryperdb --fork
mongos --configdb serverA:20000,serverB:21000,serverC:22000 --port=30000 --chunkSize=1 --logpath=/data/serverA/mongos.log --logappend --fork

其他伺服器啟動只是更改埠號和數據文件存儲目錄，這裡就不再贅述，這裡指定了分片時的塊chunks大小為1M，能夠更塊的實現分片，其大小預設為64M

全部啟動完成後，接下來配置副本集，配置分片。

配置副本集rs0：

連接到rs0任意一個節點

# mongo --port 27100
> use admin
switched to db admin
> config = {_id:"rs0", members:[{_id:0, host:"serverA:27100"}, {_id:1, host:"serverB:27200"}, {_id:2, host:"serverC:27300"}]}
> rs.initiate(config)
{ "ok" : 1 }
rs0:PRIMARY> rs.status()   查看副本集狀態

預設情況下，次要節點是不能讀取的，對每個副本集成員連接mongo shell 執行一下命令開啟讀取
> db.getMongo().setSlaveOk()

rs1配置的步驟一樣
config = {_id:"rs1", members:[{_id:0, host:"serverA:28100"}, {_id:1, host:"serverB:28200"}, {_id:2, host:"serverC:28300"}]}

配置分片伺服器：

連接到任意路由伺服器

# mongo --port 30000
mongos> use admin
switched to db admin
mongos> db.runCommand({"addshard":"rs0/serverA:27100,serverB:27200,serverC:27300", allowLocal:true})
{ "shardAdded" : "rs0", "ok" : 1 }
mongos> db.runCommand({"addshard":"rs1/serverA:28100,serverB:28200,serverC:28300", allowLocal:true})
{ "shardAdded" : "rs1", "ok" : 1 }
mongos> sh.status()
--- Sharding Status ---
  sharding version: {
        "_id" : 1,
        "minCompatibleVersion" : 5,
        "currentVersion" : 6,
        "clusterId" : ObjectId("571cacbe3b647b1179b65adf")
}
  shards:
        {  "_id" : "rs0",  "host" : "rs0/serverA:27100,serverB:27200,serverC:27300" }
        {  "_id" : "rs1",  "host" : "rs1/serverA:28100,serverB:28200,serverC:28300" }
  balancer:
        Currently enabled:  yes
        Currently running:  no
        Failed balancer rounds in last 5 attempts:  0
        Migration Results for the last 24 hours:
                No recent migrations
  databases:
        {  "_id" : "admin",  "partitioned" : false,  "primary" : "config" }

Ok配置完畢，現在激活一個集合進行測試
mongos> sh.enableSharding("foo")
{ "ok" : 1 }
mongos> sh.shardCollection("foo.bar",{inc:1})
{ "collectionsharded" : "foo.bar", "ok" : 1 }

向集群插入50萬條記錄，文檔格式為{"inc":i, "timestamp":new Date()}
# mongo --port 30000
mongos> use foo
switched to db foo
mongos> for(var i=1; i<=500000; i++){ db.bar.insert({"inc":i, "timestamp":new Date()}) }

插入完畢我們查看一下mongodb的狀態，數據已經均勻分佈到兩個分片伺服器上

那麼每個副本集就都應該擁有一份數據的副本，來查看一下，如果連接不是副本集的主節點，並且在讀取時報錯，請執行> db.getMongo().setSlaveOk()
分別連接到27100和27200副本集的成員
查看foo資料庫中，bar集合的總數
# mongo --port 27100
rs0:PRIMARY> use foo
switched to db foo
rs0:PRIMARY> db.bar.count()
251002

# mongo --port 27200
rs0:SECONDARY> db.getMongo().setSlaveOk()
rs0:SECONDARY> use foo
rs0:SECONDARY> db.bar.count()
251002
可以看到，數據已經成功複製

訪問控制
預設情況下，MongoDB不啟動訪問控制，對於單機模式啟動訪問控制，只需在啟動mongod 服務時添加 --auth 參數即可，但是在分片集群時，只能使用 keyfile的方式啟動訪問控制
首先生成 keyfile文件，並把這個文件複製到其他伺服器上
# openssl rand -base64 741 > /data/mongodb/mongodb-keyfile
# chmod 600 mongodb-keyfile 重要

在啟動訪問控制之前，先添加一個超級管理員用戶admin密碼111111
連接任意一個mongos
# mongo --port 30000
mongos> use admin
switched to db admin
mongos> db.createUser({user:"admin", pwd:"111111", roles:[{role: "root", db: "admin" }]})
Successfully added user: {
        "user" : "admin",
        "roles" : [
                {
                        "role" : "root",
                        "db" : "admin"
                }
        ]
}
開啟訪問控制很簡單，只需要重啟集群，併在每個服務啟動時添加 --keyFile /data/mongodb/mongodb-keyfile 即可

mongod --configsvr --port 20000 --dbpath /data/serverA/config --logpath /data/serverA/config.log --logappend --directoryperdb --fork --keyFile /data/mongodb/mongodb-keyfile
mongod --shardsvr --replSet rs0 --port 27100 --dbpath /data/serverA/rs0 --logpath /data/serverA/rs0.log --logappend --directoryperdb --fork --keyFile /data/mongodb/mongodb-keyfile
mongod --shardsvr --replSet rs1 --port 28100 --dbpath /data/serverA/rs1 --logpath /data/serverA/rs1.log --logappend --directoryperdb --fork --keyFile /data/mongodb/mongodb-keyfile
mongos --configdb serverA:20000,serverB:21000,serverC:22000 --port=30000 --chunkSize=1 --logpath=/data/serverA/mongos.log --logappend --fork --keyFile /data/mongodb/mongodb-keyfile

這樣在連接到集群時，操作前前就需要驗證用戶身份了，驗證有兩種方式
一個是在連接時驗證：mongo --port 30000 -u "admin" -p "111111" --authenticationDatabase "admin"
一個是連接後驗證：> use admin > db.auth("admin", "111111")

end
接下來使用Java驅動對集群操作一下