全部產品
Search

搜尋本產品

    ：初始化Tablestore Client

    文件中心

    ：初始化Tablestore Client

    更新時間：Aug 09, 2025

    Tablestore Client是Tablestore的用戶端，它提供了一系列的方法，可以用來操作Tablestore的表和資料。本文介紹如何在Java中進行Tablestore Client的初始化。

    重要

    本文以阿里雲帳號的AccessKey為例為您介紹如何初始化Tablestore Client，如果您想使用RAM使用者的存取金鑰或STS臨時訪問憑證進行初始化，請參見使用RAM使用者存取金鑰訪問Table Store和使用STS臨時訪問憑證訪問Table Store。

    準備工作

    初始化Tablestore Client前，您需要擷取執行個體的相關資訊、安裝Tablestore SDK並配置訪問憑證。

    擷取執行個體資訊

    • 地區ID：執行個體所在地區的ID，例如華東1（杭州）的地區ID為cn-hangzhou。

    • 執行個體名稱和訪問地址：每個Tablestore執行個體對應一個訪問地址（Endpoint），應用程式進行表和資料操作時需要指定訪問地址，擷取方式如下。

      1. 登入Table Store控制台。

      2. 在頁面上方，選擇資源群組和地區。

      3. 在概覽頁面，單擊執行個體別名或在操作列單擊執行個體管理。

      4. 在執行個體詳情頁簽，查看執行個體的名稱和訪問地址。

        重要

        新建立的執行個體預設未啟用公網訪問功能。如果您需要通過公網訪問執行個體中的資源，則必須開啟執行個體的公網訪問功能。

    安裝Tablestore SDK

    如果您使用的是Maven專案，請在專案的pom.xml檔案中添加如下依賴：

    <dependency>
    <groupId>com.aliyun.openservices</groupId>
    <artifactId>tablestore</artifactId>
    <version>5.17.4</version>
</dependency>

    更多關於安裝Tablestore SDK的資訊，請參見安裝Tablestore SDK。

    配置訪問憑證

    您需要為阿里雲帳號或RAM使用者建立AccessKey，並按如下方式將AccessKey配置到環境變數中。

    說明

    配置完成後請重啟或重新整理您的編譯運行環境，包括 IDE、命令列介面、其它傳統型應用程式及後台服務，確保最新的系統內容變數成功載入。更多關於配置訪問憑證的資訊，請參見配置訪問憑證。

    Linux

    1. 在命令列介面執行以下命令來將環境變數設定追加到 ~/.bashrc 檔案中。

      echo "export TABLESTORE_ACCESS_KEY_ID='YOUR_ACCESS_KEY_ID'" >> ~/.bashrc
echo "export TABLESTORE_ACCESS_KEY_SECRET='YOUR_ACCESS_KEY_SECRET'" >> ~/.bashrc

    2. 執行以下命令使變更生效。

      source ~/.bashrc

    3. 執行以下命令檢查環境變數是否生效。

      echo $TABLESTORE_ACCESS_KEY_ID
echo $TABLESTORE_ACCESS_KEY_SECRET

    macOS

    1. 在終端中執行以下命令，查看預設 Shell 類型。

      echo $SHELL

    2. 根據預設 Shell 類型進行操作。

      Zsh

      1. 執行以下命令來將環境變數設定追加到 ~/.zshrc 檔案中。

        echo "export TABLESTORE_ACCESS_KEY_ID='YOUR_ACCESS_KEY_ID'" >> ~/.zshrc
echo "export TABLESTORE_ACCESS_KEY_SECRET='YOUR_ACCESS_KEY_SECRET'" >> ~/.zshrc

      2. 執行以下命令使變更生效。

        source ~/.zshrc

      3. 執行以下命令檢查環境變數是否生效。

        echo $TABLESTORE_ACCESS_KEY_ID
