一、概述
redigo是一个redis的go client，官方描述为：Redigo is a Go client for the Redis database.
基本特点：
- 简单的API调用，并支持所有的redis命令。
- 支持管道、事务、订阅以及连接池。
项目首页：https://github.com/garyburd/redigo/
官方文档：https://godoc.org/github.com/garyburd/redigo/redis
安装：go get github.com/garyburd/redigo/redis
二、基本使用方法
2.1 连接和关闭
使用Dail方法来连接服务：
|
1 |
func Dial(network, address string, options ...DialOption) (Conn, error) {} |
network表示网络类型，address是服务地址，options是一些可选的选项，如果连接成功将返回一个redis.Conn对象，在连接使用完毕后，使用Close()关闭。
|
1 2 3 4 5 6 |
coon, err := redis.Dial("tcp", ":6379") if err != nil{ log.Error(err) return } defer coon.Close() |
2.2 执行命令
执行redis命令使用Do()方法：
|
1 |
Do(commandName string, args ...interface{}) (reply interface{}, err error) |
commandName是redis命令，后面接参数，例如执行一个SET命令：
|
1 2 3 4 5 6 |
rs, err := gCoon.Do("SET", "xxx", "hello") if err != nil{ log.Error(err) return } log.Debug(rs) |
要注意的是不能使用类似Do("SET", "xxx hello")的命令，因为系统会把这个命令解析成set一个名为xxx hello的键，它的值为空。
运行后将返回一个reply对象和错误标志err，如果err != nil则reply中保存redis服务的响应。reply是一个接口对象，根据命令的不同返回的形式也不同，它将会根据值的类型做如下转换：
|
1 2 3 4 5 6 |
Redis type Go type error redis.Error //错误类型 integer int64 // 整形 simple string string //简单的字符串将会转成string类型，如OK等 bulk string []byte or nil if value not present. //[]byte，一般是数据返回 array []interface{} or nil if value not present. // 数组 |
在获取到返回值后可以使用断言来转换数据类型，或者使用库中自带的Reply Helpers进行转换。
2.3 Reply Helpers
Reply Helpers是库里提供的类型转换功能，可以把replay从interface{}转换成我们想要的类型，包里提供了很多类型转换函数，如：
|
1 |
func Strings(reply interface{}, err error) ([]string, error) |
可以把Do函数返回的数据类型转换成[]string类型，相同的函数还有Float64，Int64等等。
|
1 2 3 4 5 6 |
rs, err := redis.Strings(gCoon.Do("keys", "*")) if err != nil{ log.Error(err) return } log.Debug(rs) |
2.4 管道
管道的使用方法设计到三个函数：
|
1 2 3 |
c.Send() c.Flush() c.Receive() |
send()方法把命令写到输出缓冲区，Flush()把缓冲区的命令刷新到redis服务器，Receive()函数接收redis给予的响应，三个操作共同完成一套命令流程：
|
1 2 3 4 5 |
c.Send("SET", "foo", "bar") c.Send("GET", "foo") c.Flush() c.Receive() // reply from SET v, err = c.Receive() // reply from GET |
合并这三个操作就成了Do()函数，官方对Do()的描述为：
|
1 |
The Do method combines the functionality of the Send, Flush and Receive methods. The Do method starts by writing the command and flushing the output buffer. Next, the Do method receives all pending replies including the reply for the command just sent by Do. If any of the received replies is an error, then Do returns the error. If there are no errors, then Do returns the last reply. If the command argument to the Do method is "", then the Do method will flush the output buffer and receive pending replies without sending a command. |
三、操作示例
|
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 |
package main import ( "github.com/garyburd/redigo/redis" "fmt" ) var gCoon redis.Conn func main(){ var err error //连接redis gCoon, err = redis.Dial("tcp", ":6379") if err != nil{ fmt.Println(err) return } defer gCoon.Close() SetAndGet() Keys() } func Keys(){ //使用Reply Helper转换类型 rs, err := redis.Strings(gCoon.Do("keys", "*")) if err != nil{ fmt.Println(err) // [xxx] return } fmt.Println(rs) } func SetAndGet(){ //设置键值 rs, err := gCoon.Do("SET", "xxx", "hello") if err != nil{ fmt.Println(err) return } fmt.Println(rs) // OK //获取键值 rs, err = gCoon.Do("GET", "xxx") if err != nil{ fmt.Println(err) return } fmt.Println(rs) //[104 101 108 108 111] 获取到的是[]byte类型 } |
评论