ApsaraDB for Redis:Use a client to connect to an ApsaraDB for Redis instance

Usage notes

• By default, cluster and read/write splitting instances run in proxy mode. In this mode, you can connect to such an ApsaraDB for Redis instance by using the endpoint of a proxy node in the instance in the same manner as you connect to an ApsaraDB for Redis standard instance. For more information about cluster and read/write splitting instances, see Cluster master-replica instances or Read/write splitting instances.
  Note If you use a private endpoint to connect to an ApsaraDB for Redis instance, you can connect to the instance in the same manner as you connect to an open source Redis cluster. For more information about private endpoints, see Enable the direct connection mode.
• If password-free access is enabled for an ApsaraDB for Redis instance deployed in a VPC, a client in the same VPC as the instance can connect to the instance without using passwords. For more information, see Enable password-free access.

Obtain connection information

When you use a client to connect to an ApsaraDB for Redis instance, you must obtain the connection information described in the following table and specify the information in the code.

Common types of clients

For information about all types of clients supported by Redis, see Clients.

• Jedis client
• TairJedis client (for ApsaraDB for Redis Enhanced Edition (Tair))
• PhpRedis client
• redis-py client
• C or C++ client
• .NET client
• node-redis client
• go-redis client
• Lettuce client (not recommended)

Jedis client

1. Download and install the Jedis client.
2. Select a connection method based on your business requirements.
   1. Start the Eclipse client, create a project, and then add the following dependency to the pom file:

      <dependency>
         <groupId>redis.clients</groupId>
         <artifactId>jedis</artifactId>
         <version>Latest version</version>
         <type>jar</type>
         <scope>compile</scope>
      </dependency>

   2. Enter the following code in the project based on the Jedis client version and modify the code based on the comments.
      Jedis 4.3.0 Jedis 2.4.0 and earlier A single connection to ApsaraDB for Redis from Jedis (not recommended because the connection cannot be restored if it times out)

      JedisPoolConfig config = new JedisPoolConfig();
      // Specify the maximum number of idle connections based on your business needs. This value cannot exceed the maximum number of connections supported by the ApsaraDB for Redis instance.
      config.setMaxIdle(200);
      // Specify the maximum number of connections based on your business needs. This value cannot exceed the maximum number of connections supported by the ApsaraDB for Redis instance. 
      config.setMaxTotal(300);
      config.setTestOnBorrow(false);
      config.setTestOnReturn(false);
      // Replace the values of the host and password parameters with the endpoint of the ApsaraDB for Redis instance and the password of the instance account. 
      String host = "r-bp10noxlhcoim2****.redis.rds.aliyuncs.com";
      String password = "testaccount:Rp829dlwa";
      JedisPool pool = new JedisPool(config, host, 6379, 3000, password);
      Jedis jedis = null;
      try {
          jedis = pool.getResource();
          // Refer to the following example and perform the pertinent operations: 
          jedis.set("foo", "bar");
          System.out.println(jedis.get("foo"));
          jedis.zadd("sose", 0, "car");
          jedis.zadd("sose", 0, "bike");
          System.out.println(jedis.zrange("sose", 0, -1));
      } catch (Exception e) {
          // Handle timeout errors or other exceptions. 
          e.printStackTrace();
      } finally {
          if (jedis != null) {
              jedis.close();
          }
      }
      
      pool.destroy();    // If your application exits and you want to destroy the resources, call this method. Then, the connection is closed, and the resources are released. 

      JedisPoolConfig config = new JedisPoolConfig();
      // Specify the maximum number of idle connections based on your business needs. This value cannot exceed the maximum number of connections supported by the ApsaraDB for Redis instance.
      config.setMaxIdle(200);
      // Specify the maximum number of connections based on your business needs. This value cannot exceed the maximum number of connections supported by the ApsaraDB for Redis instance.
      config.setMaxTotal(300);
      config.setTestOnBorrow(false);
      config.setTestOnReturn(false);
      // Replace the values of the host and password parameters with the endpoint of the ApsaraDB for Redis instance and the password of the instance account.
      String host = "r-bp10noxlhcoim2****.redis.rds.aliyuncs.com";
      String password = "testaccount:Rp829dlwa";
      JedisPool pool = new JedisPool(config, host, 6379, 3000, password);
      Jedis jedis = null;
      boolean broken = false;
      try
      {
          jedis = pool.getResource();
          // Refer to the following example and perform the pertinent operations: 
          jedis.set("foo", "bar");
          String foobar = jedis.get("foo");
          jedis.zadd("sose", 0, "car");
          jedis.zadd("sose", 0, "bike");
          Set < String > sose = jedis.zrange("sose", 0, -1);
      }
      catch(Exception e)
      {
          broken = true;
      }
      finally
      {
          if(broken)
          {
              pool.returnBrokenResource(jedis);
          }
          else if(jedis != null)
          {
              pool.returnResource(jedis);
          }
      }
      
      pool.destroy();    // If your application exits and you want to destroy the resources, call this method. Then, the connection is closed, and the resources are released. 

      import redis.clients.jedis.Jedis;
      public class jedistest {
      public static void main(String[] args) {
      try {
           String host = "r-bp10noxlhcoim2****.redis.rds.aliyuncs.com";// Specify the endpoint of the ApsaraDB for Redis instance.
           int port = 6379;
           Jedis jedis = new Jedis(host, port);
           // The authentication information.
           jedis.auth("password");//password
           String key = "redis";
           String value = "aliyun-redis";
           // Select a database. Default value: 0.
           jedis.select(1);
           // Specify a key.
           jedis.set(key, value);
           System.out.println("Set Key " + key + " Value: " + value);
           // Obtain the configured key and value.
           String getvalue = jedis.get(key);
           System.out.println("Get Key " + key + " ReturnValue: " + getvalue);
           jedis.quit();
           jedis.close();
      } 
      catch (Exception e) {
       e.printStackTrace();
       }
      }
      }