echo $TABLESTORE_ACCESS_KEY_SECRET
      Bash

      1. 執行以下命令來將環境變數設定追加到 ~/.bash_profile 檔案中。

        echo "export TABLESTORE_ACCESS_KEY_ID='YOUR_ACCESS_KEY_ID'" >> ~/.bash_profile
echo "export TABLESTORE_ACCESS_KEY_SECRET='YOUR_ACCESS_KEY_SECRET'" >> ~/.bash_profile

      2. 執行以下命令使變更生效。

        source ~/.bash_profile

      3. 執行以下命令檢查環境變數是否生效。

        echo $TABLESTORE_ACCESS_KEY_ID
echo $TABLESTORE_ACCESS_KEY_SECRET

    Windows

    CMD

    1. 在CMD中運行以下命令設定環境變數。

      setx TABLESTORE_ACCESS_KEY_ID "YOUR_ACCESS_KEY_ID"
setx TABLESTORE_ACCESS_KEY_SECRET "YOUR_ACCESS_KEY_SECRET"

    2. 重啟CMD後，運行以下命令，檢查環境變數是否生效。

      echo %TABLESTORE_ACCESS_KEY_ID%
echo %TABLESTORE_ACCESS_KEY_SECRET%
    PowerShell

    1. 在PowerShell中運行以下命令。

      [Environment]::SetEnvironmentVariable("TABLESTORE_ACCESS_KEY_ID", "YOUR_ACCESS_KEY_ID", [EnvironmentVariableTarget]::User)
[Environment]::SetEnvironmentVariable("TABLESTORE_ACCESS_KEY_SECRET", "YOUR_ACCESS_KEY_SECRET", [EnvironmentVariableTarget]::User)

    2. 運行以下命令，檢查環境變數是否生效。

      [Environment]::GetEnvironmentVariable("TABLESTORE_ACCESS_KEY_ID", [EnvironmentVariableTarget]::User)
[Environment]::GetEnvironmentVariable("TABLESTORE_ACCESS_KEY_SECRET", [EnvironmentVariableTarget]::User)

    初始化Client

    您需要先初始化一個Client，然後調用該Client的方法來訪問Tablestore服務。Tablestore提供了SyncClient和AsyncClient兩種寬表模型用戶端，以及TimeseriesClient和AsyncTimeseriesClient兩種時序模型用戶端，分別對應同步和非同步方式調用。

    說明

    不管是同步還是非同步，都是安全執行緒的，且內部會自動管理線程和串連資源，您不需要為每個線程建立一個Client，也不需要為每個請求建立一個Client。建議您在使用多線程時，共用一個Client對象。

    寬表模型

    V4簽名（推薦）

    同步方式

    以下範例程式碼使用V4簽名通過同步方式初始化Client，擷取執行個體下的資料表列表並列印到控制台。

    import com.alicloud.openservices.tablestore.ClientConfiguration;
import com.alicloud.openservices.tablestore.SyncClient;
import com.alicloud.openservices.tablestore.core.ResourceManager;
import com.alicloud.openservices.tablestore.core.auth.CredentialsProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentialProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentials;
import com.alicloud.openservices.tablestore.core.auth.V4Credentials;
import com.alicloud.openservices.tablestore.model.AlwaysRetryStrategy;
import com.alicloud.openservices.tablestore.model.ListTableResponse;

