Java測試mongodb叢集(分片+副本集)
阿新 • • 發佈:2018-12-30
需要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.資料庫驗證:如下圖所示: