搭建資料庫叢集從未如此簡單過, 想起做rac的時候, raid, lv, vg, 雙機互信, 建庫等一大堆弄下來, 在完全不出錯的情況下, 都要接近6個小時.

環境準備.

a). 作業系統, centos6.5 x86.64.

b). mongodb: mongodb-linux-x86_64-2.6.5.gz

解壓好mongodb之後就可以直接開始建叢集了.

1. 先建立6個資料夾.

/usr/local/mongodb-linux-x86_64-2.6.5/gmlogx/dat0

/usr/local/mongodb-linux-x86_64-2.6.5/gmlogx/dat1

/usr/local/mongodb-linux-x86_64-2.6.5/gmlogx

/dat2

/usr/local/mongodb-linux-x86_64-2.6.5/gmlogx/log0

/usr/local/mongodb-linux-x86_64-2.6.5/gmlogx/log1

/usr/local/mongodb-linux-x86_64-2.6.5/gmlogx/log2

2. 因為只有一臺機器, 所以使用了三個不同的埠, 開三個console, 依次執行下面的三條命令.

mongod --replSet gmlogx --dbpath=/usr/local/mongodb-2.6.5/gmlogx/dat0 --port 10000 --oplogSize=512 \
--logpath=/usr/local/mongodb-linux-x86_64-2.6.5/gmlogx/log0/log.log --logappend
mongod --replSet gmlogx --dbpath=/usr/local/mongodb-2.6.5/gmlogx/dat1 --port 10001 --oplogSize=512 \
--logpath=/usr/local/mongodb-linux-x86_64-2.6.5/gmlogx/log1/log.log --logappend
mongod --replSet gmlogx --dbpath=/usr/local/mongodb-2.6.5/gmlogx/dat2 --port 10002 --oplogSize=512 \
--logpath=/usr/local/mongodb-linux-x86_64-2.6.5/gmlogx/log2/log.log --logappend

3. 部分引數解釋: 

--replSet gmlogx, 指定了叢集的名稱gmlogx.

--port 10000, 指的是資料庫節點的服務埠為10000. 

--oplogSize=512, 指的是給mongdb的操作日誌緩衝區大小, 單位是M, 即512M. 這裡有個小坑. 如果不指定oplogSize的話, 兩個資料庫節點

就佔用了90G磁碟, 如下圖.

4. 我們的機器ip是192.168.1.117, 連線上其中一個接點, 依次鍵入下面的命令.

[[email protected] gmlogx]# mongo 192.168.1.117:10000
MongoDB shell version: 2.6.5
connecting to: 192.168.1.117:10000/test
> var cfg = {_id: "gmlogx", members: []}
> cfg.members.push({_id: 0, host: "192.168.1.117:10000"});
1
> cfg.members.push({_id: 1, host: "192.168.1.117:10001"});
2
> cfg.members.push({_id: 2, host: "192.168.1.117:10002", arbiterOnly: true});
3
> rs.initiate(cfg);
{
	"info" : "Config now saved locally.  Should come online in about a minute.",
	"ok" : 1
}
>
 

上面的arbiterOnly: true, 表示這是一個仲裁節點,  它僅用於選舉和協調另外兩個資料庫節點的主備關係.  仲裁節點本身不承載業務資料. 事實上

這種仲裁者的叢集環境不被<<mongodb權威指南>>推薦,  原話是: 如果可能, 儘量在副本集中使用奇數個數據成員, 而不要使用仲裁者.

這裡可能有個地方需要注意, 在敲上面的命令之前, 埠可能還沒有ready, 請先確認兩個資料庫節點的埠已經LISTEN

5.  退出mongo-shell, 重新進入一次就可以發現, 192.168.1.117:10000已經被選舉成主節點.

[[email protected] gmlogx]# mongo 192.168.1.117:10000
MongoDB shell version: 2.6.5
connecting to: 192.168.1.117:10000/test
gmlogx:PRIMARY> rs.status()
{
	"set" : "gmlogx",
	"date" : ISODate("2014-11-14T04:24:45Z"),
	"myState" : 1,
	"members" : [
		{
			"_id" : 0,
			"name" : "192.168.1.117:10000",
			"health" : 1,
			"state" : 1,
			"stateStr" : "PRIMARY",
			"uptime" : 1101,
			"optime" : Timestamp(1415938107, 1),
			"optimeDate" : ISODate("2014-11-14T04:08:27Z"),
			"electionTime" : Timestamp(1415938116, 1),
			"electionDate" : ISODate("2014-11-14T04:08:36Z"),
			"self" : true
		},
		{
			"_id" : 1,
			"name" : "192.168.1.117:10001",
			"health" : 1,
			"state" : 2,
			"stateStr" : "SECONDARY",
			"uptime" : 977,
			"optime" : Timestamp(1415938107, 1),
			"optimeDate" : ISODate("2014-11-14T04:08:27Z"),
			"lastHeartbeat" : ISODate("2014-11-14T04:24:44Z"),
			"lastHeartbeatRecv" : ISODate("2014-11-14T04:24:45Z"),
			"pingMs" : 0,
			"syncingTo" : "192.168.1.117:10000"
		},
		{
			"_id" : 2,
			"name" : "192.168.1.117:10002",
			"health" : 1,
			"state" : 7,
			"stateStr" : "ARBITER",
			"uptime" : 977,
			"lastHeartbeat" : ISODate("2014-11-14T04:24:44Z"),
			"lastHeartbeatRecv" : ISODate("2014-11-14T04:24:45Z"),
			"pingMs" : 0
		}
	],
	"ok" : 1
}
gmlogx:PRIMARY>

6.  建立一個database, 並嘗試插入一條記錄. 

gmlogx:PRIMARY> use gmlogx
switched to db gmlogx
gmlogx:PRIMARY> db.logx.insert({usr: 'usr', age: 32})
WriteResult({ "nInserted" : 1 })
gmlogx:PRIMARY> 

7. 通過java-driver進行查詢操作, 如果你想做到讀寫分離的效果, 可以直接訪問備節點(192.168.1.117:10001).

public static void main(String[] args) throws UnknownHostException
	{
		MongoOptions mo = new MongoOptions();
		List<ServerAddress> addr = Arrays.asList(new ServerAddress("192.168.1.117", 10000), new ServerAddress("192.168.1.117", 10001));
		mo.readPreference = ReadPreference.secondary(); /* 可從副本中讀取. */
		Mongo mg = new Mongo(addr, mo);
		DBCollection coll = mg.getDB("gmlogx").getCollection("logx");
		DBCursor cur = coll.find();
		while (cur.hasNext())
			System.out.println(cur.next());
	}