圖解redis通信協議
請求協議：
請求協議一般格式：
|
1
2
3
4
5
6
|
*<參數數量> CR LF$<參數 1 的字節數量> CR LF<參數 1 的數據> CR LF...$<參數 N 的字節數量> CR LF<參數 N 的數據> CR LF |
例如，一個登錄命令：
|
1
2
3
4
5
|
*2 2-> 參數數量$4 4-> 字節數量AUTH$13password@2018 |
返回結果：
+OK
實際上，發送的命令為“*2\r\n$4\r\nAUTH\r\n$13\r\npassword@2018\r\n”
測試代碼：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
package mainimport ( "bufio" "fmt" "net" "strconv" "testing" "time")type Conn struct { // Shared conn net.Conn // Read br *bufio.Reader // Write bw *bufio.Writer}func (c *Conn) Write(cmd string, args ...string) error { _, err := c.bw.WriteString("*" + strconv.Itoa(1 + len(args)) + "\r\n") if err != nil { return err } _, err =c.bw.WriteString("$" + strconv.Itoa(len(cmd)) + "\r\n" + cmd + "\r\n") if err != nil { return err } for _, v := range args { _, err :=c.bw.WriteString("$" + strconv.Itoa(len(v)) + "\r\n" + v + "\r\n") if err != nil { return err } } err = c.bw.Flush() if err != nil { return err } return nil}func TestDail(t *testing.T) { conn,err := net.Dial("tcp","127.0.0.1:6379") if err != nil { panic(err) } var c = &Conn{ conn: conn, br : bufio.NewReader(conn), bw: bufio.NewWriter(conn), } err = c.Write("AUTH","password@2018") if err != nil { panic(err) } p, err := c.br.ReadSlice('\n') if err != nil { panic(err) } fmt.Println(string(p)) err = c.Write("SELECT", "5") if err != nil { panic(err) } p, err = c.br.ReadSlice('\n') if err != nil { panic(err) } fmt.Println(string(p)) err = c.Write("keys","*") if err != nil { panic(err) } buffer := make([]byte, 4096) n, err := c.br.Read(buffer) if err != nil { panic(err) } fmt.Println(string(buffer[:n]))} |
運行結果
+OK
+OK
*9
$4
set2
$1
s
$4
set3
$7
string3
$4
int1
$4
test
$7
string2
$7
string1
$7
string4
到此這篇關于使用go net實現簡單的redis通信協議的文章就介紹到這了,更多相關go redis通信協議內容請搜索服務器之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持服務器之家！
原文鏈接：https://blog.csdn.net/luslin1711/article/details/106095061
