Fork me on GitHub
随笔 - 215  文章 - 13  trackbacks - 0
<2016年9月>
28293031123
45678910
11121314151617
18192021222324
2526272829301
2345678


专注即时通讯及网游服务端编程
------------------------------------
Openresty 官方模块
Openresty 标准模块(Opm)
Openresty 三方模块
------------------------------------
本博收藏大部分文章为转载,并在文章开头给出了原文出处,如有再转,敬请保留相关信息,这是大家对原创作者劳动成果的自觉尊重!!如为您带来不便,请于本博下留言,谢谢配合。

常用链接

留言簿(1)

随笔分类

随笔档案

相册

Awesome

Blog

Book

GitHub

Link

搜索

  •  

积分与排名

  • 积分 - 203795
  • 排名 - 127

最新评论

阅读排行榜


http://www.cnblogs.com/wolfred7464/p/4670864.html

redis的client有好多好多,go语言的client在redis官方有两个推荐,radix和redigo。选择哪一个好呢?确实很纠结,后来掷硬币决定选择redigo了。

redis、go、redigo的安装就不需要提了,不能强行增加篇幅。

redigo使用起来很人性化,api设计的符合直觉,我对redis了解较少,使用过程中基本没有遇到障碍。

redigo的使用入门可以去查godoc:http://godoc.org/github.com/garyburd/redigo/redis

接下来就是毫无技术含量的贴代码了:

连接redis我一般是这样写的:

c, err := redis.Dial("tcp", "127.0.0.1:6379")
if err != nil {
    fmt.Println(err)
    return
}
defer c.Close()

执行命令使用Do函数,跟在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循环遍历,也可以使用redis.Scan函数:

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()

发布订阅:

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 思月行云 阅读(2941) 评论(0)  编辑 收藏 引用 所属分类: GolangRedis\Mongo

只有注册用户登录后才能发表评论。
网站导航: 博客园   IT新闻   BlogJava   知识库   博问   管理