[大数据]使用java实现redis客户端（简单的jedis）

redis服务器默认使用端口6379与外界进行通信，我们其实可以自己实现一个简单的redis客户端。这里用java来实现一下。
实现一个redis客户端主要实现两个部分就可以

1. socket通信
2. redis通信协议（resp协议）的编码与解码

主要是第二部分resp的实现。这里先简单介绍一下resp。
RESP 协议简介

Redis 的客户端和服务端之间在 TCP 协议的上层采用一种独立名为 RESP(REdis Serialization Protocol) 协议作为进行通讯的标准方式。

Redis 协议在以下几点之间做出了折衷：
简单的实现
快速地被计算机解析
简单得可以能被人工解析
新的统一协议已在Redis 1.2中引入，但是在Redis 2.0中，这就成为了与Redis服务器通讯的标准方式。在这个统一协议里，发送给Redis服务端的所有参数都是二进制安全的。Redis用不同的回复类型回复命令。它可以从服务器发送的第一个字节开始校验回复类型：

单行回复（单行字符串回复），回复的第一个字节将是“+”
错误消息（单行字符串回复的另外展示形式），回复的第一个字节将是“-”
整型回复（正整形数字回复），回复的第一个字节将是“:”
批量回复（多行字符串回复），回复的第一个字节将是“$”
多个批量回复（数组回复），回复的第一个字节将是“*”

这里举个例子，比如命令 set name ldh,实际上是一个数组,用resp编码后结果就是

*3			//3表示数组长度为3
$3			//3表示字符串长度
set
$4
name
$3
ldh

服务端返回的OK实际上是+OK，简单来说我们的encode和decode函数定义如下

//编码，将["set","name","ldh"] -> *3\r\n$3\r\nset\r\n$4\r\nname\r\n$3\r\nldh\r\n
byte[] encode(String[] command){

}

//解码，将*3\r\n$3\r\nset\r\n$4\r\nname\r\n$3\r\nldh\r\n -> ["set","name","ldh"]
String[] decode(byte[] msg){

}

注意，我们这里只是实现客户端的resp编码，因为客户端的所有发送都是数据，客户端不会向服务端发送错误，整形这些消息,首先我们来实现编码（encode）

byte[] encode(String[] commands){
    StringBuilder stringBuilder = new StringBuilder();
    stringBuilder.append("*").append(commands.length).append("\r\n");
    for(String command : commands) {
        stringBuilder.append("$").append(command.length()).append("\r\n");
        stringBuilder.append(command).append("\r\n");
    }
    return stringBuilder.toString().getBytes();
}

然后我们再来写一个简单的socket客户端,并使用我们上边的编码函数进行编码，注意这里在读取的时候，由于java socket的read方法会发生阻塞，所以我们将读操作单独起一个线程进行，全部代码如下

public class test {

    public static void main(String[] args) {
        try {
            Scanner in = new Scanner(System.in);
            Socket socket = new Socket("127.0.0.1", 6379);
            OutputStream outputStream = socket.getOutputStream();
            InputStream inputStream = socket.getInputStream();
            BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));

            while(in.hasNext()) {
                String str = in.nextLine();
                String[] command = str.split(" ");
                outputStream.write(
                        encode(command)
                );
                outputStream.flush();

                new Thread(new read(bufferedReader)).start();

            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    static byte[] encode(String[] commands){
        StringBuilder stringBuilder = new StringBuilder();
        stringBuilder.append("*").append(commands.length).append("\r\n");
        for(String command : commands) {
            stringBuilder.append("$").append(command.length()).append("\r\n");
            stringBuilder.append(command).append("\r\n");
        }
        System.out.println(stringBuilder);
        return stringBuilder.toString().getBytes();
    }
}

class read implements Runnable{

    BufferedReader bufferedReader;

    read(BufferedReader bufferedReader){
        this.bufferedReader = bufferedReader;
    }

    @SneakyThrows
    @Override
    public void run() {
        String info;
        while((info = bufferedReader.readLine())!=null){
            System.out.println(info);
        }
    }

之后我们启动redis服务器，填入redis服务器的ip和port，运行我们的函数，这里我填入set name ldh这个命令。之后get name