public class InitSyncClientV4 {
    public static void main(String[] args) {
        // yourRegion 填寫您的執行個體所在地區，如 cn-hangzhou
        final String region = "yourRegion";
        // yourInstanceName 填寫您的執行個體名稱
        final String instanceName = "yourInstanceName";
        // yourEndpoint 填寫您的執行個體訪問地址
        final String endpoint = "yourEndpoint";
        // 擷取系統變數裡的 AccessKey ID 和 AccessKey Secret
        final String accessKeyId = System.getenv("TABLESTORE_ACCESS_KEY_ID");
        final String accessKeySecret = System.getenv("TABLESTORE_ACCESS_KEY_SECRET");

        // 構造 V4 簽名
        DefaultCredentials credentials = new DefaultCredentials(accessKeyId, accessKeySecret);
        V4Credentials credentialsV4 = V4Credentials.createByServiceCredentials(credentials, region);
        CredentialsProvider provider = new DefaultCredentialProvider(credentialsV4);

        // 以同步方式初始化Table Store用戶端
        SyncClient client = new SyncClient(endpoint, provider, instanceName, null, new ResourceManager(null, null));

        /*
        // 您可以通過指定 ClientConfiguration 修改預設配置項，以下樣本為部分自訂配置項。
        ClientConfiguration clientConfiguration = new ClientConfiguration();
        clientConfiguration.setConnectionTimeoutInMillisecond(5000); // 設定建立串連的逾時時間，單位為毫秒。
        clientConfiguration.setSocketTimeoutInMillisecond(5000); // 設定 socket 逾時時間，單位為毫秒。
        clientConfiguration.setRetryStrategy(new AlwaysRetryStrategy()); // 設定重試策略，如果不設定，則採用預設的重試策略。
        SyncClient client = new SyncClient(endpoint, provider, instanceName, clientConfiguration, new ResourceManager(null, null));
         */

        // 列出執行個體下的資料表列表並列印到控制台
        ListTableResponse listTableResponse = client.listTable();
        listTableResponse.getTableNames().forEach(System.out::println);

        // 關閉 Tablestore Client
        client.shutdown();
    }
}

    非同步方式

    以下範例程式碼使用V4簽名通過非同步方式初始化Client，擷取執行個體下的資料表列表並列印到控制台。

    import com.alicloud.openservices.tablestore.AsyncClient;
import com.alicloud.openservices.tablestore.ClientConfiguration;
import com.alicloud.openservices.tablestore.TableStoreCallback;
import com.alicloud.openservices.tablestore.core.ResourceManager;
import com.alicloud.openservices.tablestore.core.auth.CredentialsProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentialProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentials;
import com.alicloud.openservices.tablestore.core.auth.V4Credentials;
import com.alicloud.openservices.tablestore.model.AlwaysRetryStrategy;
import com.alicloud.openservices.tablestore.model.ListTableRequest;
import com.alicloud.openservices.tablestore.model.ListTableResponse;

import java.util.concurrent.*;

public class InitAsyncClientV4 {
    public static void main(String[] args) throws InterruptedException, TimeoutException, ExecutionException {
        // yourRegion 填寫您的執行個體所在地區，如 cn-hangzhou
        final String region = "yourRegion";
        // yourInstanceName 填寫您的執行個體名稱
        final String instanceName = "yourInstanceName";
        // yourEndpoint 填寫您的執行個體訪問地址
        final String endpoint = "yourEndpoint";
        // 擷取系統變數裡的 AccessKey ID 和 AccessKey Secret
        final String accessKeyId = System.getenv("TABLESTORE_ACCESS_KEY_ID");
        final String accessKeySecret = System.getenv("TABLESTORE_ACCESS_KEY_SECRET");

        // 構造 V4 簽名
        DefaultCredentials credentials = new DefaultCredentials(accessKeyId, accessKeySecret);
        V4Credentials credentialsV4 = V4Credentials.createByServiceCredentials(credentials, region);
        CredentialsProvider provider = new DefaultCredentialProvider(credentialsV4);

        // 以非同步方式初始化Table Store用戶端
        AsyncClient client = new AsyncClient(endpoint, provider, instanceName, null, new ResourceManager(null, null));

        /*
        // 您可以通過指定 ClientConfiguration 修改預設配置項，以下樣本為部分自訂配置項。
        ClientConfiguration clientConfiguration = new ClientConfiguration();
        clientConfiguration.setConnectionTimeoutInMillisecond(5000); // 設定建立串連的逾時時間，單位為毫秒。
        clientConfiguration.setSocketTimeoutInMillisecond(5000); // 設定 socket 逾時時間，單位為毫秒。
        clientConfiguration.setRetryStrategy(new AlwaysRetryStrategy()); // 設定重試策略，如果不設定，則採用預設的重試策略。
        AsyncClient client = new AsyncClient(endpoint, provider, instanceName, clientConfiguration, new ResourceManager(null, null));
        */
        
        Future<ListTableResponse> future = client.listTable(new TableStoreCallback<ListTableRequest, ListTableResponse>() {
            @Override
            public void onCompleted(ListTableRequest listTableRequest, ListTableResponse listTableResponse) {}
            @Override
            public void onFailed(ListTableRequest listTableRequest, Exception e) {}
        });

        ListTableResponse response = future.get(5, TimeUnit.SECONDS);
        if (response.getTableNames() != null) {
            response.getTableNames().forEach(System.out::println);
        }

        // 關閉 Tablestore Client
        client.shutdown();
    }
}

    V2簽名

    同步方式

    以下範例程式碼使用V2簽名通過同步方式初始化Client，擷取執行個體下的資料表列表並列印到控制台。

    import com.alicloud.openservices.tablestore.ClientConfiguration;
