Connect to database with Redis clients

As ApsaraDB for Redis is completely compatible with the native database service, their databases are connected in similar ways. Any clients compatible with the Redis protocol can access Alibaba Cloud ApsaraDB for Redis. You can choose any Redis clients based on their application features.

Note: ApsaraDB for Redis only supports access requests from the Alibaba Cloud intranet rather than those from the Internet. That means only Redis clients installed on ECS instances of the same node can be connected to ApsaraDB for Redis for data operations.

To use Redis clients, see Clients.

• Jedis client
• phpredis client
• redis-py client
• C/C++ client
• .net client
• node-redis client

Jedis client

The Jedis client can access ApsaraDB for Redis through either of the following methods:

• Jedis single-connection

• JedisPool connection

Procedure

1. Click download address to download and install the Jedis client.

2. Example of Jedis single-connection

   1. Open the Eclipse client, create a project, and enter the following code segment:

      import redis.clients.jedis.Jedis;
      public class jedistest {
      public static void main(String[] args) {
      try {
      String host = "xx.kvstore.aliyuncs.com";//The access URL is displayed on the console.
      int port = 6379;
      Jedis jedis = new Jedis(host, port);
      //Authentication information
      jedis.auth("password");//password
      String key = "redis";
      String value = "aliyun-redis";
      //Select a database. (The default value is 0.)
      jedis.select(1);
      //Set a key.
      jedis.set(key, value);
      System.out.println("Set Key " + key + " Value: " + value);
      //Get the key.
      String getvalue = jedis.get(key);
      System.out.println("Get Key " + key + " ReturnValue: " + getvalue);
      jedis.quit();
      jedis.close();
      } catch (Exception e) {
           e.printStackTrace();
      }
      }
      }

   2. Run the project. If the following result is output on the Eclipse console, you have successfully connected to ApsaraDB for Redis.

      Set Key redis Value aliyun-redis
      Get Key redis ReturnValue aliyun-redis

      Then you can use your local Jedis client to operate your ApsaraDB for Redis instance. You can also connect to your ApsaraDB for Redis instance through JedisPool.

3. Example of JedisPool connection

   1. Open the Eclipse client, create a project, and configure the pom file as follows:

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

   2. Add the following application to the project:

      import org.apache.commons.pool2.PooledObject;
      import org.apache.commons.pool2.PooledObjectFactory;
      import org.apache.commons.pool2.impl.DefaultPooledObject;
      import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
      import redis.clients.jedis.HostAndPort;
      import redis.clients.jedis.Jedis;
      import redis.clients.jedis.JedisPool;
      import redis.clients.jedis.JedisPoolConfig;

   3. If your Jedis client version is Jedis-2.7.2, enter the following code in the project:

      JedisPoolConfig config = new JedisPoolConfig();
      //Maximum idle connections, which are evaluated by the application. Do not set it to a value greater than the maximum connections of an ApsaraDB for Redis instance.
      config.setMaxIdle(200);
      //Maximum connections, which are evaluated by the application. Do not set it to a value greater than the maximum connections of an ApsaraDB for Redis instance.
      config.setMaxTotal(300);
      config.setTestOnBorrow(false);
      config.setTestOnReturn(false);
      String host = "*.aliyuncs.com";
      String password = "password";
      JedisPool pool = new JedisPool(config, host, 6379, 3000, password);
      Jedis jedis = null;
      try {
           jedis = pool.getResource();
           /// ... do stuff here ... for example
           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);
      } finally {
           if (jedis != null) {
           jedis.close();
      }
      }
      /// ... when closing your application:
      pool.destroy();

   4. If your Jedis client version is Jedis-2.6 or Jedis-2.5, enter the following code in the project:

      JedisPoolConfig config = new JedisPoolConfig();
      //Maximum idle connections, which are evaluated by the application. Do not set it to a value greater than the maximum connections of an ApsaraDB for Redis instance.
      config.setMaxIdle(200);
      //Maximum connections, which are evaluated by the application. Do not set it to a value greater than the maximum connections of an ApsaraDB for Redis instance.
      config.setMaxTotal(300);
      config.setTestOnBorrow(false);
      config.setTestOnReturn(false);
      String host = "*.aliyuncs.com";
      String password = "password";
      JedisPool pool = new JedisPool(config, host, 6379, 3000, password);
      Jedis jedis = null;
      boolean broken = false;
      try {
           jedis = pool.getResource();
           /// ... do stuff here ... for example
           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);
      }
      }

   5. Run the project. If the following result is output on the Eclipse console, you have successfully connected to ApsaraDB for Redis.

      Set Key redis Value aliyun-redis
      Get Key redis ReturnValue aliyun-redis

      Then you can use your local Jedis client to operate your ApsaraDB for Redis instance.

phpredis client

Procedure

1. Click download address to download and install the phpredis client.