3. Run the project. Eclipse may return the following result. The result indicates that the client is connected to the ApsaraDB for Redis instance.

   bar
   [bike, car]

PhpRedis client

1. Download and install the PHPRedis client.
2. Enter the following code in a PHP editor and modify the code based on the comments:

   In this example, the PHP version 8.2.1 and the PHPRedis version 5.3.7 are used.

   Code for regular ApsaraDB for Redis instances Code for ApsaraDB for Redis Enhanced Edition (Tair) instances

   <?php
    /* Replace the values of the host and port parameters with the endpoint and port number of the ApsaraDB for Redis instance.  */
    $host = "r-bp10noxlhcoim2****.redis.rds.aliyuncs.com";
    $port = 6379;
    /* Replace the values of the user and pwd parameters with the username and password of the instance account. */
    $user = "testaccount";
    $pwd = "Rp829dlwa";
    $redis = new Redis();
    if ($redis->connect($host, $port) == false) {
            die($redis->getLastError());
      }
    if ($redis->auth([$user, $pwd]) == false) {
            die($redis->getLastError());
     }
     /* You can perform operations on the instance after the connection is established. For example, you can run the following code to call the set and get methods.  */
    if ($redis->set("foo", "bar") == false) {
            die($redis->getLastError());
    }
    $value = $redis->get("foo");
    echo $value;
    ?>

   <?php
    /* Replace the values of the host and port parameters with the endpoint and port number of the ApsaraDB for Redis instance.  */
    $host = "r-bp10noxlhcoim2****.redis.rds.aliyuncs.com";
    $port = 6379;
    /* Replace the values of the user and pwd parameters with the username and password of the instance account. */
    $user = "testaccount";
    $pwd = "Rp829dlwa";
    $redis = new Redis();
    if ($redis->connect($host, $port) == false) {
            die($redis->getLastError());
      }
    if ($redis->auth([$user, $pwd]) == false) {
            die($redis->getLastError());
     }
     /* You can perform operations on the instance after the connection is established. For example, you can run the following code to use the TairString data module.  */
    if ($redis->set("foo", "bar") == false) {
            die($redis->getLastError());
    }
    /* Returns: 1 */
    $redis->rawCommand("CAS", "foo", "bar", "bzz");
    /* Returns: 1 */
    $redis->rawCommand("CAD", "foo", "bzz");
    /* Returns: OK */
    $redis->rawCommand("EXSET", "foo", "200", "VER", "1");
    /* ERR update version is stale */
    $redis->rawCommand("EXSET", "foo", "300", "VER", "10");
    /* Returns : ["OK", " ", VERSION] */
    $redis->rawCommand("EXCAS", "foo", "300", "1");
    ?>

