Tablestore:Inicializar 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();
            }
        }
    }
}

Cliente

O construtor do TunnelClient tem os seguintes parâmetros.

Configuração do cliente

O parâmetro config é do tipo ClientConfiguration. Use os métodos setXxx correspondentes para configurar as definições de conexão, tempo limite e nova tentativa. Se não forem necessárias configurações personalizadas, defina config como null. A tabela a seguir descreve as configurações comuns.

Outras configurações do cliente, como proxy, compactação, cache DNS, rastreamento de solicitações e sessões SSL, também são definidas pelos métodos correspondentes de ClientConfiguration.

Gerenciador de recursos

O parâmetro resourceManager é do tipo ResourceManager. Para um TunnelClient usado de forma independente, defina este parâmetro como null. O cliente cria um gerenciador de recursos com base em config e libera seus recursos ao chamar shutdown.

Para personalizar ou compartilhar recursos, use ResourceManager(ClientConfiguration configuration, ExecutorService callbackExecutor) para criar um ResourceManager proprietário. O construtor inclui os parâmetros listados abaixo.

Personalizar a configuração do cliente

Para ajustar as configurações padrão de conexão, tempo limite ou nova tentativa, importe ClientConfiguration no exemplo básico e substitua o código de inicialização do cliente pelo trecho a seguir:

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

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

Compartilhar recursos do cliente

Se múltiplos clientes precisarem compartilhar conexões HTTP, threads de nova tentativa e threads de callback, crie um ResourceManager proprietário e passe a instância compartilhada retornada por sharedResourceManager() para cada cliente. Após fechar todos os clientes, encerre também o ResourceManager proprietário.

O código a seguir reutiliza as variáveis e o provedor de credenciais do exemplo básico. Importe ClientConfiguration e ResourceManager antes de executar o código.

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