Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

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

使用 Cassandra Java 客户端驱动程序以编程方式访问亚马逊Keyspaces

本节说明了如何使用 Java 客户端驱动程序连接到 Amazon Keyspaces。要向用户和应用程序提供凭证以编程方式访问 Amazon Keyspaces 资源的凭证，您可以执行以下任一操作：

开始前的准备工作

要连接到 Amazon Keyspaces，您需要完成以下任务，然后才能开始执行此操作。

使用适用于 Apache Cassandr DataStax a 的 Java 驱动程序使用特定服务的证书连接到 Amazon Keyspaces 的tep-by-step 教程

以下 step-by-step 教程将引导您使用特定服务的凭证使用适用于 Cassandra 的 Java 驱动程序连接到 Amazon Keyspaces。具体而言，你将使用 Apache Cassandra 的 DataStax Java 驱动程序的 4.0 版本。

步骤 1：先决条件

步骤 2：配置驱动程序

您可以通过为应用程序创建配置文件来指定 DataStax Java Cassandra 驱动程序的设置。此配置文件覆盖默认设置，并告诉驱动程序使用端口 9142 连接到 Amazon Keyspaces 服务终端节点。有关可用服务终端节点的列表，请参阅Amazon Keyspaces 服务端点。

创建配置文件并将该文件保存在应用程序的资源文件夹中，例如src/main/resources/application.conf。打开application.conf并添加以下配置设置。

datastax-java-driver {

    basic.contact-points = [ "cassandra.us-east-2.amazonaws.com:9142"]
    advanced.auth-provider{
        class = PlainTextAuthProvider
        username = "ServiceUserName"
        password = "ServicePassword"
    }
    basic.load-balancing-policy {
        local-datacenter = "us-east-2"
        slow-replica-avoidance = false           
    }

    advanced.ssl-engine-factory {
        class = DefaultSslEngineFactory
        truststore-path = "./src/main/resources/cassandra_truststore.jks"
        truststore-password = "my_password"
        hostname-validation = false
      }
}

步骤 3：运行示例应用程序

此代码示例显示了一个简单的命令行应用程序，该应用程序使用我们之前创建的配置文件创建 Amazon Keyspaces 的连接池。它通过运行简单查询来确认连接已建立。

package <your package>;
// add the following imports to your project
import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.config.DriverConfigLoader;
import com.datastax.oss.driver.api.core.cql.ResultSet;
import com.datastax.oss.driver.api.core.cql.Row;

public class App 
{
    
    public static void main( String[] args )
    {
        //Use DriverConfigLoader to load your configuration file
        DriverConfigLoader loader = DriverConfigLoader.fromClasspath("application.conf");
        try (CqlSession session = CqlSession.builder()
                .withConfigLoader(loader)
                .build()) {

            ResultSet rs = session.execute("select * from system_schema.keyspaces");
            Row row = rs.one();
            System.out.println(row.getString("keyspace_name"));
        }
    }
}

使用适用于 Apache Cassandra 的 4.x DataStax Java 驱动程序和 SigV4 身份验证插件连接亚马逊 Keyspaces 的tep-by-step 教程

以下部分介绍如何使用 Apache Cassandra 的开源 4.x DataStax Java 驱动程序的 Sigv4 身份验证插件访问亚马逊 Keyspaces ace（适用于 Apache Cassandra）。该插件可从GitHub存储库获得。

Sigv4 身份验证插件允许您在连接到 Amazon Keyspaces 时为用户或角色使用 IAM 证书。此插件不需要用户名和密码，而是使用访问密钥签署 API 请求。有关更多信息，请参阅如何为亚马逊Keyspaces 创建和配置Amazon证书：

步骤 1：先决条件

步骤 2：配置驱动程序

您可以通过为应用程序创建配置文件来指定 DataStax Java Cassandra 驱动程序的设置。此配置文件覆盖默认设置，并告诉驱动程序使用端口 9142 连接到 Amazon Keyspaces 服务终端节点。有关可用服务终端节点的列表，请参阅Amazon Keyspaces 服务端点。

