这篇文章主要为大家展示了“如何使用go net实现简单的redis通信协议”,内容简而易懂,条理清晰,希望能够帮助大家解决疑惑,下面让小编带领大家一起研究并学习一下“如何使用go net实现简单的redis通信协议”这篇文章吧。
图解redis通信协议
请求协议:
请求协议一般格式:
*<参数数量> CR LF$<参数 1 的字节数量> CR LF<参数 1 的数据> CR LF...$<参数 N 的字节数量> CR LF<参数 N 的数据> CR LF
例如,一个登录命令:
*2 2-> 参数数量$4 4-> 字节数量AUTH$13password@2018
返回结果:
+OK
实际上,发送的命令为“*2\r\n$4\r\nAUTH\r\n$13\r\npassword@2018\r\n”
测试代码:
package mainimport ("bufio""fmt""net""strconv""testing""time")type Conn struct {// Sharedconn net.Conn// Readbr *bufio.Reader// Writebw *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通信协议”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注编程网行业资讯频道!