要連接 MongoDB 集群,你可以使用 MongoDB 的 Java 驅(qū)動程序來實現(xiàn)。
首先,你需要在項目中添加 MongoDB 的 Java 驅(qū)動程序依賴。你可以使用 Maven 或 Gradle 來添加依賴。
對于 Maven,你可以在項目的 pom.xml
文件中添加以下依賴:
<dependencies>
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongodb-driver-sync</artifactId>
<version>4.4.3</version>
</dependency>
</dependencies>
對于 Gradle,你可以在項目的 build.gradle
文件中添加以下依賴:
dependencies {
implementation 'org.mongodb:mongodb-driver-sync:4.4.3'
}
然后,你可以使用以下代碼來連接 MongoDB 集群:
import com.mongodb.ConnectionString;
import com.mongodb.MongoClientSettings;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
public class MongoDBConnection {
public static void main(String[] args) {
// 定義 MongoDB 連接字符串
String connectionString = "mongodb://hostname1:port1,hostname2:port2,hostname3:port3/?replicaSet=myReplicaSet";
// 創(chuàng)建 MongoDB 連接字符串對象
ConnectionString connString = new ConnectionString(connectionString);
// 創(chuàng)建 MongoDB 客戶端設(shè)置
MongoClientSettings settings = MongoClientSettings.builder()
.applyConnectionString(connString)
.build();
// 創(chuàng)建 MongoDB 客戶端
MongoClient mongoClient = MongoClients.create(settings);
// 使用 mongoClient 進行操作
// ...
// 關(guān)閉 MongoDB 客戶端
mongoClient.close();
}
}
在上面的代碼中,你需要將 hostname1:port1,hostname2:port2,hostname3:port3
替換為你的 MongoDB 集群中實際的主機名和端口號。replicaSet=myReplicaSet
是可選的,用于指定集群的副本集名稱。
你可以在 mongoClient
對象上執(zhí)行各種 MongoDB 操作,如插入、查詢、更新和刪除文檔等。
最后,別忘記在完成操作后關(guān)閉 MongoDB 客戶端。
希望對你有所幫助!