Go語言開發(fā)redis封裝及簡單使用詳解

更新時間：2021年11月16日 11:54:28 作者：秋天的春

這篇文章主要為大家介紹了Go語言開發(fā)redis的封裝及簡單使用示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步早日升職加薪

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
}