golang使用redis（一）

使用redigo库操作redis

安装

go get github.com/gomodule/redigo/redis

连接

    c, err := redis.Dial("tcp", 
        "172.17.84.205:6379", 
        redis.DialKeepAlive(1*time.Second), 
        redis.DialPassword("123456"), 
        redis.DialConnectTimeout(5*time.Second), 
        redis.DialReadTimeout(1*time.Second), 
        redis.DialWriteTimeout(1*time.Second)) 
 
    if err != nil { 
        fmt.Println("error:", err) 
        return 
    } 
 
    defer c.Close()

set/get key-value

_, err = c.Do("set", "testkey1", "Hello from redis") 
 
r, err := redis.String(c.Do("get", "testkey1"))

如果要设置过期时间

_, err = c.Do("set", "testkey1", "Hello from redis", "EX", "5")

其中"EX", "5"是设置的过期时间5秒

mset/mget 设置获取多个键值

_, err = c.Do("mset", "name", "Michael", "sex", "M", "age", 23, "postcode", 2343253) 
stringValues, err := redis.Strings(c.Do("mget", "name", "sex")) 
intValues, err := redis.Ints(c.Do("mget", "age", "postcode")) 
 
for _, v := range stringValues { 
    fmt.Println(v) 
} 
 
for _, i := range intValues { 
    fmt.Println(i) 
}

HSET key field value

将哈希表 key 中的域 field 的值设为 value

_, err = c.Do("hset", "books", "name", "golang", "author", "Moon", "pages", "4000") 
if err != nil { 
    fmt.Println("err:", err) 
} 
 
v, err := redis.String(c.Do("hget", "books", "name")) 
v, err := redis.String(c.Do("hget", "books", "author"))

HMSET/HGETALL,HMGET

在使用前先说明几个函数

• type Args []interface{}

  从结构化的值构造命令参数

• func (args Args) Add(value ...interface{}) Args

  添加值到Args

• func (args Args) AddFlat(v interface{}) Args

  添加Map, Slice, struct等的值到Args

• func ScanStruct(src []interface{}, dest interface{}) error

  将name和value从src转变成dest

示例代码如下

package main 
 
import ( 
    "fmt" 
    "os" 
    "time" 
 
    redis "github.com/gomodule/redigo/redis" 
) 
 
type Book struct { 
    BookName  string 
    Author    string 
    PageCount string 
    Press     string 
} 
 
func main() { 
    c, err := redis.Dial("tcp", 
        "172.17.84.205:6379", 
        redis.DialKeepAlive(1*time.Second), 
        redis.DialPassword("123456"), 
        redis.DialConnectTimeout(5*time.Second), 
        redis.DialReadTimeout(1*time.Second), 
        redis.DialWriteTimeout(1*time.Second)) 
 
    errCheck(err) 
 
    defer c.Close() 
 
    //Struct 
    top1 := Book{ 
        BookName:  "Crazy golang", 
        Author:    "Moon", 
        PageCount: "600", 
        Press:     "GoodBook", 
    } 
 
    if _, err = c.Do("HMSET", redis.Args{}.Add("Top1").AddFlat(&top1)...); err != nil { 
        fmt.Println(err) 
        return 
    } 
 
    //Map 
    top2 := map[string]string{ 
        "BookName":  "Mast C++", 
        "Author":    "Diablo", 
        "PageCount": "2000", 
        "Press":     "BLZ", 
    } 
 
    if _, err = c.Do("HMSET", redis.Args{}.Add("Top2").AddFlat(top2)...); err != nil { 
        fmt.Println(err) 
        return 
    } 
 
    top3 := []string{"BookName", "Deep learning", 
        "Author", "Barl", 
        "PageCount", "2600", 
        "Publish House", "BLZ"} 
    _, err = c.Do("HMSET", redis.Args{}.Add("Top3").AddFlat(top3)...) 
    errCheck(err) 
 
    topx := Book{} 
 
    for _, item := range []string{"Top1", "Top2", "Top3"} { 
        value, err := redis.Values(c.Do("HGETALL", item)) 
        errCheck(err) 
 
        err = redis.ScanStruct(value, &topx) 
        errCheck(err) 
 
        fmt.Printf("%s[%+v]\n", item, topx) 
    } 
 
    stringsValue, err := redis.Strings(c.Do("HMGET", "Top1", "BookName", "Author")) 
    errCheck(err) 
 
    fmt.Printf("hmget:%+v\n", stringsValue) 
 
} 
 
func errCheck(err error) { 
    if err != nil { 
        fmt.Println(err) 
        os.Exit(-1) 
    } 
}

详细代码：
IT虾米网