vlambda博客
学习文章列表

Go语言实现redis的封装及一些使用

最近在学习Golang,所以将学习过程记为笔记,以后翻阅的时候也方便,顺便也给大家做一点分享,希望能坚持下去。



学习与交流:


现在就开始你的Go语言学习之旅吧!人生苦短,let’s Go.




go redis 集合操作--sadd
redis的go语言包,我们使用官方推荐的redigo,https://github.com/garyburd/redigo

安装redigo

$ go get github.com/garyburd/redigo

带密码的redis操作

package main
import (
    "log" 
    "github.com/garyburd/redigo/redis"

func main() {
     server := "127.0.0.1:6379"
     option := redis.DialPassword("123456")
    c, err := redis.Dial("tcp", server, option)
    if err != nil {
        log.Println("connect server failed:", err)
        return
    } 
    defer c.Close() 
    v, err := redis.Int64(c.Do("SADD""myset""10.8.37.98"))
    if err != nil {
        log.Println("SADD failed:", err)
        return
    } 
    log.Println("value:", v)

}

批量添加

package main
import (
    "log"

    "github.com/garyburd/redigo/redis"
)
func main() {
    server := "127.0.0.1:6379"
    option := redis.DialPassword("123456")
    c, err := redis.Dial("tcp", server, option)
    if err != nil {
        log.Println("connect server failed:", err)
        return
    } 
    defer c.Close() 
    setKey := "myset"
    args := []interface{}{setKey}
    args = append(args, "10.1")
    args = append(args, "10.2")
    v, err := redis.Int64(c.Do("SADD", args...))
    if err != nil {
        log.Println("SADD failed:", err)
        return
    } 
    log.Println("value:", v)

}

无密码redis操作

package main
import (
    "fmt"
    "github.com/gomodule/redigo/redis"
)
func main() {
    c, err := redis.Dial("tcp""127.0.0.1:6379")
    if err != nil {
        fmt.Println(err)
        return
    }
    defer c.Close() 
    c.Do("SET""hello""world")
    s, err := redis.String(c.Do("GET""hello"))

redis封装包

package redis
import (
    "autumn/tools/cfg"
    "fmt"
    "github.com/gomodule/redigo/redis"
    "log"

var REDIS redis.Conn
func InitRedis() {
    REDIS = redis_connect("default")
}
func CloseRedis() {
    REDIS.Close()

func redis_connect(project string) redis.Conn {
    server := fmt.Sprintf("%s:%s",
        cfg.Get("redis", project+".host").String(),
        cfg.Get("redis", project+".port").String())
    var err error
    option := redis.DialPassword(cfg.Get("redis", project+".passwd").String())
    c, err := redis.Dial("tcp", server, option)
    if err != nil {
        log.Fatal("[GIN-MYSQL(" + project + ")] connect to redis error:" + err.Error())
    } 
    log.Println("[GIN-Redis(" + project + ")] connected success"
    return c
}



文章链接:https://www.jb51.net/article/229328.htm