Docs 菜单
Docs 主页
/
语言
/
Java
/
Java Reactive Streams 驱动程序

连接至 MongoDB

在此页面上

  • Overview
  • 连接
  • 本地部署
  • Atlas
  • 副本集(Replica Set)
  • 分片集群
  • 连接选项

Overview

本页包含的代码示例展示了如何使用各种设置将Java Reactive Streams应用程序连接到MongoDB 。

提示

要了解有关此页面上的连接选项的更多信息，请参阅每个部分中提供的链接。

要使用此页面中的连接示例，请将代码示例复制到示例应用程序或您自己的应用程序中。 请务必将代码示例中的所有占位符（例如 <Atlas connection string> ）替换为 MongoDB 部署的相关值。

重要

项目 Reactor 库

本指南使用 Project Reactor 库来使用Java Reactive Streams驾驶员方法返回的Publisher实例。 要学习；了解有关 Project Reactor 库及其使用方法的更多信息，请参阅 入门 在 Reactor 文档中。要详细学习；了解如何使用本指南中的 Project Reactor 库方法，请参阅将数据写入MongoDB指南。

您可以使用以下示例应用程序来测试本页上的代码示例。 要使用示例应用程序，请执行以下步骤：

  1. 在 IDE 中创建一个新的Java项目。

  2. 在Java项目中安装Java Reactive Streams驾驶员。

  3. 安装 Project Reactor 库 在您的Java项目中。

  4. 复制以下代码并将其粘贴到名为ConnectionApp.java的新Java文件中。

  5. 从此页面复制代码示例，并将其粘贴到文件中的指定行。

1import com.mongodb.ConnectionString;
2import com.mongodb.MongoClientSettings;
3import com.mongodb.ServerApi;
4import com.mongodb.ServerApiVersion;
5
6import org.bson.BsonDocument;
7import org.bson.BsonInt64;
8import org.bson.Document;
9
10import com.mongodb.reactivestreams.client.MongoClient;
11import com.mongodb.reactivestreams.client.MongoClients;
12import com.mongodb.reactivestreams.client.MongoDatabase;
13import org.bson.conversions.Bson;
14import reactor.core.publisher.Mono;
15
16class ConnectionApp {
17    public static void main(String[] args) {
18        //start example code here
19        
20        //end example code here        
21        {
22            Bson command = new BsonDocument("ping", new BsonInt64(1));
23            MongoDatabase database = mongoClient.getDatabase("admin");
24            Publisher<Document> MonoPublisher = database.runCommand(command);
25
26            Mono.from(MonoPublisher)
27                    .doOnSuccess(x -> System.out.println("Pinged your deployment. You successfully connected to MongoDB!"))
28                    .doOnError(err -> System.out.println("Error: " + err.getMessage()))
29                    .block();
30
31            //other application code
32
33        }
34    }
35}

连接

本地部署

String uri = "mongodb://<hostname>:<port>/";
try (MongoClient mongoClient = MongoClients.create(uri))

Atlas

String uri = "<Atlas connection string>";
ServerApi serverApi = ServerApi.builder()
             .version(ServerApiVersion.V1)
             .build();
 MongoClientSettings settings = MongoClientSettings.builder()
             .applyConnectionString(new ConnectionString(uri))
             .serverApi(serverApi)
             .build();
 try (MongoClient mongoClient = MongoClients.create(settings))

副本集(Replica Set)

String uri = "mongodb://<replica set member>:<port>/?replicaSet=<replica set name>";
try (MongoClient mongoClient = MongoClients.create(uri))

分片集群

要连接到分片集群，请为MongoClients.create()方法指定一个或多个mongos实例。 要了解有关分片集群的更多信息，请参阅MongoDB MongoDB Server手册中的分片。

您可以通过以下方式连接到单个mongos实例：

  • 在连接string中指定主机名和端口，如以下代码所示：

    MongoClient mongoClient = MongoClients.create( "mongodb://<hostname>:<port>" );

  • 如果 mongos 在 localhost:27017 上运行，则排除连接string ，如以下代码所示：

    MongoClient mongoClient = MongoClients.create();

您可以通过以下方式连接到多个mongos实例：

  • 指定连接string以包含其主机名和端口，如以下代码所示：

    MongoClient mongoClient = MongoClients.create("mongodb://<first hostname>:<first port>,<second hostname>:<second port>");

  • 指定与每个实例对应的ServerAddress对象列表，如以下代码所示：

    MongoClient mongoClient = MongoClients.create(
        MongoClientSettings.builder()
            .applyToClusterSettings(builder ->
                builder.hosts(Arrays.asList(
                    new ServerAddress("<first hostname>", <first port>),
                    new ServerAddress("<second hostname", <second port>))))
            .build());

连接选项

您可以使用连接string或 MongoClientSettings 类型或同时使用两者来指定连接设置。

示例，您可以在连接string中指定 TLS/SSL 和身份验证设置，如以下代码所示：

MongoClient mongoClient = MongoClients.create("mongodb://user1:pwd1@host1/?authSource=db1&ssl=true");

您还可以使用MongoClientSettings实例指定 TLS/SSL 和MongoCredential类型来存储身份验证信息，如以下代码所示：

String user; // the username
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);
MongoClientSettings settings = MongoClientSettings.builder()
    .credential(credential)
    .applyToSslSettings(builder -> builder.enabled(true))
    .applyToClusterSettings(builder ->
        builder.hosts(Arrays.asList(new ServerAddress("host1", 27017))))
    .build();
MongoClient mongoClient = MongoClients.create(settings);

在某些情况下，您可能需要将连接string与编程配置结合使用，如以下代码所示：

ConnectionString connectionString = new ConnectionString("mongodb://host1:27107,host2:27017/?ssl=true");
CommandListener myCommandListener = ...;
MongoClientSettings settings = MongoClientSettings.builder()
    .addCommandListener(myCommandListener)
    .applyConnectionString(connectionString)
    .build();
MongoClient mongoClient = MongoClients.create(settings);

后退

后续步骤

来年

创建 MongoClient