先決條件
先運行mongodb肯定是必須的,然后導入以下包:
|
1
2
3
4
5
|
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.
|
1
|
mongoclient mongoclient = new mongoclient( "host1" , 27017 );? |
2. you can specify themongoclienturi connection string.
|
1
|
mongoclient mongoclient = new mongoclient(new mongoclienturi("mongodb://host1:27017")); |
連接到副本集
mongodb將自動發現主要和副本。
you can specify the members using themongoclienturi connection string:
指定兩個副本集:
至少有一個副本集和副本集選項的成員：
你可以使用serveraddress指定副本集中的所有成員.
|
1
2
3
4
|
mongoclient mongoclient = new mongoclient(arrays.aslist(new serveraddress("host1", 27017), new serveraddress("host2", 27017), new serveraddress("host3", 27017))); |
連接到分片集群
要連接到分片群集，請將mongos實例或多個實例指定給mongoclient構造函數。
連接到一個mongos實例:
|
1
|
mongoclient mongoclient = new mongoclient( "localhost" , 27017 ); |
連接多個 mongos 實例:
|
1
2
3
4
5
|
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和身份驗證設置：
|
1
2
|
mongoclienturi uri = new mongoclienturi("mongodb://user1:pwd1@host1/?authsource=db1&ssl=true");mongoclient mongoclient = new mongoclient(uri); |
您還可以使用mongoclientoptions來指定 tls/ssl 和mongocredential的認證信息：
|
1
2
3
4
5
6
7
8
9
|
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); |
這里只是官方給的簡單演示連接, 不可直接用于生產環境, 比如: 這里邊沒有配置讀寫關注, 讀取偏好, 連接池配置等都是默認的. 而這些默認值直接用于生產環境肯定是不行的.
至于生產環境怎么配置, 要根據業務情況來實際分析, 我在后邊會提供一個參考.
生產環境配置見: mongodb連接配置實踐
參考官方文檔:https://mongodb.github.io/mongo-java-driver/3.4/driver/tutorials/connect-to-mongodb/
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
原文鏈接：http://www.cnblogs.com/jycboy/p/10076859.html
