1. 程式人生 > >Java測試mongodb叢集(分片+副本集)

Java測試mongodb叢集(分片+副本集)

需要Java-mongo驅動jar包,官網下載:mongo-java-driver-3.5.0.jar

1.建立專案TestMongoDBShards,(具體建立專案參考楊海文件–IDEA開發工具的安裝及使用)匯入驅動jar包。點選 File -> Project Structure(快捷鍵 Ctrl + Alt + Shift + s);如下圖所示:
這裡寫圖片描述
2.點選Project Structure介面左側的“Modules”顯示下圖介面;“Dependencies” 標籤介面下,點選右邊綠色的 “+”號,如下圖所示:
這裡寫圖片描述
3.選擇第一個選項“JARs or directories…”,選擇相應的jar包,如下圖所示:
這裡寫圖片描述


4.點“OK”。
這裡寫圖片描述
5.jar包新增成功
這裡寫圖片描述
6.Java程式碼編譯:

public class TestMongoDBShards {

    public static void main(String[] args) {
        try {
            List<ServerAddress> addresses = new ArrayList<ServerAddress>();
            ServerAddress address1 = new ServerAddress("192.168.221.130" , 23000);
            ServerAddress address2 = new ServerAddress("192.168.221.131" , 23000);
            ServerAddress address3 = new ServerAddress("192.168.221.132" , 23000);
            addresses.add(address1);
            addresses.add(address2);
            addresses.add(address3);
            MongoClient client = new MongoClient(addresses);
            DB db = client.getDB( "testdb" );
            DBCollection coll = db.getCollection( "table1" );
            BasicDBObject object = new BasicDBObject();
            object.append( "id" , 100);
            DBObject dbObject = coll.findOne(object);
            System.out .println(dbObject);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

**如果是Springboot整合叢集地址為:

                 spring.data.mongodb.uri=mongodb://user:[email protected]:port1,ip2:port2/database

7.路由伺服器130,131,132都啟動,查詢ID為100的記錄。如下圖所示:
這裡寫圖片描述
8.在資料庫中驗證,如下圖所示:
這裡寫圖片描述
9.停掉130服務,繼續查詢id為100的資料,如下圖所示:
這裡寫圖片描述
這裡寫圖片描述
10.繼續將131服務也停掉,
這裡寫圖片描述
11.查詢id為100的記錄,如下圖所示:
這裡寫圖片描述
12.資料庫驗證:如下圖所示:
這裡寫圖片描述