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

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

使用 Cassandra Java 客户端驱动程序通过编程方式访问 Amazon Keyspaces

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

开始前的准备工作

Amazon Keyspaces 要求使用传输层安全性 (TLS) 以帮助保护与客户端的连接。要使用 TLS 连接到 Amazon Keyspaces，您需要完成以下任务，然后才能开始。

使用特定于服务的凭据使用适用于 Apache 卡桑德拉的 DataSax Java 驱动程序 Connect 到亚马逊 Keyspaces 的分步教程

以下分步教程将指导您使用适用于 Cassandra 的 Java 驱动程序使用特定于服务的凭据连接到 Amazon Keyspaces。具体来说，您将使用适用于阿帕奇卡桑德拉的数据 STAX Java 驱动程序 4.0 版本。

第 1 步：先决条件

第 2 步：配置驱动程序

您可以通过为应用程序创建配置文件来指定 DataSax Java 卡桑德拉驱动程序的设置。此配置文件将覆盖默认设置，并告诉驱动程序使用端口 9142 连接到 Amazon Keyspaces 服务终端节点。有关可用服务终端节点的列表，请参阅亚马逊 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"
    }

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

第 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 卡桑德拉的 4.x DataSax Java 驱动程序和 Sigv4 身份验证插件 Connect 到亚马逊 Keyspaces 的分步教程

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

Sigv4 身份验证插件允许您在连接到 Amazon Keyspaces 时使用临时证书。此插件不需要用户名和密码，而是使用您在配置插件时指定的访问密钥为您签署 API 请求。有关更多信息，请参阅 。Amazon签名版本 4 流程 (SigV4).

第 1 步：先决条件

第 2 步：配置驱动程序

您可以通过为应用程序创建配置文件来指定 DataSax Java 卡桑德拉驱动程序的设置。此配置文件将覆盖默认设置，并告诉驱动程序使用端口 9142 连接到 Amazon Keyspaces 服务终端节点。有关可用服务终端节点的列表，请参阅亚马逊 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
        }
        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"
            }
        }
    }

第 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 卡桑德拉的 3.x DataSax Java 驱动程序和 Sigv4 身份验证插件 Connect 到亚马逊 Keyspaces

以下部分介绍了如何使用适用于 Apache Cassandra 的 3.x 开源 DataSax Java 驱动程序的 SiGv4 身份验证插件访问 Amazon Keyspaces。可从获得插件GitHub 存储库.

Sigv4 身份验证插件允许您在连接到 Amazon Keyspaces 时使用临时证书。此插件不需要用户名和密码，而是使用您在配置插件时指定的访问密钥为您签署 API 请求。有关更多信息，请参阅 。Amazon签名版本 4 流程 (SigV4).

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

使用说明：

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