Tablestore:Initialize TunnelClient

public TunnelClient(
    String endpoint,
    CredentialsProvider credsProvider,
    String instanceName,
    ClientConfiguration config,
    ResourceManager resourceManager
)

import com.alicloud.openservices.tablestore.TunnelClient;
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.tunnel.ListTunnelRequest;
import com.alicloud.openservices.tablestore.model.tunnel.ListTunnelResponse;

public class InitTunnelClient {

    public static void main(String[] args) {
        String accessKeyId = System.getenv("TABLESTORE_ACCESS_KEY_ID");
        String accessKeySecret = System.getenv("TABLESTORE_ACCESS_KEY_SECRET");
        String region = "<region-id>";
        String instanceName = "<instance-name>";
        String endpoint = "<instance-endpoint>";
        String tableName = "<table-name>";

        TunnelClient tunnelClient = null;
        try {
            DefaultCredentials credentials = new DefaultCredentials(accessKeyId, accessKeySecret);
            V4Credentials credentialsV4 = V4Credentials.createByServiceCredentials(credentials, region);
            CredentialsProvider provider = new DefaultCredentialProvider(credentialsV4);

            tunnelClient = new TunnelClient(
                endpoint,
                provider,
                instanceName,
                null,
                null
            );

            ListTunnelResponse response = tunnelClient.listTunnel(new ListTunnelRequest(tableName));
            System.out.println("TunnelClient initialized. Tunnels: " + response.getTunnelInfos().size());
            System.out.println("RequestId: " + response.getRequestId());
        } finally {
            if (tunnelClient != null) {
                tunnelClient.shutdown();
            }
        }
    }
}

Client

Le constructeur TunnelClient contient les paramètres suivants.

Configuration du client

Le paramètre config est de type ClientConfiguration. Utilisez les méthodes setXxx correspondantes pour configurer les paramètres de connexion, de délai d'attente et de nouvelle tentative. Si vous n'avez pas besoin de paramètres personnalisés, définissez config sur null. Le tableau suivant décrit les paramètres courants.

D'autres paramètres client, tels que le proxy, la compression, le cache DNS, le traçage des requêtes et les paramètres de session SSL, sont également configurés à l'aide des méthodes correspondantes de ClientConfiguration.

Gestionnaire de ressources

Le paramètre resourceManager est de type ResourceManager. Pour un TunnelClient utilisé de manière indépendante, définissez ce paramètre sur null. Le client crée un gestionnaire de ressources basé sur config et libère ses ressources lorsque vous appelez shutdown.

Pour personnaliser ou partager des ressources, utilisez ResourceManager(ClientConfiguration configuration, ExecutorService callbackExecutor) pour créer un ResourceManager propriétaire. Le constructeur contient les paramètres suivants.

Personnaliser la configuration du client

Pour ajuster les paramètres par défaut de connexion, de délai d'attente ou de nouvelle tentative, importez ClientConfiguration dans l'exemple de base et remplacez le code d'initialisation du client par le code suivant :

ClientConfiguration config = new ClientConfiguration();
config.setMaxConnections(200);
config.setConnectionTimeoutInMillisecond(10000);
config.setSocketTimeoutInMillisecond(30000);
config.setRetryThreadCount(2);

tunnelClient = new TunnelClient(
    endpoint,
    provider,
    instanceName,
    config,
    null
);

Partager les ressources du client

Si plusieurs clients doivent partager des connexions HTTP, des threads de nouvelle tentative et des threads de rappel, créez un ResourceManager propriétaire et transmettez l'instance partagée renvoyée par sharedResourceManager() à chaque client. Après avoir fermé tous les clients, fermez le ResourceManager propriétaire.

Le code suivant réutilise les variables et le fournisseur d'identifiants de l'exemple de base. Importez ClientConfiguration et ResourceManager avant d'exécuter le code.

ClientConfiguration config = new ClientConfiguration();
ResourceManager owner = new ResourceManager(config);
TunnelClient tunnelClientA = new TunnelClient(
    endpoint, provider, instanceName, config, owner.sharedResourceManager());
TunnelClient tunnelClientB = new TunnelClient(
    endpoint, provider, instanceName, config, owner.sharedResourceManager());

try {
    tunnelClientA.listTunnel(new ListTunnelRequest(tableName));
    tunnelClientB.listTunnel(new ListTunnelRequest(tableName));
} finally {
    tunnelClientA.shutdown();
    tunnelClientB.shutdown();
    owner.shutdown();
}