http://www.cnblogs.com/wolfred7464/p/4670864.html
redis的client有好多好多，go語言的client在redis官方有兩個推薦，radix和redigo。選擇哪一個好呢？確實很糾結(jié)，后來擲硬幣決定選擇redigo了。
redis、go、redigo的安裝就不需要提了，不能強(qiáng)行增加篇幅。
redigo使用起來很人性化，api設(shè)計的符合直覺，我對redis了解較少，使用過程中基本沒有遇到障礙。
redigo的使用入門可以去查godoc：http://godoc.org/github.com/garyburd/redigo/redis
接下來就是毫無技術(shù)含量的貼代碼了：
連接redis我一般是這樣寫的：
c, err := redis.Dial("tcp", "127.0.0.1:6379")
if err != nil {
fmt.Println(err)
return
}
defer c.Close()
執(zhí)行命令使用Do函數(shù)，跟在redis-cli敲命令的感覺差不多的：
v, err := c.Do("SET", "name", "red")
if err != nil {
fmt.Println(err)
return
}
fmt.Println(v)
v, err = redis.String(c.Do("GET", "name"))
if err != nil {
fmt.Println(err)
return
}
fmt.Println(v)
列表也是一樣：
c.Do("lpush", "redlist", "qqq")
c.Do("lpush", "redlist", "www")
c.Do("lpush", "redlist", "eee")
讀取列表可以for循環(huán)遍歷，也可以使用redis.Scan函數(shù)：
values, _ := redis.Values(c.Do("lrange", "redlist", "0", "100"))
for _, v := range values {
fmt.Println(string(v.([]byte)))
}
// 或者
var v1 string
redis.Scan(values, &v1)
fmt.Println(v1)
管道：
c.Send("SET", "name", "red")
c.Send("GET", "name")
c.Flush()
c.Receive()
c.Receive()
發(fā)布訂閱：
func subscribe() {
c, err := redis.Dial("tcp", "127.0.0.1:6379")
if err != nil {
fmt.Println(err)
return
}
defer c.Close()
psc := redis.PubSubConn{c}
psc.Subscribe("redChatRoom")
for {
switch v := psc.Receive().(type) {
case redis.Message:
fmt.Printf("%s: message: %s\n", v.Channel, v.Data)
case redis.Subscription:
fmt.Printf("%s: %s %d\n", v.Channel, v.Kind, v.Count)
case error:
fmt.Println(v)
return
}
}
}
go subscribe()
go subscribe()
go subscribe()
go subscribe()
go subscribe()
c, err := redis.Dial("tcp", "127.0.0.1:6379")
if err != nil {
fmt.Println(err)
return
}
defer c.Close()
for {
var s string
fmt.Scanln(&s)
_, err := c.Do("PUBLISH", "redChatRoom", s)
if err != nil {
fmt.Println("pub err: ", err)
return
}
}
posted on 2016-09-22 15:41
思月行云 閱讀(3032)
評論(0) 編輯 收藏 引用 所屬分類:
Golang 、
Redis\Mongo