3. Run the preceding code to connect to the ApsaraDB for Redis instance.

redis-py client

1. Download and install the Redis Python client.
2. Enter the following code in a Python editor and modify the code based on the comments.

   In this example, the Python version 3.9 and the Redis Python version 4.4.1 are used.

   Code for regular ApsaraDB for Redis instances Code for ApsaraDB for Redis Enhanced Edition (Tair) instances

   #!/usr/bin/env python
   #-*- coding: utf-8 -*-
   import redis
   # Replace the values of the host and port parameters with the endpoint and port number of the ApsaraDB for Redis instance. 
   host = 'r-bp10noxlhcoim2****.redis.rds.aliyuncs.com'
   port = 6379
   # Replace the value of the pwd parameter with the password of the instance account. 
   pwd = 'testaccount:Rp829dlwa'
   r = redis.Redis(host=host, port=port, password=pwd)
   # You can perform operations on the instance after the connection is established. For example, you can run the following code to call the set and get methods. 
   r.set('foo', 'bar')
   print(r.get('foo'))

   #!/usr/bin/env python
   #-*- coding: utf-8 -*-
   import redis
   # Replace the values of the host and port parameters with the endpoint and port number of the ApsaraDB for Redis instance. 
   host = 'r-bp10noxlhcoim2****.redis.rds.aliyuncs.com'
   port = 6379
   # Replace the value of the pwd parameter with the password of the instance account. 
   pwd = 'testaccount:Rp829dlwa'
   r = redis.Redis(host=host, port=port, password=pwd)
   # You can perform operations on the instance after the connection is established. For example, you can run the following code to call the set and get methods. 
   print(r.execute_command('CAS foo bar bzz'))
   print(r.execute_command('CAD foo bzz'))
   print(r.execute_command('EXSET foo 200 VER 1'))
   try:
       r.execute_command('EXSET foo 300 VER 10')
   except:
       print("The attached version is different from the server version, the operation will fail. ")
   print(r.execute_command('EXCAS foo 300 1'))

3. Run the preceding code to connect to the ApsaraDB for Redis instance.

Spring Data Redis client

1. Download and install the Spring Data Redis client.
2. Enter the following code in a Spring Data Redis editor and modify the code based on the comments:

   In this example, the Spring Data Redis version 2.7.6 is used.

   Spring Data Redis With Jedis (recommended) Spring Data Redis With Lettuce (not recommended)

   	@Bean
   		 JedisConnectionFactory redisConnectionFactory() {
   			 RedisStandaloneConfiguration config = new RedisStandaloneConfiguration("host", port);
   	 
   			 JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
   			 // Specify the maximum number of connections based on your business needs. This value cannot exceed the maximum number of connections supported by the ApsaraDB for Redis instance. 
   			 jedisPoolConfig.setMaxTotal(30);
   			 // Specify the maximum number of idle connections based on your business needs. This value cannot exceed the maximum number of connections supported by the ApsaraDB for Redis instance. 
   			 jedisPoolConfig.setMaxIdle(20);
   			 // Close testOn[Borrow|Return] to prevent additional PING commands from being generated. 
   			 jedisPoolConfig.setTestOnBorrow(false);
   			 jedisPoolConfig.setTestOnReturn(false);
   	 
   			 JedisClientConfiguration jedisClientConfiguration = JedisClientConfiguration.builder().usePooling().poolConfig(
   				 jedisPoolConfig).build();
   	 
   			 return new JedisConnectionFactory(config, jedisClientConfiguration);
   		 }

    	@Bean
   		LettuceConnectionFactory redisConnectionFactory() {
   			RedisStandaloneConfiguration config = new RedisStandaloneConfiguration("host", 6379);
   			return new LettuceConnectionFactory(config);
   		}

   Note By default, Spring Data Redis 2.0 and later use Lettuce as the driver. If you want to switch over to Jedis, you must exclude the Lettuce dependency and add the Jedis dependency. Example:

   <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-data-redis</artifactId>
       <exclusions>
           <exclusion>
               <artifactId>lettuce-core</artifactId>
               <groupId>io.lettuce</groupId>
           </exclusion>
       </exclusions>
   </dependency>
   
   <dependency>
       <groupId>redis.clients</groupId>
       <artifactId>jedis</artifactId>
       <version>Latest version</version>
   </dependency>

