先決條件 先運行mongodb肯定是必須的,然後導入以下包: MongoClient MongoClient()實例表示到資料庫的連接池; 你將只需要MongoClient類的一個實例,即使有多個線程也是一樣。 重要: 通常,您只能為給定的MongoDB部署(例如獨立,副本集或分片群集)創建一個Mo ...
先決條件
先運行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 the MongoClientURI
connection string.
MongoClient mongoClient = new MongoClient(new MongoClientURI("mongodb://host1:27017"));
連接到副本集
MongoDB將自動發現主要和副本。
You can specify the members using the MongoClientURI
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/
轉發清註明出處: https://www.cnblogs.com/jycboy/p/10076859.html