DaxClientConfig config = new DaxClientConfig.Builder() .withConnectTimeout(Duration.ofSeconds(5)) //设置连接超时为5秒 .withRequestTimeout(Duration.ofSeconds(5)) //设置请求超时为5秒 .withMaxRetries(3) //设置最大重试次数为3次 .build();
DaxClient daxClient = new DaxClient(config);
DaxClientConfig config = new DaxClientConfig.Builder() .withClusterEndpoints(Collections.singletonList("mydaxcluster.myregion.dax.amazonaws.com:8111")) .withCredentialProvider(new AWSCredentialsProviderChain()) .build();
ClientConfiguration clientConfig = new ClientConfiguration(); clientConfig.setConnectionTimeout(1000); //设置连接超时为1秒 clientConfig.setSocketTimeout(1000); //设置请求超时为1秒
//创建连接池配置 PoolConfiguration poolConfiguration = new PoolConfiguration(); poolConfiguration.setMinIdle(2); //设置最小空闲连接数为2 poolConfiguration.setMaxIdle(10); //设置最大空闲连接数为10 poolConfiguration.setMaxQueueLength(100); //设置最大队列长度为100
//创建连接池 DaxConnectionPool connectionPool = new DaxConnectionPool(config, clientConfig, poolConfiguration);
//从连接池中获取连接 DaxClient daxClient = new DaxClient(connectionPool);
下一篇:Awsdax稳定性问题