先運(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類的一個(gè)實(shí)例,即使有多個(gè)線程也是一樣。
重要:
通常,您只能為給定的MongoDB部署(例如獨(dú)立,副本集或分片群集)創(chuàng)建一個(gè)MongoClient實(shí)例,并在您的應(yīng)用程序中使用它。 但是,如果您創(chuàng)建了多個(gè)實(shí)例:
以下幾種方法:
1.
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將自動(dòng)發(fā)現(xiàn)主要和副本。
You can specify the members using the MongoClientURI
connection string:
指定兩個(gè)副本集:
MongoClient mongoClient = new MongoClient( new MongoClientURI("mongodb://host1:27017,host2:27017,host3:27017"));?
至少有一個(gè)副本集和副本集選項(xiàng)的成員:
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)));
您可以使用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)境, 比如: 這里邊沒有配置讀寫關(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)境配置見: mongodb連接配置實(shí)踐
參考官方文檔:
https://mongodb.github.io/mongo-java-driver/3.4/driver/tutorials/connect-to-mongodb/
轉(zhuǎn)發(fā)清注明出處: https://www.cnblogs.com/jycboy/p/10076859.html
如果您覺得閱讀本文對(duì)您有幫助,請(qǐng)點(diǎn)一下??推薦”按鈕,您的“推薦??將是我最大的寫作動(dòng)力!歡迎各位轉(zhuǎn)載,但是未經(jīng)作者本人同意,轉(zhuǎn)載文章之后必須在文章頁(yè)面明顯位置給出作者和原文連接,否則保留追究法律責(zé)任的權(quán)利??
聯(lián)系客服