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

更新時(shí)間：2018年12月07日 09:31:41 作者：超超boy

這篇文章主要介紹了詳解Java 連接MongoDB集群的幾種方式，小編覺(jué)得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧

先決條件

先運(yùn)行mongodb肯定是必須的,然后導(dǎo)入以下包:

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

MongoClient

MongoClient()實(shí)例表示到數(shù)據(jù)庫(kù)的連接池; 你將只需要MongoClient類(lèi)的一個(gè)實(shí)例，即使有多個(gè)線程也是一樣。

重要:

通常，您只能為給定的MongoDB部署（例如獨(dú)立，副本集或分片群集）創(chuàng)建一個(gè)MongoClient實(shí)例，并在您的應(yīng)用程序中使用它。但是，如果您創(chuàng)建了多個(gè)實(shí)例：

所有資源使用限制（例如，最大連接等）適用于每個(gè)MongoClient實(shí)例。
要關(guān)閉一個(gè)實(shí)例，調(diào)用MongoClient.close() 來(lái)清理資源。

連接到一個(gè)獨(dú)立的MongoDB實(shí)例

以下幾種方法:

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

2. You can specify theMongoClientURI connection string.

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

連接到副本集

MongoDB將自動(dòng)發(fā)現(xiàn)主要和副本。

You can specify the members using theMongoClientURI connection string:

指定兩個(gè)副本集:

復(fù)制代碼代碼如下:

MongoClient mongoClient = new MongoClient( new MongoClientURI("mongodb://host1:27017,host2:27017,host3:27017"));​

至少有一個(gè)副本集和副本集選項(xiàng)的成員：

復(fù)制代碼代碼如下:

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)));

連接到分片集群

要連接到分片群集，請(qǐng)將mongos實(shí)例或多個(gè)實(shí)例指定給MongoClient構(gòu)造函數(shù)。

連接到一個(gè)mongos實(shí)例:

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

連接多個(gè) mongos 實(shí)例:

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)));

連接選項(xiàng)

您可以使用MongoClientURI或MongoClientOptions或兩者來(lái)指定連接設(shè)置。

例如，您可以在MongoClientURI連接字符串中指定 TLS/SSL和身份驗(yàn)證設(shè)置：

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

您還可以使用MongoClientOptions來(lái)指定 TLS/SSL 和MongoCredential的認(rèn)證信息：

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);

這里只是官方給的簡(jiǎn)單演示連接, 不可直接用于生產(chǎn)環(huán)境, 比如: 這里邊沒(méi)有配置讀寫(xiě)關(guān)注, 讀取偏好, 連接池配置等都是默認(rèn)的. 而這些默認(rèn)值直接用于生產(chǎn)環(huán)境肯定是不行的.

至于生產(chǎn)環(huán)境怎么配置, 要根據(jù)業(yè)務(wù)情況來(lái)實(shí)際分析, 我在后邊會(huì)提供一個(gè)參考.

生產(chǎn)環(huán)境配置見(jiàn): mongodb連接配置實(shí)踐

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

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: