Use a private endpoint to connect to an ApsaraDB for Redis instance - ApsaraDB for Redis (2023)

import redis.clients.jedis.HostAndPort; import redis.clients.jedis.JedisCluster; import redis.clients.jedis.JedisPoolConfig; import java.util.HashSet; import java.util.Set; public class DirectTest { private static final int DEFAULT_TIMEOUT = 2000; private static final int DEFAULT_REDIRECTIONS = 5; private static final JedisPoolConfig DEFAULT_CONFIG = new JedisPoolConfig(); public static void main(String args[]){ // Specify the private endpoint that you applied for the cluster instance. String host = "r-bp1xxxxxxxxxxxx.redis.rds.aliyuncs.com"; int port = 6379; String password = "xxxx"; Set<HostAndPort> jedisClusterNode = new HashSet<HostAndPort>(); jedisClusterNode.add(new HostAndPort(host, port)); JedisCluster jc = new JedisCluster(jedisClusterNode, DEFAULT_TIMEOUT, DEFAULT_TIMEOUT, DEFAULT_REDIRECTIONS,password, "clientName", DEFAULT_CONFIG); jc.set("key","value"); jc.get("key"); jc.close(); } }

import redis.clients.jedis.*; import java.util.HashSet; import java.util.Set; public class main { private static final int DEFAULT_TIMEOUT = 2000; private static final int DEFAULT_REDIRECTIONS = 5; private static final JedisPoolConfig DEFAULT_CONFIG = new JedisPoolConfig(); public static void main(String args[]){ JedisPoolConfig config = new JedisPoolConfig(); // Specify the maximum number of idle connections. In direct connection mode, the client directly connects to a shard of a cluster instance. Therefore, the following requirement must be met: Number of clients × Value of MaxTotal < Maximum number of connections to a single shard. // Set the maximum number of connections to a shard of an ApsaraDB for Redis Community Edition instance to 10000 and set the maximum number of connections to a shard of an ApsaraDB for Redis Enhanced Edition (Tair) instance to 30000. config.setMaxTotal(30); // Specify the maximum number of idle connections based on your business needs. config.setMaxIdle(20); config.setTestOnBorrow(false); config.setTestOnReturn(false); // Specify the private endpoint that you applied for the cluster instance. String host = "r-bp1xxxxxxxxxxxx.redis.rds.aliyuncs.com"; int port = 6379; // Specify the password of the instance. String password = "xxxxx"; Set<HostAndPort> jedisClusterNode = new HashSet<HostAndPort>(); jedisClusterNode.add(new HostAndPort(host, port)); JedisCluster jc = new JedisCluster(jedisClusterNode, DEFAULT_TIMEOUT, DEFAULT_TIMEOUT, DEFAULT_REDIRECTIONS,password, "clientName", config); } }

<?php // Specify the private endpoint and the port number to connect to the cluster instance. $array = ['r-bp1xxxxxxxxxxxx.redis.rds.aliyuncs.com:6379']; // Specify the password for the connection. $pwd = "xxxx"; // Use the password to connect to the cluster instance. $obj_cluster = new RedisCluster(NULL, $array, 1.5, 1.5, true, $pwd); // Display the result of the connection. var_dump($obj_cluster); if ($obj_cluster->set("foo", "bar") == false) { die($obj_cluster->getLastError()); } $value = $obj_cluster->get("foo"); echo $value; ?>

@Bean JedisConnectionFactory redisConnectionFactory() { List<String> clusterNodes = Arrays.asList("host1:port1", "host2:port2", "host3:port3"); RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration(clusterNodes); redisClusterConfiguration.setPassword("xxx"); JedisPoolConfig jedisPoolConfig = new JedisPoolConfig(); // Specify the maximum number of idle connections. In direct connection mode, the client directly connects to a shard of a cluster instance. Therefore, the following requirement must be met: Number of clients × Value of MaxTotal < Maximum number of connections to a single shard. // Set the maximum number of connections to a shard of an ApsaraDB for Redis Community Edition instance to 10000 and set the maximum number of connections to a shard of an ApsaraDB for Redis Enhanced Edition (Tair) instance to 30000. jedisPoolConfig.setMaxTotal(30); // Specify the maximum number of idle connections based on your business needs. jedisPoolConfig.setMaxIdle(20); // Disable testOn[Borrow|Return] to prevent generating additional ping commands. jedisPoolConfig.setTestOnBorrow(false); jedisPoolConfig.setTestOnReturn(false); return new JedisConnectionFactory(redisClusterConfiguration, jedisPoolConfig); }

@Bean public LettuceConnectionFactory redisConnectionFactory() { List<String> clusterNodes = Arrays.asList("host1:port1", "host2:port2", "host3:port3"); RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration(clusterNodes); redisClusterConfiguration.setPassword("xxx"); ClusterTopologyRefreshOptions topologyRefreshOptions = ClusterTopologyRefreshOptions.builder() .enablePeriodicRefresh(Duration.ofSeconds(15)) // Specify the interval at which the topology of the cluster instance is refreshed. We recommend that you set the interval to 15 seconds. If you set it to a smaller value, a large number of calls are made to the nodes of the cluster instance. This degrades the cluster instance performance. .dynamicRefreshSources(false) // Specify whether to use the IP addresses of the nodes obtained from the topology as nodes to be called to refresh the topology of the cluster instance. If you connect to an ApsaraDB for Redis instance, you must set the parameter to false. .enableAllAdaptiveRefreshTriggers() // Enable all triggers to adaptively refresh the topology. After adaptive refresh is enabled, the topology of the cluster instance is automatically refreshed each time a runtime event such as a MOVED redirection occurs on the cluster instance. .adaptiveRefreshTriggersTimeout(Duration.ofSeconds(15)).build(); // Specify the time period during which the topology of the cluster instance can be refreshed only once. This prevents the topology from being frequently refreshed. LettuceClientConfiguration lettuceClientConfiguration = LettuceClientConfiguration.builder(). clientOptions(ClusterClientOptions.builder() .validateClusterNodeMembership(false) .topologyRefreshOptions(topologyRefreshOptions).build()).build(); return new LettuceConnectionFactory(redisClusterConfiguration, lettuceClientConfiguration); }

public class ClusterDemo { public static void main(String[] args) throws Exception { String host = "r-bp1xxxxxxxxxxxx.redis.rds.aliyuncs.com"; int port = 30001; String password = "xxxx"; RedisURI redisURI = RedisURI.Builder.redis(host) .withPort(port) .withPassword(password) .build(); ClusterTopologyRefreshOptions refreshOptions = ClusterTopologyRefreshOptions.builder() .enablePeriodicRefresh(Duration.ofSeconds(15)) // Specify the interval at which the topology of the cluster instance is refreshed. We recommend that you set the interval to 15 seconds. If you set it to a smaller value, a large number of calls are made to the nodes of the cluster instance. This degrades the cluster instance performance. .dynamicRefreshSources(false) // Specify whether to use the IP addresses of the nodes obtained from the topology as nodes to be called to refresh the topology of the cluster instance. If you connect to an ApsaraDB for Redis instance, you must set the parameter to false. .enableAllAdaptiveRefreshTriggers() // Enable all triggers to adaptively refresh the topology. After adaptive refresh is enabled, the topology of the cluster instance is automatically refreshed each time a runtime event such as a MOVED redirection occurs on the cluster instance. .adaptiveRefreshTriggersTimeout(Duration.ofSeconds(15)).build(); // Specify the time period during which the topology of the cluster instance can be refreshed only once. This prevents the topology from being frequently refreshed. RedisClusterClient redisClient = RedisClusterClient.create(redisURI); redisClient.setOptions(ClusterClientOptions.builder() .socketOptions(SocketOptions.builder() .keepAlive(true) // Set the keepAlive parameter to true. .build()) .validateClusterNodeMembership(false) .topologyRefreshOptions(refreshOptions).build()); StatefulRedisClusterConnection<String, String> connection = redisClient.connect(); connection.sync().set("key", "value"); } }