Golang redis(五)redigo pipline管道

缺乏、安全感 2021-12-09 22:37 493阅读 0赞

redis管道可以用来一次性执行多个命令， 可以节省网络带宽，同时对于应用的性能也有一定的提升

#### pipline 管道 ####

redigo支持管道： 使用Send, Flush and Receive 三个函数

`Send(commandName string, args ...interface{}) error`  
`Flush() error`  
`Receive() (reply interface{}, err error)`

send将命令发送到缓冲区中

flush刷新缓冲区，将命令发送到redis服务器

receive负责处理接收到的消息内容， 注意：receive一次只从结果中拿出一个send的命令进行处理

例如

c.Send("SET", "foo", "bar")
    c.Send("GET", "foo")
    c.Flush()
    c.Receive() // reply from SET
    v, err = c.Receive() // reply from GET

示例：

package main
    
    import (
       "fmt"
       "github.com/gomodule/redigo/redis"
       "log"
    )
    
    func echoReceive(res interface{}, err error){
       if err != nil{
          fmt.Println(err)
       }else {
          if res != nil{
             fmt.Printf("---------  ")
             fmt.Println(string(res.([]byte)))
          }else {
             fmt.Println(res)
          }
    
       }
    }
    
    func main() {
       c1, err := redis.Dial("tcp", "127.0.0.1:6379")
       if err != nil {
          log.Fatalln(err)
       }
       defer c1.Close()
    
       c1.Send("Get", "my_test")
       c1.Flush()
       echoReceive(c1.Receive())
    
       c1.Send("Get", "my_test2")
       c1.Flush()
       echoReceive(c1.Receive())
    
       c1.Send("Get", "my_test")
       c1.Send("Get", "my_test2")
       c1.Send("Get", "my_test3")
       c1.Flush()
       echoReceive(c1.Receive())
       echoReceive(c1.Receive())
       echoReceive(c1.Receive())
    }

输出结果：

---------  this is test
    <nil>
    ---------  this is test
    <nil>
    ---------  this is test3

另外也提供了Do方法

Do方法结合了Send，Flush和Receive方法的功能。Do方法首先写入命令并刷新输出缓冲区。接下来，Do方法接收所有待处理的回复，包括刚刚发送的命令的回复。如果收到的任何回复都是错误，则Do返回错误。如果没有错误，则Do返回最后一个回复。如果Do方法的命令参数为“”，则Do方法将刷新输出缓冲区并接收挂起的回复而不发送命令

例如：

c.Send("MULTI")
    c.Send("INCR", "foo")
    c.Send("INCR", "bar")
    r, err := c.Do("EXEC")
    fmt.Println(r) // prints [1, 1]

示例：

package main
    
    import (
       "fmt"
       "github.com/gomodule/redigo/redis"
    )
    
    
    func main() {
       c1, err := redis.Dial("tcp", "127.0.0.1:6379")
       if err != nil {
          log.Fatalln(err)
       }
       defer c1.Close()
    
    	var value1 string
    	var value2 string
    	var value3 string
    
    	c1.Send("MULTI")
    	c1.Send("Get", "my_test")
    	c1.Send("Get", "my_test2")
    	c1.Send("Get", "my_test3")
    	r, err := redis.Values(c1.Do("EXEC"))
    	//fmt.Println(r)
    	if _, err := redis.Scan(r, &value1, &value2, &value3); err == nil {
    		fmt.Println(value1)
    		fmt.Println(value2)
    		fmt.Println(value3)
    	}
    }

输出：

this is test
    
    this is test3