Go redis 客户端源码阅读连接操作

Posted Go语言中文网

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Go redis 客户端源码阅读连接操作相关的知识,希望对你有一定的参考价值。

https://github.com/gomodule/redigo

实现了redis客户端,包括一个连接池和redis pipleline

conn.go

func (c *conn) Do(cmd string, args ...interface{}) (interface{}, error){

if cmd != "" { if err := c.writeCommand(cmd, args); err != nil { return nil, c.fatal(err) } }    if err := c.bw.Flush(); err != nil { return nil, c.fatal(err) }  for i := 0; i <= pending; i++ { var e error if reply, e = c.readReply(); e != nil { return nil, c.fatal(e) } if e, ok := reply.(Error); ok && err == nil { err = e }  }


方法封装了一个请求的3个过程 Send, Flush and Receive

1,send 将请求写到输出缓冲

2, Flush将缓冲区的命令发送到服务端

3,Receive 接收服务端的响应

https://godoc.org/github.com/gomodule/redigo/redis#hdr-Pipelining

// conn is the low-level implementation of Conntype conn struct {
// Shared mu sync.Mutex pending int err error conn net.Conn
// Read readTimeout time.Duration br *bufio.Reader
// Write writeTimeout time.Duration bw *bufio.Writer
// Scratch space for formatting argument length. // '*' or '$', length, "\r\n" lenScratch [32]byte
// Scratch space for formatting integers and floats. numScratch [40]byte}

以上就是连接操作的核心代码


因为redis是文本协议,因此发送时需要按照redis协议序列化,接收的时候按照redis协议反序列化。


客户端发送命令的格式(类型):5种类型

    间隔符号,在Linux下是\r\n,在Windows下是\n

1. 简单字符串 Simple Strings, 以 "+"加号 开头

      格式:+ 字符串 \r\n

               字符串不能包含 CR或者 LF(不允许换行)

      eg: "+OK\r\n"

      注意:为了发送二进制安全的字符串,一般推荐使用后面的 Bulk Strings类型

2. 错误 Errors, 以"-"减号 开头

  格式:- 错误前缀 错误信息 \r\n

               错误信息不能包含 CR或者 LF(不允许换行),Errors与Simple Strings很相似,不同的是Erros会被当作异常来看待

      eg: "-Error unknow command 'foobar'\r\n"

3. 整数型 Integer, 以 ":" 冒号开头

  格式:: 数字 \r\n

      eg: ":1000\r\n"

4. 大字符串类型 Bulk Strings, 以 "$"美元符号开头,长度限制512M

  格式:$ 字符串的长度 \r\n 字符串 \r\n

               字符串不能包含 CR或者 LF(不允许换行);

      eg: "$6\r\nfoobar\r\n"    其中字符串为 foobar,而6就是foobar的字符长度

            "$0\r\n\r\n"       空字符串

            "$-1\r\n"           null

5. 数组类型 Arrays,以 "*"星号开头

  格式:* 数组元素个数 \r\n 其他所有类型 (结尾不需要\r\n)

             注意:只有元素个数后面的\r\n是属于该数组的,结尾的\r\n一般是元素的

      eg: "*0\r\n"      空数组

           "*2\r\n$2\r\nfoo\r\n$3\r\nbar\r\n"      数组包含2个元素,分别是字符串foo和bar

    "*3\r\n:1\r\n:2\r\n:3\r\n"       数组包含3个整数:1、2、3

           "*5\r\n:1\r\n:2\r\n:3\r\n:4\r\n$6\r\nfoobar\r\n"  包含混合类型的数组

           "*-1\r\n"         Null数组

           "*2\r\n*3\r\n:1\r\n:2\r\n:3\r\n*2\r\n+Foo\r\n-Bar\r\n"   数组嵌套,外层数组包含2个数组,整理后如下:

                 "*2\r\n

      *3\r\n:1\r\n:2\r\n:3\r\n

      *2\r\n+Foo\r\n-Bar\r\n"



推荐阅读




喜欢本文的朋友,欢迎关注“Go语言中文网



以上是关于Go redis 客户端源码阅读连接操作的主要内容,如果未能解决你的问题,请参考以下文章

redis-py 源码阅读

Redis源码阅读集群-连接初始化

Redis源码阅读---连接建立

MySQL与Redis数据库连接池介绍(图示+源码+代码演示)

《Redis设计与实现》[第二部分]单机数据库的实现-C源码阅读

redis源码阅读-主从复制增量复制细节