3. Run the preceding code to connect to the ApsaraDB for Redis instance.

C or C++ client

1. Download and install the C Redis client.
2. Enter the following code in a C or C ++ editor and modify the code based on the comments:

   In this example, the HiRedis version 1.1.0 is used.

   Code for regular ApsaraDB for Redis instances Code for ApsaraDB for Redis Enhanced Edition (Tair) instances

   #include <stdio.h>
   #include <stdlib.h>
   #include <string.h>
   #include <hiredis.h>
   int main(int argc, char **argv) {
       unsigned int j;
       redisContext *c;
       redisReply *reply;
       if (argc < 4) {
               printf("Usage: example r-bp10noxlhcoim2****.redis.rds.aliyuncs.com 6379 instance_id password\n");
               exit(0);
       }
       const char *hostname = argv[1];
       const int port = atoi(argv[2]);
       const char *instance_id = argv[3];
       const char *password = argv[4];
       struct timeval timeout = { 1, 500000 }; // 1.5 seconds
       c = redisConnectWithTimeout(hostname, port, timeout);
       if (c == NULL || c->err) {
       if (c) {
               printf("Connection error: %s\n", c->errstr);
               redisFree(c);
       } else {
           printf("Connection error: can't allocate redis context\n");
       }
       exit(1);
       }
       /* AUTH */
       reply = redisCommand(c, "AUTH %s", password);
       printf("AUTH: %s\n", reply->str);
       freeReplyObject(reply);
       /* PING server */
       reply = redisCommand(c,"PING");
       printf("PING: %s\n", reply->str);
       freeReplyObject(reply);
       /* Set a key */
       reply = redisCommand(c,"SET %s %s", "foo", "hello world");
       printf("SET: %s\n", reply->str);
       freeReplyObject(reply);
       /* Set a key using binary safe API */
       reply = redisCommand(c,"SET %b %b", "bar", (size_t) 3, "hello", (size_t) 5);
       printf("SET (binary API): %s\n", reply->str);
       freeReplyObject(reply);
       /* Try a GET and two INCR */
       reply = redisCommand(c,"GET foo");
       printf("GET foo: %s\n", reply->str);
       freeReplyObject(reply);
       reply = redisCommand(c,"INCR counter");
       printf("INCR counter: %lld\n", reply->integer);
       freeReplyObject(reply);
       /* again ... */
       reply = redisCommand(c,"INCR counter");
       printf("INCR counter: %lld\n", reply->integer);
       freeReplyObject(reply);
       /* Create a list of numbers, from 0 to 9 */
       reply = redisCommand(c,"DEL mylist");
       freeReplyObject(reply);
       for (j = 0; j < 10; j++) {
               char buf[64];
               snprintf(buf,64,"%d",j);
               reply = redisCommand(c,"LPUSH mylist element-%s", buf);
               freeReplyObject(reply);
           }
       /* Let's check what we have inside the list */
       reply = redisCommand(c,"LRANGE mylist 0 -1");
       if (reply->type == REDIS_REPLY_ARRAY) {
               for (j = 0; j < reply->elements; j++) {
               printf("%u) %s\n", j, reply->element[j]->str);
       }
       }
       freeReplyObject(reply);
       /* Disconnects and frees the context */
       redisFree(c);
       return 0;
   }

   #include <iostream>
   #include <string>
   #include <string.h>
   #include <hiredis/hiredis.h>
   using namespace std;
    
   int main(int argc, char **argv) {
       unsigned int j;
       redisContext *c;
       redisReply *reply;
       if (argc < 3) {
               printf("Usage: example r-bp10noxlhcoim2****.redis.rds.aliyuncs.com 6379 password\n");
               exit(0);
       }
       const char *hostname = argv[1];
       const int port = atoi(argv[2]);
       const char *password = argv[3];
       struct timeval timeout = { 1, 500000 }; // 1.5 seconds
       c = redisConnectWithTimeout(hostname, port, timeout);
       if (c == NULL || c->err) {
       if (c) {
               printf("Connection error: %s\n", c->errstr);
               redisFree(c);
       } else {
               printf("Connection error: can't allocate redis context\n");
       }
       exit(1);
       }
       /* AUTH */
       reply = (redisReply *)redisCommand(c, "AUTH %s", password);
       printf("AUTH: %s\n", reply->str);
       freeReplyObject(reply);
   
       /* PING server */
       reply = (redisReply *)redisCommand(c,"PING");
       printf("PING: %s\n", reply->str);
       freeReplyObject(reply);
   
       /* The following code provides an example on how to use the TairString data module. */
       reply = (redisReply *)redisCommand(c,"SET foo bar");
       printf("SET: %s\n", reply->str);
       freeReplyObject(reply);
   
       reply = (redisReply *)redisCommand(c,"CAS foo bar bzz");
       printf("CAS: %lld\n", reply->integer);
       freeReplyObject(reply);
   
       reply = (redisReply *)redisCommand(c,"CAD foo bzz");
       printf("CAD: %lld\n", reply->integer);
       freeReplyObject(reply);
   
       /* TairString exstrtype */
       reply = (redisReply *)redisCommand(c,"EXSET foo 200 VER 1");
       printf("EXSET: %s\n", reply->str);
       freeReplyObject(reply);
   
       /* The attached version is different from the server version, the operation will fail */
       reply = (redisReply *)redisCommand(c,"EXSET foo 300 VER 10");
       printf("EXSET: %s\n", reply->str);
       freeReplyObject(reply);
   
       /* Compare the specified version to update the value, and the update is successful
       when the version in the engine is the same as the specified one */
       reply = (redisReply *)redisCommand(c,"EXCAS foo 300 1");
       if (reply->type == REDIS_REPLY_ARRAY) {
           /* ["OK", "", version], The middle value is an empty string, meaningless when successful */
           for (j = 0; j < reply->elements; j++) {
               printf("%u) %s\n", j, reply->element[j]->str);
           }
       }
       freeReplyObject(reply);
   
       /* Disconnects and frees the context */
       redisFree(c);
       return 0;
   }