import com.alicloud.openservices.tablestore.SyncClient;
import com.alicloud.openservices.tablestore.core.ResourceManager;
import com.alicloud.openservices.tablestore.core.auth.CredentialsProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentialProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentials;
import com.alicloud.openservices.tablestore.model.AlwaysRetryStrategy;
import com.alicloud.openservices.tablestore.model.ListTableResponse;

public class InitSyncClientV2 {
    public static void main(String[] args) {
        // yourInstanceName 填寫您的執行個體名稱
        final String instanceName = "yourInstanceName";
        // yourEndpoint 填寫您的執行個體訪問地址
        final String endpoint = "yourEndpoint";
        // 擷取系統變數裡的 AccessKey ID 和 AccessKey Secret
        final String accessKeyId = System.getenv("TABLESTORE_ACCESS_KEY_ID");
        final String accessKeySecret = System.getenv("TABLESTORE_ACCESS_KEY_SECRET");

        // 構造 V2 簽名
        DefaultCredentials credentials = new DefaultCredentials(accessKeyId, accessKeySecret);
        CredentialsProvider provider = new DefaultCredentialProvider(credentials);

        // 以同步方式初始化Table Store用戶端
        SyncClient client = new SyncClient(endpoint, provider, instanceName, null, new ResourceManager(null, null));

        /*
        // 您可以通過指定 ClientConfiguration 修改預設配置項，以下樣本為部分自訂配置項。
        ClientConfiguration clientConfiguration = new ClientConfiguration();
        clientConfiguration.setConnectionTimeoutInMillisecond(5000); // 設定建立串連的逾時時間，單位為毫秒。
        clientConfiguration.setSocketTimeoutInMillisecond(5000); // 設定 socket 逾時時間，單位為毫秒。
        clientConfiguration.setRetryStrategy(new AlwaysRetryStrategy()); // 設定重試策略，如果不設定，則採用預設的重試策略。
        SyncClient client = new SyncClient(endpoint, provider, instanceName, clientConfiguration, new ResourceManager(null, null));
         */

        // 列出執行個體下的資料表列表並列印到控制台
        ListTableResponse listTableResponse = client.listTable();
        listTableResponse.getTableNames().forEach(System.out::println);

        // 關閉 Tablestore Client
        client.shutdown();
    }
}

    非同步方式

    以下範例程式碼使用V2簽名通過非同步方式初始化Client，擷取執行個體下的資料表列表並列印到控制台。

    import com.alicloud.openservices.tablestore.AsyncClient;
import com.alicloud.openservices.tablestore.ClientConfiguration;
import com.alicloud.openservices.tablestore.TableStoreCallback;
import com.alicloud.openservices.tablestore.core.ResourceManager;
import com.alicloud.openservices.tablestore.core.auth.CredentialsProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentialProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentials;
import com.alicloud.openservices.tablestore.model.AlwaysRetryStrategy;
import com.alicloud.openservices.tablestore.model.ListTableRequest;
import com.alicloud.openservices.tablestore.model.ListTableResponse;

