本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

使用 MongoDB Java 驱动程序连接到亚马逊 DocumentDB

本节提供使用 Java 驱动程序连接亚马逊文档数据库的 step-by-step指南。这将使你开始将文档数据库集成到你的 Java 应用程序中。

第 1 步：设置您的 项目

步骤 2：创建连接字符串

Amazon DocumentDB 连接字符串对于在您的应用程序和 DocumentDB 集群之间建立连接至关重要。此字符串封装了关键信息，例如集群终端节点、端口、身份验证详细信息和各种连接选项。要构建 DocumentDB 连接字符串，通常从基本格式开始：

"mongodb://username:password@cluster-endpoint:port/?[connection options]"

您需要将 “用户名” 和 “密码” 替换为实际凭证。你可以在中找到集群的终端节点和端口号 AWS Management Console ，也可以通过 AWS CLI。查找集群的端点要查找您的集群的集群终端节点，请参阅。DocumentDB 的默认端口是 27017。

连接字符串示例

连接字符串可用的不同选项如下所示：

TLS 证书

tls=true|false— 此选项启用或禁用传输层安全 (TLS)。默认情况下，Amazon DocumentDB 集群启用传输中加密，因此，除非在集群级别禁用 TLS，否则此选项的值应为。true

使用 TLS 时，在创建与 DocumentDB 集群的连接时，代码需要提供 SSL 证书。下载与集群建立安全连接所需的证书：global-bundle.pem。有两种使用该global-bundle.pem文件的方法。

从只读副本读取

replicaSet=rs0&readPreference=secondaryPreferred— 指定这两个选项会将所有读取请求路由到只读副本，将写入请求路由到主实例。replicaSet=rs0在连接字符串中使用可让 MongoDB 驱动程序维护自动更新的集群拓扑视图，从而允许应用程序在添加或删除实例时保持对当前节点配置的可见性。不提供这些选项或指定readPreference=primary会将所有读取和写入操作发送到主实例。有关更多选项readPreference，请参阅读取首选项选项。

写关注和日记

写入问题决定了数据库为写入操作请求的确认级别。MongoDB 驱动程序提供了调整写入问题和日志文件的选项。Amazon DocumentDB 不希望您设置写入关注点和日志，并且会忽略为和j（w和）writeConcern发送的值。journalDocumentDB 总是使用writeConcern:majority和journal:写入数据，true因此在向客户端发送确认之前，写入操作会持久地记录在大多数节点上。

RetryWrites

retryWrites=false— DocumentDB 不支持可重试写入，因此应始终将此属性设置为。false

IAM 身份验证

authSource=%24external和 authMechanism=MONGODB-AWS — 这两个参数用于使用进行身份验证 AWS Identity and Access Management。IAM 身份验证目前仅在基于实例的集群版本 5.0 中可用。有关更多信息，请参阅 使用 IAM 身份进行身份验证。

连接池

以下选项可用于连接池：

连接超时参数

超时是一种机制，用于限制操作或连接尝试在被视为失败之前可能花费的时间。以下超时参数可用于防止无限期等待和管理资源分配：

步骤 3：编写连接代码

以下代码示例显示了如何与 Amazon DocumentDB 建立 TLS 连接：

public static MongoClient makeDbConnection(String dbName, String DbUserName, String DbPassword,
    String DbClusterEndPoint, String keyStorePass) throws Exception {
    MongoClient connectedClient;
    String connectionOptions = "?replicaSet=rs0&readPreference=secondaryPreferred&retryWrites=false";
    String connectionUrl = "mongodb://" + DbUserName + ":" + DbPassword + "@" + DbClusterEndPoint + ":27017/" +
        dbName + connectionOptions;

    try {
        KeyStore trustStore = KeyStore.getInstance(KeyStore.getDefaultType());
        try (FileInputStream fis = new FileInputStream("src/main/resources/certs/truststore.jks")) {
            trustStore.load(fis, keyStorePass.toCharArray());
            TrustManagerFactory tmf = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
            tmf.init(trustStore);

            SSLContext sslContext = SSLContext.getInstance("TLSv1.2");
            sslContext.init(null, tmf.getTrustManagers(), new SecureRandom());
            ConnectionString connectionString = new ConnectionString(connectionUrl);
            MongoClientSettings settings = MongoClientSettings.builder()
                .applyConnectionString(connectionString)
                .applyToSslSettings(builder - > {
                    builder.enabled(true);
                    builder.context(sslContext);
                })
                .build();
            connectedClient = MongoClients.create(settings);
        }
        return connectedClient;
    } catch (MongoException e5) {
        throw new RuntimeException(e5);
    } catch (Exception e) {
        throw new RuntimeException(e);
    }
}

步骤 4：处理连接异常

在 Java 应用程序中使用 DocumentDB 时，处理连接异常对于保持稳健可靠的数据库操作至关重要。如果管理得当，这些异常不仅有助于快速诊断问题，还可以确保您的应用程序能够优雅地处理临时网络中断或服务器不可用，从而改善稳定性和用户体验。与建立连接有关的一些关键例外情况包括：

第 5 步：运行代码

以下代码示例创建 Amazon DocumentDB 连接并打印所有数据库：

public static void TestConnection() {
    try (MongoClient mongoClient = makeDbConnection(DATABASE_NAME, DB_USER_NAME, DB_PASSWORD, DB_CLUSTER_ENDPOINT, KEYSTORE_PASSWORD)) {
        List < String > databases = mongoClient.listDatabaseNames().into(new ArrayList < > ());
        System.out.println("Databases: " + databases);
    } catch (MongoException e) {
        System.err.println("MongoDB error: " + e.getMessage());
        throw new RuntimeException(e);
    }
}

连接最佳实践

以下是使用 MongoDB Java 驱动程序连接到亚马逊 DocumentDB 时需要考虑的最佳实践：