筆記整理自 b站_黑馬程序員Redis入門到實戰(zhàn)教程

創(chuàng)新互聯(lián)主要從事網站設計制作、網站設計、網頁設計、企業(yè)做網站、公司建網站等業(yè)務。立足成都服務萬秀,10年網站建設經驗,價格優(yōu)惠、服務專業(yè),歡迎來電咨詢建站服務:13518219792

Redis 是一個 CS 架構的軟件，通信一般分兩步（不包括 pipeline 和 PubSub）：

• 客戶端（client）向服務端（server）發(fā)送一條命令
• 服務端解析并執(zhí)行命令，返回響應結果給客戶端

因此客戶端發(fā)送命令的格式、服務端響應結果的格式必須有一個規(guī)范，這個規(guī)范就是通信協(xié)議。

而在 Redis 中采用的是 RESP（Redis Serialization Protocol）協(xié)議：

• Redis 1.2 版本引入了 RESP 協(xié)議
• Redis 2.0 版本中成為與 Redis 服務端通信的標準，稱為 RESP2
• Redis 6.0 版本中，從 RESP2 升級到了 RESP3 協(xié)議，增加了更多數據類型并且支持 6.0 的新特性–客戶端緩存

但目前，默認使用的依然是 RESP2 協(xié)議，也是我們要學習的協(xié)議版本（以下簡稱 RESP）。

在 RESP 中，通過首字節(jié)的字符來區(qū)分不同數據類型，常用的數據類型包括 5 種：

• 單行字符串：首字節(jié)是‘+’，后面跟上單行字符串，以 CRLF（"\r\n"）結尾。例如返回"OK"："+OK\r\n"

• 錯誤（Errors）：首字節(jié)是‘-’，與單行字符串格式一樣，只是字符串是異常信息，例如："-Error message\r\n"

• 數值：首字節(jié)是‘:’，后面跟上數字格式的字符串，以 CRLF 結尾。例如：":10\r\n"

• 多行字符串：首字節(jié)是‘$’，表示二進制安全的字符串，大支持 512MB：

  • 如果大小為 0，則代表空字符串："$0\r\n\r\n"
  • 如果大小為 -1，則代表不存在："$-1\r\n"
    

• 數組：首字節(jié)是‘*’，后面跟上數組元素個數，再跟上元素，元素數據類型不限：
  

Redis 支持 TCP 通信，因此我們可以使用 Socket 來模擬客戶端，與 Redis 服務端建立連接：

public class Main {static Socket s;
    static PrintWriter writer;
    static BufferedReader reader;

    public static void main(String[] args) {try {// 1.建立連接
            String host = "192.168.150.101";
            int port = 6379;
            s = new Socket(host, port);
            // 2.獲取輸出流、輸入流
            writer = new PrintWriter(new OutputStreamWriter(s.getOutputStream(), StandardCharsets.UTF_8));
            reader = new BufferedReader(new InputStreamReader(s.getInputStream(), StandardCharsets.UTF_8));

            // 3.發(fā)出請求
            // 3.1.獲取授權 auth 123321
            sendRequest("auth", "123321");
            Object obj = handleResponse();
            System.out.println("obj = " + obj);

            // 3.2.set name 虎哥
            sendRequest("set", "name", "虎哥");
            // 4.解析響應
            obj = handleResponse();
            System.out.println("obj = " + obj);

            // 3.2.set name 虎哥
            sendRequest("get", "name");
            // 4.解析響應
            obj = handleResponse();
            System.out.println("obj = " + obj);

            // 3.2.set name 虎哥
            sendRequest("mget", "name", "num", "msg");
            // 4.解析響應
            obj = handleResponse();
            System.out.println("obj = " + obj);
        } catch (IOException e) {e.printStackTrace();
        } finally {// 5.釋放連接
            try {if (reader != null) reader.close();
            } catch (IOException e) {e.printStackTrace();
            }
            try {if (writer != null) writer.close();
            } catch (IOException e) {e.printStackTrace();
            }
            try {if (s != null) s.close();
            } catch (IOException e) {e.printStackTrace();
            }
        }
    }

    private static Object handleResponse() throws IOException {// 讀取首字節(jié)
        int prefix = reader.read();
        // 判斷數據類型標識
        switch (prefix) {case '+': // 單行字符串，直接讀一行
                return reader.readLine();
            case '-': // 異常，也讀一行
                throw new RuntimeException(reader.readLine());
            case ':': // 數字
                return Long.parseLong(reader.readLine());
            case '$': // 多行字符串
                // 先讀長度
                int len = Integer.parseInt(reader.readLine());
                if (len == -1) {return null;
                }
                if (len == 0) {return "";
                }
                // 再讀數據，讀len個字節(jié)。我們假設沒有特殊字符，所以讀一行（簡化）
                return reader.readLine();
            case '*':
                return readBulkString();
            default:
                throw new RuntimeException("錯誤的數據格式！");
        }
    }

    // 讀數組
    private static Object readBulkString() throws IOException {// 獲取數組大小
        int len = Integer.parseInt(reader.readLine());
        if (len<= 0) {return null;
        }
        // 定義集合，接收多個元素
        List