import java.util.concurrent.*;

public class InitAsyncClientV2 {

    public static void main(String[] args) throws InterruptedException, ExecutionException, TimeoutException {
        // yourInstanceName 填寫您的執行個體名稱
        final String instanceName = "yourInstanceName";
        // yourEndpoint 填寫您的執行個體訪問地址
        final String endpoint = "yourEndpoint";
        // 擷取系統變數裡的 AccessKey ID 和 AccessKey Secret
        final String accessKeyId = System.getenv("TABLESTORE_ACCESS_KEY_ID");
        final String accessKeySecret = System.getenv("TABLESTORE_ACCESS_KEY_SECRET");

        // 構造 V2 簽名
        DefaultCredentials credentials = new DefaultCredentials(accessKeyId, accessKeySecret);
        CredentialsProvider provider = new DefaultCredentialProvider(credentials);

        // 以非同步方式初始化Table Store用戶端
        AsyncClient client = new AsyncClient(endpoint, provider, instanceName, null, new ResourceManager(null, null));

        /*
        // 您可以通過指定 ClientConfiguration 修改預設配置項，以下樣本為部分自訂配置項。
        ClientConfiguration clientConfiguration = new ClientConfiguration();
        clientConfiguration.setConnectionTimeoutInMillisecond(5000); // 設定建立串連的逾時時間，單位為毫秒。
        clientConfiguration.setSocketTimeoutInMillisecond(5000); // 設定 socket 逾時時間，單位為毫秒。
        clientConfiguration.setRetryStrategy(new AlwaysRetryStrategy()); // 設定重試策略，如果不設定，則採用預設的重試策略。
        AsyncClient client = new AsyncClient(endpoint, provider, instanceName, clientConfiguration, new ResourceManager(null, null));
        */

        Future<ListTableResponse> future = client.listTable(new TableStoreCallback<ListTableRequest, ListTableResponse>() {
            @Override
            public void onCompleted(ListTableRequest listTableRequest, ListTableResponse listTableResponse) {}
            @Override
            public void onFailed(ListTableRequest listTableRequest, Exception e) {}
        });

        ListTableResponse response = future.get(5, TimeUnit.SECONDS);
        if (response.getTableNames() != null) {
            response.getTableNames().forEach(System.out::println);
        }

        // 關閉 Tablestore Client
        client.shutdown();

    }
}

    時序模型

    V4簽名（推薦）

    同步方式

    以下範例程式碼使用V4簽名通過同步方式初始化Client，擷取執行個體下的時序表列表並列印到控制台。

    import com.alicloud.openservices.tablestore.ClientConfiguration;
import com.alicloud.openservices.tablestore.TimeseriesClient;
import com.alicloud.openservices.tablestore.core.ResourceManager;
import com.alicloud.openservices.tablestore.core.auth.CredentialsProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentialProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentials;
import com.alicloud.openservices.tablestore.core.auth.V4Credentials;
import com.alicloud.openservices.tablestore.model.AlwaysRetryStrategy;
import com.alicloud.openservices.tablestore.model.timeseries.ListTimeseriesTableResponse;