创建配置文件并将该文件保存在应用程序的资源文件夹中，例如src/main/resources/application.conf。打开application.conf并添加以下配置设置。

datastax-java-driver {
        basic.contact-points = ["cassandra.us-east-2.amazonaws.com:9142"]
        basic.load-balancing-policy {
            class = DefaultLoadBalancingPolicy
            local-datacenter = us-east-2
            slow-replica-avoidance = false                 
        }
        advanced {
            auth-provider = {
                class = software.aws.mcs.auth.SigV4AuthProvider
                aws-region = us-east-2
            }
            ssl-engine-factory {
                class = DefaultSslEngineFactory
                truststore-path = "./src/main/resources/cassandra_truststore.jks"
                truststore-password = "my_password"
                hostname-validation = false
            }
        }
    }

步骤 3：运行应用程序

此代码示例显示了一个简单的命令行应用程序，该应用程序使用我们之前创建的配置文件创建 Amazon Keyspaces 的连接池。它通过运行简单查询来确认连接已建立。

package <your package>;
// add the following imports to your project
import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.config.DriverConfigLoader;
import com.datastax.oss.driver.api.core.cql.ResultSet;
import com.datastax.oss.driver.api.core.cql.Row;

public class App 
{
    
    public static void main( String[] args )
    {
        //Use DriverConfigLoader to load your configuration file
        DriverConfigLoader loader = DriverConfigLoader.fromClasspath("application.conf");
        try (CqlSession session = CqlSession.builder()
                .withConfigLoader(loader)
                .build()) {

            ResultSet rs = session.execute("select * from system_schema.keyspaces");
            Row row = rs.one();
            System.out.println(row.getString("keyspace_name"));
        }
    }
}

使用适用于 Apache Cassandra 的 3.x DataStax Java 驱动程序和 Sigv4 身份验证插件Connect 亚马逊 Keyspaces

下一节介绍如何使用适用于 Apache Cassandra 的 3.x 开源 DataStax Java 驱动程序的 Sigv4 身份验证插件来访问 Amazon Keyspaces。该插件可从GitHub 存储库获得。

Sigv4 身份验证插件允许您在连接到 Amazon Keyspaces 时为用户和角色使用 IAM 证书。此插件不需要用户名和密码，而是使用访问密钥签署 API 请求。有关更多信息，请参阅如何为亚马逊Keyspaces 创建和配置Amazon证书：

步骤 1：先决条件

步骤 2：运行应用程序

此代码示例显示了一个简单的命令行应用程序，该应用程序创建了与 Amazon Keyspaces 的连接池。它通过运行简单查询来确认连接已建立。

package <your package>;
// add the following imports to your project

import software.aws.mcs.auth.SigV4AuthProvider;  
import com.datastax.driver.core.Cluster;  
import com.datastax.driver.core.ResultSet;  
import com.datastax.driver.core.Row;  
import com.datastax.driver.core.Session;

public class App 
{
    
    public static void main( String[] args )
    {
        String endPoint = "cassandra.us-east-2.amazonaws.com";  
        int portNumber = 9142;
        Session session = Cluster.builder()  
	                                 .addContactPoint(endPoint)  
	                                 .withPort(portNumber)  
	                                 .withAuthProvider(new SigV4AuthProvider("us-east-2"))  
	                                 .withSSL()  
	                                 .build()  
	                                 .connect();

        ResultSet rs = session.execute("select * from system_schema.keyspaces");  
        Row row = rs.one();  
        System.out.println(row.getString("keyspace_name"));
    }
}

使用注释：

有关可用终端节点的列表，请参阅Amazon Keyspaces 服务端点。

有关在 Amazon Keyspaces 中使用 Java 驱动程序时有用的 Java 驱动程序策略、示例和最佳实践，请参阅以下存储库：https://github.com/aws-samples/amazon-keyspaces-java-driver-helpers。