国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 開發 > Java > 正文

詳解Java 連接MongoDB集群的幾種方式

2024-07-14 08:43:03
字體:
來源:轉載
供稿:網友

先決條件

先運行mongodb肯定是必須的,然后導入以下包:

import com.mongodb.MongoClient;import com.mongodb.MongoClientURI;import com.mongodb.ServerAddress;import com.mongodb.MongoCredential;import com.mongodb.MongoClientOptions;

MongoClient

MongoClient()實例表示到數據庫的連接池; 你將只需要MongoClient類的一個實例,即使有多個線程也是一樣。

重要:

通常,您只能為給定的MongoDB部署(例如獨立,副本集或分片群集)創建一個MongoClient實例,并在您的應用程序中使用它。 但是,如果您創建了多個實例:

  • 所有資源使用限制(例如,最大連接等)適用于每個MongoClient實例。
  • 要關閉一個實例,調用MongoClient.close() 來清理資源。

連接到一個獨立的MongoDB實例

以下幾種方法:

1.

MongoClient mongoClient = new MongoClient( "host1" , 27017 );? 

2. You can specify theMongoClientURI connection string.

MongoClient mongoClient = new MongoClient(new MongoClientURI("mongodb://host1:27017"));

連接到副本集

MongoDB將自動發現主要和副本。

You can specify the members using theMongoClientURI connection string:

指定兩個副本集:

 

復制代碼代碼如下:
MongoClient mongoClient = new MongoClient( new MongoClientURI("mongodb://host1:27017,host2:27017,host3:27017"));?

 

至少有一個副本集和副本集選項的成員:

 

復制代碼代碼如下:
MongoClient mongoClient = new MongoClient( new MongoClientURI( "mongodb://host1:27017,host2:27017,host3:27017/?replicaSet=myReplicaSet"));

 

你可以使用ServerAddress指定副本集中的所有成員.

MongoClient mongoClient = new MongoClient(Arrays.asList(new ServerAddress("host1", 27017),       new ServerAddress("host2", 27017),       new ServerAddress("host3", 27017)));

連接到分片集群

要連接到分片群集,請將mongos實例或多個實例指定給MongoClient構造函數。

連接到一個mongos實例:

MongoClient mongoClient = new MongoClient( "localhost" , 27017 );

連接多個 mongos 實例:

MongoClient mongoClient = new MongoClient( new MongoClientURI("mongodb://host1:27017,host2:27017"));MongoClient mongoClient = new MongoClient(  Arrays.asList(new ServerAddress("host1", 27017),         new ServerAddress("host2", 27017)));

連接選項

您可以使用MongoClientURI或MongoClientOptions或兩者來指定連接設置。

例如,您可以在MongoClientURI連接字符串中指定 TLS/SSL和身份驗證設置:

MongoClientURI uri = new MongoClientURI("mongodb://user1:pwd1@host1/?authSource=db1&ssl=true");MongoClient mongoClient = new MongoClient(uri);

您還可以使用MongoClientOptions來指定 TLS/SSL 和MongoCredential的認證信息:

String user; // the user name String database; // the name of the database in which the user is defined char[] password; // the password as a character array // ... MongoCredential credential = MongoCredential.createCredential(user, database, password); MongoClientOptions options = MongoClientOptions.builder().sslEnabled(true).build(); MongoClient mongoClient = new MongoClient(new ServerAddress("host1", 27017),                      Arrays.asList(credential),                      options);

這里只是官方給的簡單演示連接, 不可直接用于生產環境, 比如: 這里邊沒有配置讀寫關注, 讀取偏好, 連接池配置等都是默認的. 而這些默認值直接用于生產環境肯定是不行的.

至于生產環境怎么配置, 要根據業務情況來實際分析, 我在后邊會提供一個參考.

參考官方文檔:https://mongodb.github.io/mongo-java-driver/3.4/driver/tutorials/connect-to-mongodb/

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持VeVb武林網。


注:相關教程知識閱讀請移步到JAVA教程頻道。
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 荥阳市| 徐汇区| 兴安盟| 扎赉特旗| 漠河县| 泾川县| 葫芦岛市| 阿瓦提县| 罗甸县| 宜兴市| 广平县| 临邑县| 辰溪县| 聂荣县| 西昌市| 桃源县| 罗平县| 黔西县| 宁强县| 乐至县| 岳阳县| 嘉峪关市| 自治县| 军事| 福建省| 太原市| 祥云县| 吴桥县| 卓资县| 大邑县| 黔江区| 年辖:市辖区| 开封市| 左权县| 河曲县| 青川县| 大兴区| 弥勒县| 秦安县| 沅江市| 万源市|