3. Compile the code.

   gcc -o example -g example.c -I /usr/local/include/hiredis -lhiredis

4. Perform a test run and connect to the ApsaraDB for Redis instance.

    example r-bp10noxlhcoim2****.redis.rds.aliyuncs.com 6379 instance_id password

.NET client

1. Download and install the StackExchange.Redis client.
   Important We recommend that you do not use the ServiceStack Redis or CSRedis client.

   • If you use ServiceStack Redis and run into issues related to the client, you must purchase technical support from ServiceStack.
   • The maintenance of the CSRedis client has been ended.
2. Enter the following code in a StackExchange.Redis editor and modify the code based on the comments.

   In this example, the StackExchange.Redis version 2.5.61 is used.

   Code for regular ApsaraDB for Redis instances Code for ApsaraDB for Redis Enhanced Edition (Tair) instances

   using StackExchange.Redis;
    // Specify the endpoint, port number, and password of the ApsaraDB for Redis instance. 
    private static ConfigurationOptions configurationOptions = ConfigurationOptions.Parse("r-bp10noxlhcoim2****.redis.rds.aliyuncs.com:6379,password=testaccount:Rp829dlwa,connectTimeout=2000");
     //the lock for singleton
    private static readonly object Locker = new object();
     //singleton
    private static ConnectionMultiplexer redisConn;
    //singleton
    public static ConnectionMultiplexer getRedisConn()
    {
        if (redisConn == null)
        {
            lock (Locker)
            {
                if (redisConn == null || !redisConn.IsConnected)
                {
                    redisConn = ConnectionMultiplexer.Connect(configurationOptions);
                }
            }
        }
        return redisConn;
    }

   using System;
   using StackExchange.Redis;
   
   namespace CSharpTestRedis
   {
       class Program
       {  
           // Specify the endpoint, port number, and password of the ApsaraDB for Redis instance. 
   		private static ConfigurationOptions connDCS = ConfigurationOptions.Parse("r-bp10noxlhcoim2****.redis.rds.aliyuncs.com:6379,password=testaccount:Rp829dlwa");
           //the lock for singleton
           private static readonly object Locker = new object();
           //singleton
           private static ConnectionMultiplexer redisConn;
           //singleton
           public static ConnectionMultiplexer getRedisConn()
           {
               if (redisConn == null)
               {
                   lock (Locker)
                   {
                       if (redisConn == null || !redisConn.IsConnected)
                       {
                           redisConn = ConnectionMultiplexer.Connect(connDCS);
                       }
                   }
               }
               return redisConn;
           }
           static void Main(string[] args)
           {
               redisConn = getRedisConn();
               var db = redisConn.GetDatabase();
   
               var ret = db.Execute("set", "foo", "bal");
               Console.WriteLine("set " + ret);
               ret = db.Execute("CAS", "foo", "bal", "bzz");
               Console.WriteLine("CAS " + ret);
               ret = db.Execute("CAD", "foo", "bzz");
               Console.WriteLine("CAD " + ret);
               ret = db.Execute("EXSET", "foo", "200", "VER", "1");
               Console.WriteLine("EXSET " + ret);
               
               try {
                   ret = db.Execute("EXSET", "foo", "300", "VER", "10");
                   Console.WriteLine("EXSET " + ret);
               } catch (Exception ex) {
                   Console.WriteLine("ERR : " + ex.ToString());
               }
               // ["OK", "", version], The middle value is an empty string, meaningless when successful.
               db.Execute("EXCAS", "foo", "300", "1");
               Console.WriteLine("END");
           }
       }
   }

   Note

   • ConfigurationOptions is a core object of the StackExchange.Redis client. ConfigurationOptions is shared and reused by the client. The singleton pattern is recommended. For more information about parameter settings, see Configuration Options.
   • GetDatabase() returns a lightweight object. You can obtain this object from the ConnectionMultiplexer object.

      redisConn = getRedisConn();
      var db = redisConn.GetDatabase();

   Use the following common data modules to perform operations. These data structures are slightly different from those used in native Redis APIs.

   String Hash List Set Sorted Set

   //set get
   string strKey = "hello";
   string strValue = "world";
   bool setResult = db.StringSet(strKey, strValue);
   Console.WriteLine("set " + strKey + " " + strValue + ", result is " + setResult);
   //incr
   string counterKey = "counter";
   long counterValue = db.StringIncrement(counterKey);
   Console.WriteLine("incr " + counterKey + ", result is " + counterValue);
   //expire
   db.KeyExpire(strKey, new TimeSpan(0, 0, 5));
   Thread.Sleep(5 * 1000);
   Console.WriteLine("expire " + strKey + ", after 5 seconds, value is " + db.StringGet(strKey));
   //mset mget
   KeyValuePair<RedisKey, RedisValue> kv1 = new KeyValuePair<RedisKey, RedisValue>("key1", "value1");
   KeyValuePair<RedisKey, RedisValue> kv2 = new KeyValuePair<RedisKey, RedisValue>("key2", "value2");
   db.StringSet(new KeyValuePair<RedisKey, RedisValue>[] {kv1,kv2});            
   RedisValue[] values = db.StringGet(new RedisKey[] {kv1.Key, kv2.Key});
   Console.WriteLine("mget " + kv1.Key.ToString() + " " + kv2.Key.ToString() + ", result is " + values[0] + "&&" + values[1]);

   string hashKey = "myhash";
   //hset
   db.HashSet(hashKey,"f1","v1");
   db.HashSet(hashKey,"f2", "v2");
   HashEntry[] values = db.HashGetAll(hashKey);
   //hgetall
   Console.Write("hgetall " + hashKey + ", result is");
   for (int i = 0; i < values.Length;i++) 
   {
     HashEntry hashEntry = values[i];
     Console.Write(" " + hashEntry.Name.ToString() + " " + hashEntry.Value.ToString());
   }
   Console.WriteLine();

   //list key
   string listKey = "myList";
   //rpush
   db.ListRightPush(listKey, "a");
   db.ListRightPush(listKey, "b");
   db.ListRightPush(listKey, "c");
   //lrange
   RedisValue[] values = db.ListRange(listKey, 0, -1);
   Console.Write("lrange " + listKey + " 0 -1, result is ");
   for (int i = 0; i < values.Length; i++)
   {
    Console.Write(values[i] + " ");
   }
   Console.WriteLine();

   //set key
   string setKey = "mySet";
   //sadd
   db.SetAdd(setKey, "a");
   db.SetAdd(setKey, "b");
   db.SetAdd(setKey, "c");
   //sismember
   bool isContains = db.SetContains(setKey, "a");
   Console.WriteLine("set " + setKey + " contains a is " + isContains );

   string sortedSetKey = "myZset";
   //sadd
   db.SortedSetAdd(sortedSetKey, "xiaoming", 85);
   db.SortedSetAdd(sortedSetKey, "xiaohong", 100);
   db.SortedSetAdd(sortedSetKey, "xiaofei", 62);
   db.SortedSetAdd(sortedSetKey, "xiaotang", 73);
   //zrevrangebyscore
   RedisValue[] names = db.SortedSetRangeByRank(sortedSetKey, 0, 2, Order.Ascending);
   Console.Write("zrevrangebyscore " + sortedSetKey + " 0 2, result is ");
   for (int i = 0; i < names.Length; i++)
   {
     Console.Write(names[i] + " ");
   }
   Console.WriteLine();

