Redis protocol in Vertx

• Server:

package com.dangchienhsgs.redis.server;

import io.vertx.core.DeploymentOptions;
import io.vertx.core.Vertx;
import io.vertx.core.net.NetSocket;
import redis.reply.*;

/**
 * Created by Nguyen Dang Chien on 7/28/16.
 */
public class SimpleRedisServer extends AbstractRedisServer {
    private static int NUMBER_SERVER_INSTANCES = 100;

    @Override
    public String getHost() {
        return "127.0.0.1";
    }

    @Override
    public int getPort() {
        return 1234;
    }

    @Override
    public void handleMultiBulkReply(NetSocket socket, MultiBulkReply reply) {
        // do sth
    }

    @Override
    public void handleBulkReply(NetSocket socket, BulkReply reply) {
        // do sth
    }

    @Override
    public void handleIntegerReply(NetSocket socket, IntegerReply reply) {
        // do sth
    }

    @Override
    public void handleStatusReply(NetSocket socket, StatusReply reply) {
        // do sth
    }

    @Override
    public void handleErrorReply(NetSocket socket, ErrorReply reply) {
        // do sth
    }
}

Deploy server with load balancing to use multicore :)

    public static void main(String[] args) {
        Vertx vertx = Vertx.vertx();
        DeploymentOptions options = new DeploymentOptions().setInstances(NUMBER_SERVER_INSTANCES);
        vertx.deployVerticle(SimpleRedisServer.class.getCanonicalName(), options);
    }

• Client: Please use any redis client like Jedis to send message to server :)

Example:

public class TestJedisCompability {

    @Test
    public void testJedis() throws Exception {
        Jedis jedis = new Jedis("127.0.0.1", 1234);

        Stopwatch stopwatch = Stopwatch.createUnstarted();

        stopwatch.start();
        for (int i = 0; i < 100000; i++) {
            List<String> list = jedis.hmget("mykey", "myvalue");
            System.out.println(list);
        }
        stopwatch.stop();

        System.out.println(stopwatch.elapsed(TimeUnit.MILLISECONDS));
    }

    @Test
    public void testMultiBulk() {
        BulkReply reply1 = new BulkReply("abc".getBytes());
        BulkReply reply2 = new BulkReply("xyz".getBytes());

        MultiBulkReply multiBulkReply = new MultiBulkReply(new BulkReply[]{reply1, reply2});

        Buffer buffer = Buffer.buffer();

        buffer.appendByte((byte) '*');
        System.out.println(buffer);
    }
}