1. 程式人生 > >Java 連線MongoDB叢集的幾種方式

Java 連線MongoDB叢集的幾種方式

先決條件

先執行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)));

連線選項

您可以使用MongoClientURIMongoClientOptions或兩者來指定連線設定。

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

MongoClientURI uri = new MongoClientURI("mongodb://user1:[email protected]/?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