（一）.RESP协议解释

  RESP协议在Redis1.2被引入，直到Redis2.0才成为和Redis服务器通信的标准。这个协议需要在你的Redis客户端实现。RESP 是一个支持多种数据类型的序列化协议：简单字符串（Simple Strings）,错误（ Errors）,整型（ Integers）, 大容量字符串（Bulk Strings）和数组（Arrays）。该协议的优点如下：（Reids协议详细规范解释）
1. 实现起来简单。
2. 解析速度快。
3. 有可读性。

（二）.RESP协议规范

  在RESP中，数据的类型依赖于首字节，第一个字符表示数据的类型，紧接着是一个不能包含CR或LF的字符串（不允许换行），最后以"\r\n"(CRLF)表示结束进行分割。

2.1-RESP第一个字节与数据类型的映射关系如下：

类型 响应首字节 备注
单行字符串（Simple Strings） + 第一个字节为+
错误（Errors） - 第一个字节为-
整型（Integers） : 第一个字节为:
多行字符串（Bulk Strings） $ 第一个字节为$
数组（Arrays） * 第一个字节为*

2.2-拆解释义RESP协议：

使用Redis-cli编辑如下指令向Redis服务端发送:

127.0.0.1:6379> set hello world

  对发送的指令分析，实际上Redis-cli会遵循RESP协议对命令进行拆解编译后再发送给Redis服务器端。RESP协议编译如下：

*3
$3
set
$5
hello
$5
world

$3$5$5

视图展示：


2.3-RESP协议验证：

+OK

（三）.Go解析RESP协议实现转发

3.1-开启IP/prot监听：

Redis1Conn, _ = net.Dial("tcp", "192.168.0.107:6379")listen, err := net.Listen("tcp", "0.0.0.0:12345")
// TCP server端
func main() {
    Redis1Conn, _ = net.Dial("tcp", "192.168.0.107:6379")

    listen, err := net.Listen("tcp", "0.0.0.0:12345")
    if err != nil {
        fmt.Println("listen failed, err:", err)
        return
    }
    for {
        conn, err := listen.Accept() // 建立连接
        if err != nil {
            fmt.Println("accept failed, err:", err)
            continue
        }
        go process(conn) // 启动一个goroutine处理连接
    }
}

3.2-处理解析Redis-cli的RESP协议：

  实现思路，RESP协议的指令是以"\r\n"(CRLF)表示结束进行分割，则按照"\r\n"(CRLF)分隔符按行读取TCP流消息。实现函数如下：

func read(reader *bufio.Reader) []byte {
    line, err := reader.ReadBytes('\n')
    if err != nil {
        errors.New("读取行错误")
    }
    return bytes.TrimRight(line, "\r\n")
}

*cmdArrLencmdArrLen$cmdLencmdData
// 处理redis-cli发送的程序
func handlerCliCmd(conn net.Conn) []string {
    var cmd []string
    reader := bufio.NewReader(conn)

    cmdHead := read(reader)

    cmd = append(cmd, string(cmdHead))

    if string(cmdHead[:1]) == "*" {

        cmdArrByteLen := cmdHead[1:] //发送的命令数组长度

        cmdArrLen := BytesToInt(cmdArrByteLen)

        for i := 0; i < cmdArrLen; i++ {
            cmdLen := read(reader)
            cmd = append(cmd, string(cmdLen))
            if string(cmdLen[:1]) == "$" {
                cmdData := read(reader)
                cmd = append(cmd, string(cmdData))
            }
        }
    }
    return cmd
}

3.3-转发Redis-cli客户端的命令：

COMMAND"+OK\r\n"for _, cmds := range cmd {}_, err := Redis1Conn.Write(toRedis)conn.Write(buf[:n2])
// 处理函数
func process(conn net.Conn) {
    defer func() {
        fmt.Println("连接断开了\n")
        conn.Close() // 关闭连接
    }()

    for {

        cmd := handlerCliCmd(conn) //处理命令
    
        if cmd[2] == "COMMAND" {
            conn.Write([]byte("+OK\r\n"))
        } else {
            var toRedis []byte
            for _, cmds := range cmd {
                t := cmds + "\r\n"
                toRedis = append(toRedis, []byte(t)...)
            }
            
            _, err := Redis1Conn.Write(toRedis)
            if err != nil {
                fmt.Println(err)
            }
            
            buf := make([]byte, 1024)
            _, err2 := Redis1Conn.Read(buf[:])

            if err2 != nil {
                fmt.Println(err)
            }

            conn.Write(buf[:n2])
        }
    }
}

3.4-验证程序效果：

redis-cli -h 192.168.0.105 -p 12345*1 $7 COMMANDset test 123*3 $3 set $4 test $3 123+OK