public class InitTimeseriesClientV4 {
    public static void main(String[] args) {
        // yourRegion 填寫您的執行個體所在地區，如 cn-hangzhou
        final String region = "yourRegion";
        // yourInstanceName 填寫您的執行個體名稱
        final String instanceName = "yourInstanceName";
        // yourEndpoint 填寫您的執行個體訪問地址
        final String endpoint = "yourEndpoint";
        // 擷取系統變數裡的 AccessKey ID 和 AccessKey Secret
        final String accessKeyId = System.getenv("TABLESTORE_ACCESS_KEY_ID");
        final String accessKeySecret = System.getenv("TABLESTORE_ACCESS_KEY_SECRET");

        // 構造 V4 簽名
        DefaultCredentials credentials = new DefaultCredentials(accessKeyId, accessKeySecret);
        V4Credentials credentialsV4 = V4Credentials.createByServiceCredentials(credentials, region);
        CredentialsProvider provider = new DefaultCredentialProvider(credentialsV4);

        // 以同步方式初始化Table Store用戶端
        TimeseriesClient client = new TimeseriesClient(endpoint, provider, instanceName, null, new ResourceManager(null, null));

        /*
        // 您可以通過指定 ClientConfiguration 修改預設配置項，以下樣本為部分自訂配置項。
        ClientConfiguration clientConfiguration = new ClientConfiguration();
        clientConfiguration.setConnectionTimeoutInMillisecond(5000); // 設定建立串連的逾時時間，單位為毫秒。
        clientConfiguration.setSocketTimeoutInMillisecond(5000); // 設定 socket 逾時時間，單位為毫秒。
        clientConfiguration.setRetryStrategy(new AlwaysRetryStrategy()); // 設定重試策略，如果不設定，則採用預設的重試策略。
        TimeseriesClient client = new TimeseriesClient(endpoint, provider, instanceName, clientConfiguration, new ResourceManager(null, null));
         */

        // 列出執行個體下的時序表列表並列印到控制台
        ListTimeseriesTableResponse listTimeseriesTableResponse = client.listTimeseriesTable();
        listTimeseriesTableResponse.getTimeseriesTableNames().forEach(System.out::println);

        // 關閉 Tablestore TimeSeriesClient
        client.shutdown();
    }
}

    非同步方式

    以下範例程式碼使用V4簽名通過非同步方式初始化Client，擷取執行個體下的時序表列表並列印到控制台。

    import com.alicloud.openservices.tablestore.AsyncTimeseriesClient;
import com.alicloud.openservices.tablestore.ClientConfiguration;
import com.alicloud.openservices.tablestore.TableStoreCallback;
import com.alicloud.openservices.tablestore.core.ResourceManager;
import com.alicloud.openservices.tablestore.core.auth.CredentialsProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentialProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentials;
import com.alicloud.openservices.tablestore.core.auth.V4Credentials;
import com.alicloud.openservices.tablestore.model.AlwaysRetryStrategy;
import com.alicloud.openservices.tablestore.model.timeseries.ListTimeseriesTableRequest;
import com.alicloud.openservices.tablestore.model.timeseries.ListTimeseriesTableResponse;

import java.util.concurrent.*;