node-redis client

1. Download and install the node-redis client.
2. Enter the following code in the node-redis client and modify the code based on the comments:

   In this example, the Node.js version 19.4.0 and the node-redis version 4.5.1 are used.

   Code for regular ApsaraDB for Redis instances Code for ApsaraDB for Redis Enhanced Edition (Tair) instances

   import { createClient } from 'redis';
   
   // Specify the port number, endpoint, username, and password of the instance.
   const client = createClient({
     // redis[s]://[[username][:password]@][host][:port][/db-number]
     url: 'redis://testaccount:Rp829dlwa@r-bp10noxlhcoim2****.redis.rds.aliyuncs.com:6379'
   });
   
   client.on('error', (err) => console.log('Redis Client Error', err));
   
   await client.connect();
   
   await client.set('foo', 'bar');
   const value = await client.get('foo');
   console.log("get foo: %s", value);
   await client.disconnect();

   import { createClient } from 'redis';
   
   // Specify the port number, endpoint, username, and password of the instance.
   const client = createClient({
     // redis[s]://[[username][:password]@][host][:port][/db-number]
     url: 'redis://testaccount:Rp829dlwa@r-bp10noxlhcoim2****.redis.rds.aliyuncs.com:6379'
   });
   
   client.on('error', (err) => console.log('Redis Client Error', err));
   
   await client.connect();
   
   await client.set('foo', 'bar');
   await client.get('foo');
   const value = await client.sendCommand(['CAS', 'foo', 'bar', 'bzz']);
   console.log("cas result: %s", value);
   await client.disconnect();

   Note

   If the SyntaxError: Cannot use import statement outside a module error message is returned, change the suffix of the .js file to .mjs and add the --experimental-modules option when you use this client. Example: node --experimental-modules redis.mjs.

