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

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

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

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

开始前的准备工作

要连接到 Amazon Keyspaces，您需要完成以下任务。

Step-by-step 使用连接到 Amazon Keyspaces DataStax 使用特定服务凭据的 Apache Cassandra 的 Java 驱动程序

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

第 1 步：先决条件

第 2 步：配置驱动程序

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

创建配置文件并将该文件保存在应用程序的资源文件夹中，例如，src/main/resources/application.conf. Open（打开）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"
    }

    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"));
        }
    }
}

Step-by-step 使用 4.x 连接到 Amazon Keyspaces DataStax 适用于 Apache Cassandra 的 Java 驱动程序和 SigV4 身份验证插件

以下部分介绍如何使用开源 4.x 的 SigV4 身份验证插件 DataStax for Apache Cassandra 访问亚马逊 Keyspaces spache Cassandra。该插件可从以下网址获得GitHub知识库.

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

第 1 步：先决条件

第 2 步：配置驱动程序

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

创建配置文件并将该文件保存在应用程序的资源文件夹中，例如，src/main/resources/application.conf. Open（打开）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
        }
        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"));
        }
    }
}

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

以下部分介绍如何使用适用于 3.x 开源的 SigV4 身份验证插件 DataStax Apache Cassandra 访问亚马逊 Keyspaces 的 Java 驱动程序。该插件可从以下网址获得GitHub 知识库.

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

第 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。