2. In any editor supporting php editing, enter the following code:

    <?php
    /* Replace the following parameter values with the host of the connected instance and the port number. */
    $host = "localhost";
    $port = 6379;
    /* Replace the following parameter values with the instance ID and instance password. */
    $user = "test_username";
    $pwd = "test_password";
    $redis = new Redis();
    if ($redis->connect($host, $port) == false) {
    die($redis->getLastError());
      }
    if ($redis->auth($pwd) == false) {
            die($redis->getLastError());
     }
     /* The database can be operated after authentication. For more information, see https://github.com/phpredis/phpredis. */
    if ($redis->set("foo", "bar") == false) {
            die($redis->getLastError());
    }
    $value = $redis->get("foo");
    echo $value;
    ?>

3. Run the preceding code. Then You can use your local phpredis client to access your ApsaraDB for Redis instance. For more information, see https://github.com/phpredis/phpredis.

redis-py client

Procedure

1. Click download address to download and install the redis-py client.

2. In any editor supporting Python editing, enter the following code. Then you can use a local redis-py client to connect to and operate the database.

#!/usr/bin/env python
#-*- coding: utf-8 -*-
import redis
#Replace the following parameter values with the host of the connected instance and the port number.
host = 'localhost'
port = 6379
#Replace the following parameter values with the instance password. 
pwd = 'test_password'
r = redis.StrictRedis(host=host, port=port, password=pwd)
#The database can be operated after a connection is created. For more information, see https://github.com/andymccurdy/redis-py.
r.set('foo', 'bar');
print r.get('foo')

C/C++ client

Procedure

1. Download, compile, and install the C client. The code for compiling and installation is as follows:

    git clone https://github.com/redis/hiredis.git
        cd hiredis
        make 
        sudo make install

2. Enter the following code in the C/C++ editor:

    #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 xxx.kvstore.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;
        }

3. Compile the preceding code.

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

4. Perform the test run.

    example xxx.kvstore.aliyuncs.com 6379 instance_id password

So far, the C/C++ client can connect to ApsaraDB for Redis.

.net client

Procedure

1. Download and use the .net client.

    git clone https://github.com/ServiceStack/ServiceStack.Redis

2. Create a .net project in the .net client.

3. Add the reference file stored in the library file directory ServiceStack.Redis/lib/tests to the client.

4. Enter the following code in the created .net project to connect to ApsaraDB for Redis. For more information about port use, see https://github.com/ServiceStack/ServiceStack.Redis.

   using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
    using ServiceStack.Redis;
    namespace ServiceStack.Redis.Tests
    {
    class Program
    {
            public static void RedisClientTest()
            {
            string host = "127.0.0.1";/*IP address of the access host*/
            string password = "password";/*Password*/
            RedisClient redisClient = new RedisClient(host, 6379, password);
            string key = "test-aliyun";
            string value = "test-aliyun-value";
            redisClient.Set(key, value);
            string listKey = "test-aliyun-list";
            System.Console.WriteLine("set key " + key + " value " + value);
            string getValue = System.Text.Encoding.Default.GetString(redisClient.Get(key));
            System.Console.WriteLine("get key " + getValue);
            System.Console.Read();
    }
    public static void RedisPoolClientTest()
    {
            string[] testReadWriteHosts = new[] {
            "redis://password@127.0.0.1:6379"/*redis://password@access address:port number*/
    };
    RedisConfig.VerifyMasterConnections = false;//You must set the parameter.
    PooledRedisClientManager redisPoolManager = new PooledRedisClientManager(10/*Number of connection pools*/, 10/*Connection pool timeout time*/, testReadWriteHosts);for (int i = 0; i < 100; i++){
    IRedisClient redisClient = redisPoolManager.GetClient();//Obtain the connection.
    RedisNativeClient redisNativeClient = (RedisNativeClient)redisClient;
    redisNativeClient.Client = null;//ApsaraDB for Redis does not support client setname. Therefore, you must set the client object to null.
    try
    {
            string key = "test-aliyun1111";
            string value = "test-aliyun-value1111";
            redisClient.Set(key, value);
            string listKey = "test-aliyun-list";
            redisClient.AddItemToList(listKey, value);
            System.Console.WriteLine("set key " + key + " value " + value);
            string getValue = redisClient.GetValue(key);
            System.Console.WriteLine("get key " + getValue);
            redisClient.Dispose();//
    }catch (Exception e)
    {
            System.Console.WriteLine(e.Message);
    }
    }
            System.Console.Read();
    }static void Main(string[] args)
    {
            //Single connection mode
            RedisClientTest();
            //Connection pool mode
            RedisPoolClientTest();
        }
    }
    }

node-redis client

Procedure

1. Download and install node-redis.

    npm install hiredis redis

2. Enter and run the following code in the node-redis client to connect to ApsaraDB for Redis.

    var redis = require("redis"),
    client = redis.createClient({detect_buffers: true});
    client.auth("password", redis.print)

3. Use ApsaraDB for Redis.

      // Write data.
    client.set("key", "OK");
    // Obtain data and a string is returned.
    client.get("key", function (err, reply) {
    console.log(reply.toString()); // print `OK`
    });
    // If a buffer is transmitted, a buffer is returned.
    client.get(new Buffer("key"), function (err, reply) {
    console.log(reply.toString()); // print `<Buffer 4f 4b>`
    });
    client.quit();