simple-redisclient

Redis client using Redis Serialization Protocol

Implements

Refer to Redis Serialization Protocol and jedis:

Server To Client

Protocol Type	First Byte	Example
Simple Strings	`+`	`+OK\r\n`
Errors	`-`	`-ERR unknown command 'hello'`
Integers	`:`	`:2`
Bulk Strings	`$`	`$6\r\nfoobar\r\n`
Arrays	`*`	`*2\r\n$3\r\nfoo\r\n$3\r\nbar\r\n`

// redis.clients.jedis.Protocol#read
public static final byte DOLLAR_BYTE = '$';
public static final byte ASTERISK_BYTE = '*';
public static final byte PLUS_BYTE = '+';
public static final byte MINUS_BYTE = '-';
public static final byte COLON_BYTE = ':';

public static Object read(final RedisInputStream is) {
    return process(is);
}
private static Object process(final RedisInputStream is) {
    final byte b = is.readByte();
    switch (b) {
    case PLUS_BYTE:
      return processStatusCodeReply(is);
    case DOLLAR_BYTE:
      return processBulkReply(is);
    case ASTERISK_BYTE:
      return processMultiBulkReply(is);
    case COLON_BYTE:
      return processInteger(is);
    case MINUS_BYTE:
      processError(is);
      return null;
    default:
      throw new JedisConnectionException("Unknown reply: " + (char) b);
    }
}

Client To Server

Protocol Type	First Byte	Example
Arrays	`*`	`*3\r\n$3\r\nSET\r\n$3\r\nfoo\r\n$3\r\nbar\r\n`

// redis.clients.jedis.Protocol#sendCommand
public static void sendCommand(final RedisOutputStream os, final ProtocolCommand command,
  final byte[]... args) {
    sendCommand(os, command.getRaw(), args);
}

private static void sendCommand(final RedisOutputStream os, final byte[] command,
  final byte[]... args) {
    try {
      os.write(ASTERISK_BYTE);
      os.writeIntCrLf(args.length + 1);
      os.write(DOLLAR_BYTE);
      os.writeIntCrLf(command.length);
      os.write(command);
      os.writeCrLf();
    
      for (final byte[] arg : args) {
        os.write(DOLLAR_BYTE);
        os.writeIntCrLf(arg.length);
        os.write(arg);
        os.writeCrLf();
      }
    } catch (IOException e) {
      throw new JedisConnectionException(e);
    }
}

Installation

<dependency>
  <groupId>com.github.myibu</groupId>
  <artifactId>simple-redisclient</artifactId>
  <version>1.0.3</version>
</dependency>

Examples

RedisClient redisClient = new RedisClient();
List<RedisClient.RedisReply> reply = redisClient.execAndReturnMore("get foo");
System.out.println(reply);

myibu/simple-redisclient

simple-redisclient

Implements

Installation

Examples

Change Notes

1.0.2

1.0.3