golang中使用redis

yandaren · · 2189 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。


golang中比较好用的第三方开源redisclient有:

两个都是非常优秀的redisclient库,也是redis官网上推荐,笔者选择是的是go-redis,因为go-redis封装了redis的大部分命令,不用关心redis的命令的细节,直接调用相应接口就行;redigo是基于命令的,发送一个命令,然后在解析reply;所以相对而言,笔者觉得go-redis接口更友好;

这里也稍微做个广告,如果有朋友是用c++的,可以尝试下笔者开源的一个c++版的redisclient:redis_cpp, 跟go-redis类似,封装了redis大部分的命令,支持redis standalone, sentinel, cluster mode, 接口友好好用

1. go-redis的安装

go get https://github.com/go-redis/redis

2. 测试代码

// redis_test project main.go
package main

import (
    "fmt"
    "time"

    "github.com/go-redis/redis"
)

func err_handler(err error) {
    fmt.Printf("err_handler, error:%s\n", err.Error())
    panic(err.Error())
}

func standalone_single_client_redis_test() {
    fmt.Printf("standalone_single_client_redis_test")

    client := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379",
        Password: "",
        DB:       0,
    })

    defer client.Close()

    pong, err := client.Ping().Result()
    if err != nil {
        fmt.Printf("ping error[%s]\n", err.Error())
        err_handler(err)
    }
    fmt.Printf("ping result: %s\n", pong)

    fmt.Printf("----------------------------------------\n")

    // set / get test
    fmt.Printf("set/get test\n")
    err = client.Set("foo", "bar", 0).Err()
    if err != nil {
        fmt.Printf("try set key[foo] to value[bar] error[%s]\n", err.Error())
        err_handler(err)
    }

    err = client.Set("foo1", "bar1", time.Hour*2).Err()
    if err != nil {
        fmt.Printf("try set key[foo1] to value[bar1] error[%s]\n", err.Error())
        err_handler(err)
    }

    // get value
    value, err := client.Get("foo").Result()
    if err != nil {
        fmt.Printf("try get key[foo] error[%s]\n", err.Error())
        // err_handler(err)
    }

    fmt.Printf("key[foo]'s value is %s\n", value)

    value, err = client.Get("foo1").Result()
    if err != nil {
        fmt.Printf("try get key[foo1] error[%s]\n", err.Error())
        // err_handler(err)
    }

    fmt.Printf("key[foo1]'s value is %s\n", value)

    value, err = client.Get("foo2").Result()
    if err != nil {
        fmt.Printf("try get key[foo2] error[%s]\n", err.Error())
        // err_handler(err)
    }

    fmt.Printf("key[foo2]'s value is %s\n", value)

    // get ttl
    duration, err := client.TTL("foo").Result()
    if err != nil {
        fmt.Printf("try get ttl of key[foo] error[%s]\n", err.Error())
        err_handler(err)
    }

    fmt.Printf("key[foo]' ttl is [%s] %fs\n", duration.String(), duration.Seconds())

    duration, err = client.TTL("foo1").Result()
    if err != nil {
        fmt.Printf("try get ttl of key[foo1] error[%s]\n", err.Error())
        err_handler(err)
    }

    fmt.Printf("key[foo1]' ttl is [%s] %ds\n", duration.String(), int64(duration.Seconds()))

    fmt.Printf("----------------------------------------\n")

    // list test
    fmt.Printf("list test\n")

    err = client.RPush("tqueue", "tmsg1").Err()
    if err != nil {
        fmt.Printf("rpush list[tqueue] error[%s]\n", err.Error())
        err_handler(err)
    }

    list_len, err := client.LLen("tqueue").Result()
    if err != nil {
        fmt.Printf("try get len of list[tqueue] error[%s]\n", err.Error())
        err_handler(err)
    }

    fmt.Printf("len of list[tqueue] is %d\n", list_len)

    result, err := client.BLPop(time.Second*1, "tqueue").Result()
    if err != nil {
        fmt.Printf("blpop list[tqueue] error[%s]\n", err.Error())
        err_handler(err)
    }
    fmt.Printf("blpop list[tqueue], value[%s]\n", result[1])

    fmt.Printf("----------------------------------------\n")

    fmt.Printf("hmap test\n")

    err = client.HSet("tmap", "1", "f1").Err()
    if err != nil {
        fmt.Printf("try hset map[tmap] field[1] error[%s]\n", err.Error())
        err_handler(err)
    }

    err = client.HSet("tmap", "2", "f2").Err()
    if err != nil {
        fmt.Printf("try hset map[tmap] field[2] error[%s]\n", err.Error())
        err_handler(err)
    }

    kv_map := make(map[string]interface{})
    kv_map["3"] = "f3"
    kv_map["4"] = "f4"

    err = client.HMSet("tmap", kv_map).Err()
    if err != nil {
        fmt.Printf("try mset map[tmap] field[3] field[4] error[%s]\n", err.Error())
        err_handler(err)
    }

    map_len, err := client.HLen("tmap").Result()
    if err != nil {
        fmt.Printf("try get len of map[tmap] error[%s]\n", err.Error())
        err_handler(err)
    }
    fmt.Printf("len of map[tmap] is %d\n", map_len)

    // get map value
    value, err = client.HGet("tmap", "1").Result()
    if err != nil {
        fmt.Printf("try get field[1] value of map[tmap] error[%s]\n", err.Error())
        err_handler(err)
    }

    fmt.Printf("field[1] value of map[tmap] is %s\n", value)

    // hgetall
    result_kv, err := client.HGetAll("tmap").Result()
    if err != nil {
        fmt.Printf("try hgetall map[tmap] error[%s]\n", err.Error())
        err_handler(err)
    }

    for k, v := range result_kv {
        fmt.Printf("map[tmap] %s = %s\n", k, v)
    }

    fmt.Printf("----------------------------------------\n")

    fmt.Printf("pubsub test\n")

    pubsub := client.Subscribe("test_channel")

    _, err = pubsub.Receive()
    if err != nil {
        fmt.Printf("try subscribe channel[test_channel] error[%s]\n", err.Error())
        err_handler(err)
    }

    // go channel to used to receive message
    ch := pubsub.Channel()

    // publish a message
    err = client.Publish("test_channel", "hello").Err()
    if err != nil {
        fmt.Printf("try publish message to channel[test_channel] error[%s]\n", err.Error())
        err_handler(err)
    }

    time.AfterFunc(time.Second*2, func() {
        _ = pubsub.Close()
    })

    // consume message
    for {
        msg, ok := <-ch
        if !ok {
            break
        }

        fmt.Printf("recv message[%s] from channel[%s]\n", msg.Payload, msg.Channel)
    }
}

func main() {
    fmt.Println("redis_test!")

    standalone_single_client_redis_test()
}


有疑问加站长微信联系(非本文作者)

本文来自:简书

感谢作者:yandaren

查看原文:golang中使用redis

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

2189 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传