public class InitAsyncTimeseriesClientV4 {
    public static void main(String[] args) throws InterruptedException, TimeoutException, ExecutionException {
        // yourRegion 填寫您的執行個體所在地區，如 cn-hangzhou
        final String region = "yourRegion";
        // yourInstanceName 填寫您的執行個體名稱
        final String instanceName = "yourInstanceName";
        // yourEndpoint 填寫您的執行個體訪問地址
        final String endpoint = "yourEndpoint";
        // 擷取系統變數裡的 AccessKey ID 和 AccessKey Secret
        final String accessKeyId = System.getenv("TABLESTORE_ACCESS_KEY_ID");
        final String accessKeySecret = System.getenv("TABLESTORE_ACCESS_KEY_SECRET");

        // 構造 V4 簽名
        DefaultCredentials credentials = new DefaultCredentials(accessKeyId, accessKeySecret);
        V4Credentials credentialsV4 = V4Credentials.createByServiceCredentials(credentials, region);
        CredentialsProvider provider = new DefaultCredentialProvider(credentialsV4);

        // 以非同步方式初始化Table Store用戶端
        AsyncTimeseriesClient client = new AsyncTimeseriesClient(endpoint, provider, instanceName, null, new ResourceManager(null, null));

        /*
        // 您可以通過指定 ClientConfiguration 修改預設配置項，以下樣本為部分自訂配置項。
        ClientConfiguration clientConfiguration = new ClientConfiguration();
        clientConfiguration.setConnectionTimeoutInMillisecond(5000); // 設定建立串連的逾時時間，單位為毫秒。
        clientConfiguration.setSocketTimeoutInMillisecond(5000); // 設定 socket 逾時時間，單位為毫秒。
        clientConfiguration.setRetryStrategy(new AlwaysRetryStrategy()); // 設定重試策略，如果不設定，則採用預設的重試策略。
        AsyncTimeseriesClient client = new AsyncTimeseriesClient(endpoint, provider, instanceName, clientConfiguration, new ResourceManager(null, null));
        */
        
        Future<ListTimeseriesTableResponse> future = client.listTimeseriesTable(new TableStoreCallback<ListTimeseriesTableRequest, ListTimeseriesTableResponse>() {
            @Override
            public void onCompleted(ListTimeseriesTableRequest listTimeseriesTableRequest, ListTimeseriesTableResponse listTimeseriesTableResponse) {}
            @Override
            public void onFailed(ListTimeseriesTableRequest listTimeseriesTableRequest, Exception e) {}
        });

        ListTimeseriesTableResponse response = future.get(5, TimeUnit.SECONDS);
        if (response.getTimeseriesTableNames() != null) {
            response.getTimeseriesTableNames().forEach(System.out::println);
        }

        // 關閉 Tablestore Client
        client.shutdown();
    }
}

    V2簽名

    同步方式

    以下範例程式碼使用V2簽名通過同步方式初始化Client，擷取執行個體下的時序表列表並列印到控制台。

    import com.alicloud.openservices.tablestore.ClientConfiguration;
import com.alicloud.openservices.tablestore.TimeseriesClient;
import com.alicloud.openservices.tablestore.core.ResourceManager;
import com.alicloud.openservices.tablestore.core.auth.CredentialsProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentialProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentials;
import com.alicloud.openservices.tablestore.model.AlwaysRetryStrategy;
import com.alicloud.openservices.tablestore.model.timeseries.ListTimeseriesTableResponse;

public class InitTimeseriesClientV2 {
    public static void main(String[] args) {
        // yourInstanceName 填寫您的執行個體名稱
        final String instanceName = "yourInstanceName";
        // yourEndpoint 填寫您的執行個體訪問地址
        final String endpoint = "yourEndpoint";
        // 擷取系統變數裡的 AccessKey ID 和 AccessKey Secret
        final String accessKeyId = System.getenv("TABLESTORE_ACCESS_KEY_ID");
        final String accessKeySecret = System.getenv("TABLESTORE_ACCESS_KEY_SECRET");

        // 構造 V2 簽名
        DefaultCredentials credentials = new DefaultCredentials(accessKeyId, accessKeySecret);
        CredentialsProvider provider = new DefaultCredentialProvider(credentials);

        // 以同步方式初始化Table Store用戶端
        TimeseriesClient client = new TimeseriesClient(endpoint, provider, instanceName, null, new ResourceManager(null, null));

        /*
        // 您可以通過指定 ClientConfiguration 修改預設配置項，以下樣本為部分自訂配置項。
        ClientConfiguration clientConfiguration = new ClientConfiguration();
        clientConfiguration.setConnectionTimeoutInMillisecond(5000); // 設定建立串連的逾時時間，單位為毫秒。
        clientConfiguration.setSocketTimeoutInMillisecond(5000); // 設定 socket 逾時時間，單位為毫秒。
        clientConfiguration.setRetryStrategy(new AlwaysRetryStrategy()); // 設定重試策略，如果不設定，則採用預設的重試策略。
        TimeseriesClient client = new TimeseriesClient(endpoint, provider, instanceName, clientConfiguration, new ResourceManager(null, null));
         */

        // 列出執行個體下的時序表列表並列印到控制台
        ListTimeseriesTableResponse listTimeseriesTableResponse = client.listTimeseriesTable();
        listTimeseriesTableResponse.getTimeseriesTableNames().forEach(System.out::println);

        // 關閉 Tablestore TimeSeriesClient
        client.shutdown();
    }
}

    非同步方式

    以下範例程式碼使用V2簽名通過非同步方式初始化Client，擷取執行個體下的時序表列表並列印到控制台。

    import com.alicloud.openservices.tablestore.AsyncTimeseriesClient;
