摘要：為了方便使用，官網(wǎng)推薦了針對(duì)各種編程語(yǔ)言的多種客戶端，支持等主流編程語(yǔ)言。協(xié)議被稱為，客戶端通過(guò)協(xié)議連接到客戶端的端口默認(rèn)端口。協(xié)議是在中引入的，不過(guò)現(xiàn)在已經(jīng)是中的標(biāo)準(zhǔn)協(xié)議了。所以你應(yīng)該再客戶端中實(shí)現(xiàn)這個(gè)協(xié)議。

Redis是開(kāi)源的、基于內(nèi)存的數(shù)據(jù)結(jié)構(gòu)存儲(chǔ)系統(tǒng)，可用作數(shù)據(jù)庫(kù)、緩存以及消息代理方面。Redis支持許多種數(shù)據(jù)結(jié)構(gòu)，并內(nèi)置了豐富的諸如冗余、腳本、事務(wù)、持久化等功能，深受業(yè)界喜愛(ài)，被各種業(yè)務(wù)系統(tǒng)廣泛使用。為了方便使用，Redis官網(wǎng)推薦了針對(duì)各種編程語(yǔ)言的多種客戶端，支持java、c#、python、c++等主流編程語(yǔ)言。那么大家會(huì)問(wèn)，既然Redis客戶端已經(jīng)這么豐富了，為什么還要嘗試自己編寫客戶端？我的看法是，知己知彼，自己嘗試制作Redis客戶端，不僅可以加深對(duì)Redis的了解，而且可以通曉Redis客戶端的原理，為今后的更好地使用、乃至定制改造Redis作好充分準(zhǔn)備。

要想親自開(kāi)發(fā)Redis客戶端，需要以下知識(shí)：
1、網(wǎng)絡(luò)編程基礎(chǔ)
2、熟悉Redis協(xié)議
3、了解Redis的基本操作
另外文中的例子將會(huì)采用java編寫，因此最好有基本的java編程知識(shí)。

本文面向Redis各層次使用者。

Redis協(xié)議被稱為：RESP (REdis Serialization Protocol)，客戶端通過(guò)TCP協(xié)議連接到客戶端的6379端口（默認(rèn)端口）。
RESP協(xié)議是在Redis1.2中引入的，不過(guò)現(xiàn)在已經(jīng)是Redis2.0中的標(biāo)準(zhǔn)協(xié)議了。所以你應(yīng)該再Redis客戶端中實(shí)現(xiàn)這個(gè)協(xié)議。

RESP其實(shí)是一個(gè)序列化協(xié)議，支持簡(jiǎn)單字符串、錯(cuò)誤、整數(shù)、整塊字符串和數(shù)組。數(shù)據(jù)類型依賴頭文字，分別表示如下：
簡(jiǎn)單字符串的頭文字是“+”
錯(cuò)誤的頭文字是“-”
整數(shù)的頭文字是“:”
整塊字符串的頭文字是“$”
數(shù)組的頭文字是“*”

客戶端向Redis服務(wù)器發(fā)送命令，以RESP整塊字符串?dāng)?shù)組的形式。

服務(wù)器端根據(jù)命令的結(jié)果，選擇適宜的一種RESP類型返回

簡(jiǎn)單字符串是以半角加號(hào)開(kāi)頭，后跟隨著不含回車換行的字符串，然后以回車換行結(jié)尾。
舉例如下：+OK
簡(jiǎn)單字符串是非二進(jìn)制安全的，如果需要二進(jìn)制安全，可使用“整塊字符串”。

錯(cuò)誤和簡(jiǎn)單字符串類似，但頭文字換成半角減號(hào)了。后面跟隨的文字，可以視為錯(cuò)誤消息內(nèi)容。
舉例如下：
-ERR unknown command "foobar"
-WRONGTYPE Operation against a key holding the wrong kind of value

整數(shù)與簡(jiǎn)單字符串類似，頭文字為半角冒號(hào)。
舉例如下：
:0
:1000

整塊字符串可以用來(lái)標(biāo)示二進(jìn)制安全的、最大512MB長(zhǎng)度的字符串。它以$符號(hào)開(kāi)頭，后跟隨實(shí)際字符串長(zhǎng)度，以回車換行結(jié)尾，后跟隨實(shí)際字符串，再最終以回車換行結(jié)尾。
舉例如下：
$6 foobar
空字符串表現(xiàn)形式如下：$0
nil表現(xiàn)形式如下：$-1

數(shù)組以半角星號(hào)開(kāi)頭，后接數(shù)組中元素個(gè)數(shù)，然后以回車換行結(jié)尾，然后后接各個(gè)元素。
舉例如下：
空數(shù)組：*0
包含兩個(gè)整塊字符串的數(shù)組：*2 $3 foo $3 bar
包含三個(gè)整數(shù)的數(shù)組：*3 :1 :2 :3
數(shù)組還支持嵌套。

要實(shí)現(xiàn)和Redis服務(wù)端通信，首先需要與Redis服務(wù)端建立TCP通信連接，然后使用上述的RESP協(xié)議，將想要執(zhí)行的Redis命令發(fā)送至服務(wù)端，并等待服務(wù)端響應(yīng)，然后接收到響應(yīng)結(jié)果，展示給用戶。

以下代碼實(shí)現(xiàn)了一個(gè)簡(jiǎn)單的獲取info的操作。

package my_redis_client;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.nio.CharBuffer;

/**
 * Hello world!
 *
 */
public class App 
{
    public static void main( String[] args )
    {
        //定義redis服務(wù)端默認(rèn)端口
        int port = 6379;

        Socket socket = null;
        BufferedReader in = null;
        PrintWriter out = null;
        
        try {
            //創(chuàng)建tcp連接
            socket = new Socket("localhost", port);
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            out = new PrintWriter(socket.getOutputStream(), true);
            
            //傳送info命令
            //客戶端向Redis服務(wù)器發(fā)送命令，以RESP整塊字符串?dāng)?shù)組的形式
            out.println("*1
$4
info
");
            System.out.println("Redis command wat sent successfully.");
            
            //接收服務(wù)器的回復(fù)
            CharBuffer response = CharBuffer.allocate(1024);
            int readedLen = in.read(response);
            String responseBody = response.flip().toString();
            
            //輸出服務(wù)器的回復(fù)
            System.out.println(responseBody);
            
        }
        catch(Exception e) {
            e.printStackTrace();
        }
        finally {
            //最后關(guān)閉相關(guān)的流
            if (out != null){
                out.close();
                out = null;
            }
            
            if (in != null) {
                try {
                    in.close();
                }
                catch(IOException e){
                    e.printStackTrace();
                }
                
                in = null;
            }
            
            if (socket != null) {
                try {
                    socket.close();
                }
                catch(IOException e){
                    e.printStackTrace();
                }
                
                socket = null;
            }
        }
    }
}

運(yùn)行后，系統(tǒng)將會(huì)在命令行界面輸出info的執(zhí)行結(jié)果。

根據(jù)上述代碼所描述的方法，就可以繼續(xù)擴(kuò)展客戶端的功能，實(shí)現(xiàn)Redis各種命令了。

https://github.com/yourcaptai...

  net.yesdata
  dudu-RESP-interpreter
  1.0.4

https://oss.sonatype.org