3. Run the preceding code to connect to the ApsaraDB for Redis instance.

go-redis client

1. Download and install the go-redis client.
2. Enter the following code in a go-redis editor and modify the code based on the comments:

   In this example, the Go version 1.18.5 and the go-redis version 8.11.5 are used.

   Code for regular ApsaraDB for Redis instances Code for ApsaraDB for Redis Enhanced Edition (Tair) instances

   package main
   
   import (
   	"github.com/go-redis/redis"
   	"fmt"
   )
   
   func ExampleClient() {
   	client := redis.NewClient(&redis.Options{
           // Specify the endpoint and port number of the ApsaraDB for Redis instance.
   		Addr:     "r-bp10noxlhcoim2****.redis.rds.aliyuncs.com:6379",
           // Specify the password of the instance account.
   		Password: "testaccount:Rp829dlwa",
   		DB:       0,  // use default DB
   	})
       // The following code provides an example on how to call the set and get methods. 
   	err := client.Set("foo", "bar", 0).Err()
   	if err != nil {
   		panic(err)
   	}
   
   	val, err := client.Get("foo").Result()
   	if err != nil {
   		panic(err)
   	}
   	fmt.Println("set : foo -> ", val)
   }
   
   func main() {
   	ExampleClient()
   }

   package main
   
   import (
   	"github.com/go-redis/redis"
   	"fmt"
   )
   
   func ExampleClient() {
   	client := redis.NewClient(&redis.Options{
           // Specify the endpoint and port number of the ApsaraDB for Redis instance.
   		Addr:     "r-bp10noxlhcoim2****.redis.rds.aliyuncs.com:6379",
           // Specify the password of the instance account.
   		Password: "testaccount:Rp829dlwa", // no password set
   		DB:       0,  // use default DB
   	})
   
   	err := client.Set("foo", "bar", 0).Err()
   	if err != nil {
   		panic(err)
   	}
   
   	val, err := client.Get("foo").Result()
   	if err != nil {
   		panic(err)
   	}
   	fmt.Println("set : foo -> ", val)
   	
   	// The following code provides an example on how to use the TairString data module.
   	res, err := client.Do("CAS", "foo", "bar", "bzz").Result()
   	fmt.Println("CAS : ", res)
   
   	res, err = client.Do("CAD", "foo", "bzz").Result()
   	fmt.Println("CAD : ", res)
   
   	res, err = client.Do("EXSET", "foo", "200", "VER", "1").Result()
   	fmt.Println("EXSET : ", res)
   
   	res, err = client.Do("EXSET", "foo", "300", "VER", "10").Result()
   	if err != nil {
   		fmt.Println(err)
   	}
   	fmt.Println("EXSET : ", res)
   
   	res, err = client.Do("EXCAS", "foo", "300", "1").Result()
   	fmt.Println("EXCAS : ", res)
   }
   
   func main() {
   	ExampleClient()
   }

3. Run the preceding code to connect to the ApsaraDB for Redis instance.

Lettuce client

The Lettuce client supports synchronous and asynchronous communication based on comprehensive Redis APIs. The Lettuce client does not automatically reconnect to an instance after multiple requests time out. If failures occur in ApsaraDB for Redis and cause failovers for proxy nodes or data nodes, a connection timeout may occur. This may result in a failure to reconnect to ApsaraDB for Redis. To prevent such risks, we recommend that you use a Jedis client to connect to ApsaraDB for Redis instances. For more information, see Jedis client.

For more information, visit GitHub.