import com.alicloud.openservices.tablestore.ClientConfiguration;
import com.alicloud.openservices.tablestore.TableStoreCallback;
import com.alicloud.openservices.tablestore.core.ResourceManager;
import com.alicloud.openservices.tablestore.core.auth.CredentialsProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentialProvider;
import com.alicloud.openservices.tablestore.core.auth.DefaultCredentials;
import com.alicloud.openservices.tablestore.model.AlwaysRetryStrategy;
import com.alicloud.openservices.tablestore.model.timeseries.ListTimeseriesTableRequest;
import com.alicloud.openservices.tablestore.model.timeseries.ListTimeseriesTableResponse;

import java.util.concurrent.*;

public class InitAsyncTimeseriesClientV2 {

    public static void main(String[] args) throws InterruptedException, TimeoutException, ExecutionException {
        // yourInstanceName 填寫您的執行個體名稱
        final String instanceName = "yourInstanceName";
        // yourEndpoint 填寫您的執行個體訪問地址
        final String endpoint = "yourEndpoint";
        // 擷取系統變數裡的 AccessKey ID 和 AccessKey Secret
        final String accessKeyId = System.getenv("TABLESTORE_ACCESS_KEY_ID");
        final String accessKeySecret = System.getenv("TABLESTORE_ACCESS_KEY_SECRET");

        // 構造 V2 簽名
        DefaultCredentials credentials = new DefaultCredentials(accessKeyId, accessKeySecret);
        CredentialsProvider provider = new DefaultCredentialProvider(credentials);

        // 以非同步方式初始化Table Store用戶端
        AsyncTimeseriesClient client = new  AsyncTimeseriesClient(endpoint, provider, instanceName, null, new ResourceManager(null, null));

        /*
        // 您可以通過指定 ClientConfiguration 修改預設配置項，以下樣本為部分自訂配置項。
        ClientConfiguration clientConfiguration = new ClientConfiguration();
        clientConfiguration.setConnectionTimeoutInMillisecond(5000); // 設定建立串連的逾時時間，單位為毫秒。
        clientConfiguration.setSocketTimeoutInMillisecond(5000); // 設定 socket 逾時時間，單位為毫秒。
        clientConfiguration.setRetryStrategy(new AlwaysRetryStrategy()); // 設定重試策略，如果不設定，則採用預設的重試策略。
        AsyncTimeseriesClient client = new  AsyncTimeseriesClient(endpoint, provider, instanceName, null, new ResourceManager(null, null));
        */
        
        Future<ListTimeseriesTableResponse> future = client.listTimeseriesTable(new TableStoreCallback<ListTimeseriesTableRequest, ListTimeseriesTableResponse>() {
            @Override
            public void onCompleted(ListTimeseriesTableRequest listTimeseriesTableRequest, ListTimeseriesTableResponse listTimeseriesTableResponse) {}
            @Override
            public void onFailed(ListTimeseriesTableRequest listTimeseriesTableRequest, Exception e) {}
        });

        ListTimeseriesTableResponse response = future.get(5, TimeUnit.SECONDS);
        if (response.getTimeseriesTableNames() != null) {
            response.getTimeseriesTableNames().forEach(System.out::println);
        }

        // 關閉 Tablestore Client
        client.shutdown();
    }
}

    常見問題

    相關文檔

    • 為了進一步保證使用者密鑰的安全，Tablestore支援在初始化用戶端時使用V4簽名演算法對使用者密鑰進行保護，推薦您使用V4簽名進行用戶端初始化。更多資訊，請參見使用者密鑰安全。