Go语言连接Redis之go-redis使用指南

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Go›Go教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

参考下面的连接：
https://mp.weixin.qq.com/s?__biz=MzU5MjAxMDc1Ng==&mid=2247483899&idx=1&sn=b103ca28fb0674ae87fa073981d6fd08&chksm=fe270a90c950838617959c341581438acbdfb993020d1fc1a0d6baaa1b019058e5c26e976473&mpshare=1&scene=23&srcid=&sharer_sharetime=1588766854496&sharer_shareid=f556102554c3e8d6752418dddc22f428#rd

main.go

package main

import (
	"fmt"
	"haimait/learn/base/redis_dome01/utils"
)



func main(){
	test1()
}

func test1()  {
	utils.RedisSet("age",18,0)
	get, err := utils.RedisGet("age2")
	if err !=nil {
		fmt.Println("err:",err)
		return
	}
	fmt.Println(get)
}

redis_api.go

package utils

import (
	"encoding/json"
	"fmt"
	"strings"
	"time"

	"github.com/ansel1/merry"
	"github.com/astaxie/beego/logs"
	"github.com/go-redis/redis"
)

var RedisClient *redis.Client

func init() {
	NewClient()
}

func NewClient() *redis.Client {
	if RedisClient != nil {
		return RedisClient
	}

	RedisClient = redis.NewClient(&redis.Options{
		Addr: "182.92.234.23:6379",
		Password: "123456", // no password set
		DB:   0, // use default DB
	})

	_, err := RedisClient.Ping().Result()
	if err != nil {
		logs.Error("redis connection failed: ", err.Error())
	}

	return RedisClient
}

func RedisSet(key string, value interface{}, expire int) error {
	if expire > 0 {
		err := RedisClient.Do("SET", key, value, "PX", expire).Err()
		if err != nil {
			logs.Error("RedisSet Error! key:", key, "Details:", err.Error())
			return err
		}
	} else {
		err := RedisClient.Do("SET", key, value).Err()
		if err != nil {
			logs.Error("RedisSet Error! key:", key, "Details:", err.Error())
			return err
		}
	}

	return nil
}
func RedisKeyExists(key string) (bool, error) {
	ok, err := RedisClient.Do("EXISTS", key).Bool()
	return ok, err
}

func RedisGet(key string) (string, error) {
	value, err := RedisClient.Do("GET", key).String()
	if err != nil {
		return "", nil
	}

	return value, nil
}

func RedisGetResult(key string) (interface{}, error) {
	v, err := RedisClient.Do("GET", key).Result()
	if err == redis.Nil {
		return v, nil
	}
	return v, err
}

func RedisGetInt(key string) (int, error) {
	v, err := RedisClient.Do("GET", key).Int()
	if err == redis.Nil {
		return 0, nil
	}
	return v, err
}

func RedisGetInt64(key string) (int64, error) {
	v, err := RedisClient.Do("GET", key).Int64()
	if err == redis.Nil {
		return 0, nil
	}
	return v, err
}

func RedisGetUint64(key string) (uint64, error) {
	v, err := RedisClient.Do("GET", key).Uint64()
	if err == redis.Nil {
		return 0, nil
	}
	return v, err
}

func RedisGetFloat64(key string) (float64, error) {
	v, err := RedisClient.Do("GET", key).Float64()
	if err == redis.Nil {
		return 0.0, nil
	}
	return v, err
}

func RedisExpire(key string, expire int) error {
	err := RedisClient.Do("EXPIRE", key, expire).Err()
	if err != nil {
		logs.Error("RedisExpire Error!", key, "Details:", err.Error())
		return err
	}

	return nil
}

func RedisPTTL(key string) (int, error) {
	ttl, err := RedisClient.Do("PTTL", key).Int()
	if err != nil {
		return -1, err
	}

	return ttl, nil
}

func RedisTTL(key string) (int, error) {
	ttl, err := RedisClient.Do("TTL", key).Int()
	if err != nil {
		return -1, err
	}

	return ttl, nil
}

func RedisSetJson(key string, value interface{}, expire int) error {
	jsonData, _ := json.Marshal(value)
	if expire > 0 {
		err := RedisClient.Do("SET", key, jsonData, "PX", expire).Err()
		if err != nil {
			logs.Error("RedisSetJson Error! key:", key, "Details:", err.Error())
			return err
		}
	} else {
		err := RedisClient.Do("SET", key, jsonData).Err()
		if err != nil {
			logs.Error("RedisSetJson Error! key:", key, "Details:", err.Error())
			return err
		}
	}

	return nil
}

func RedisGetJson(key string) ([]byte, error) {
	value, err := RedisClient.Do("GET", key).String()
	if err != nil {
		return nil, nil
	}

	return []byte(value), nil
}

func RedisDel(key string) error {
	err := RedisClient.Do("DEL", key).Err()
	if err != nil {
		logs.Error("RedisDel Error! key:", key, "Details:", err.Error())
	}
	return err
}

func RedisHGet(key, field string) (string, error) {
	value, err := RedisClient.Do("HGET", key, field).String()
	if err != nil {
		return "", nil
	}

	return value, nil
}

func RedisHSet(key, field, value string) error {
	err := RedisClient.Do("HSET", key, field, value).Err()
	if err != nil {
		logs.Error("RedisHSet Error!", key, "field:", field, "Details:", err.Error())
	}
	return err
}

func RedisHDel(key, field string) error {
	err := RedisClient.Do("HDEL", key, field).Err()
	if err != nil {
		logs.Error("RedisHDel Error!", key, "field:", field, "Details:", err.Error())
	}
	return err
}

func RedisZAdd(key, member, score string) error {
	err := RedisClient.Do("ZADD", key, score, member).Err()
	if err != nil {
		logs.Error("RedisZAdd Error!", key, "member:", member, "score:", score, "Details:", err.Error())
	}
	return err
}

func RedisZRank(key, member string) (int, error) {
	rank, err := RedisClient.Do("ZRANK", key, member).Int()
	if err == redis.Nil {
		return -1, nil
	}

	if err != nil {
		logs.Error("RedisZRank Error!", key, "member:", member, "Details:", err.Error())
		return -1, nil
	}

	return rank, err
}

func RedisZRange(key string, start, stop int) (values []string, err error) {
	values, err = RedisClient.ZRange(key, int64(start), int64(stop)).Result()
	if err != nil {
		logs.Error("RedisZRange Error!", key, "start:", start, "stop:", stop, "Details:", err.Error())
		return
	}

	return
}

func RedisZRangeWithScores(key string, start, stop int) (values []redis.Z, err error) {
	values, err = RedisClient.ZRangeWithScores(key, int64(start), int64(stop)).Result()
	if err != nil {
		logs.Error("RedisZRange Error!", key, "start:", start, "stop:", stop, "Details:", err.Error())
		return
	}

	return
}

func RedisZRem(key, member string) error {
	err := RedisClient.Do("ZREM", key, member).Err()
	if err != nil {
		logs.Error("RedisZRem Error!", key, "member:", member, "Details:", err.Error())
	}
	return err
}

func RedisRPUSH(key string, member string) (err error) {
	err = RedisClient.Do("RPUSH", key, member).Err()
	if err != nil {
		logs.Error("RedisRPUSH Error!", key, member, "Details:", err.Error())
		return
	}

	return
}

func RedisBLPOP(timeout time.Duration, keys ...string) (value []string, err error) {
	value, err = RedisClient.BLPop(timeout, keys...).Result()
	if err == redis.Nil {
		err = nil
		return
	}

	if err != nil {
		logs.Error("BLPop Error!", keys, timeout, "Details:", err.Error())
		return
	}
	return
}

func RedisLLEN(key string) (value int64, err error) {
	value, err = RedisClient.LLen(key).Result()
	if err != nil {
		logs.Error("RedisLLEN Error!", key, "Details:", err.Error())
		return
	}

	return
}

func RedisLRange(key string, start, stop int) (values []string, err error) {
	values, err = RedisClient.LRange(key, int64(start), int64(stop)).Result()
	if err != nil {
		logs.Error("RedisLRange Error!", key, "start:", start, "stop:", stop, "Details:", err.Error())
		return
	}

	return
}

func RedisKeys(pattern string) (keys []string, err error) {
	keys, err = RedisClient.Keys(pattern).Result()
	if err != nil {
		logs.Error("RedisKeys Error!", pattern, "Details:", err.Error())
		return
	}

	return
}

// RedisListAllValuesWithPrefix will take in a key prefix and return the value of all the keys that contain that prefix
func RedisListAllValuesWithPrefix(prefix string) (map[string]string, error) {
	// Grab all the keys with the prefix
	keys, err := getKeys(fmt.Sprintf("%s*", prefix))
	if err != nil {
		return nil, err
	}

	// We will now iterate through all of the values to
	values, err := getKeyAndValuesMap(keys, prefix)

	return values, nil
}

// getKeys will take a certain prefix that the keys share and return a list of all the keys
func getKeys(prefix string) ([]string, error) {
	var allKeys []string
	var cursor uint64
	count := int64(10) // count specifies how many keys should be returned in every Scan call

	for {
		var keys []string
		var err error
		keys, cursor, err = RedisClient.Scan(cursor, prefix, count).Result()
		if err != nil {
			return nil, merry.Appendf(err, "error retrieving '%s' keys", prefix)
		}

		allKeys = append(allKeys, keys...)

		if cursor == 0 {
			break
		}

	}

	return allKeys, nil
}

// getKeyAndValuesMap generates a [string]string map structure that will associate an ID with the token value stored in Redis
func getKeyAndValuesMap(keys []string, prefix string) (map[string]string, error) {
	values := make(map[string]string)
	for _, key := range keys {
		value, err := RedisClient.Do("GET", key).String()
		if err != nil {
			return nil, merry.Appendf(err, "error retrieving value for key %s", key)
		}

		// Strip off the prefix from the key so that we save the key to the user ID
		strippedKey := strings.Split(key, prefix)
		values[strippedKey[1]] = value
	}

	return values, nil
}

func RedisBatchDel(key ...string) error {
	err := RedisClient.Del(key...).Err()
	if err != nil {
		logs.Error("RedisBatchDel Error! key:", key, "Details:", err.Error())
	}
	return err
}

func RedisMset(pairs ...interface{}) error {
	err := RedisClient.MSet(pairs...).Err()
	if err != nil {
		logs.Error("RedisMset Error! pairs:", pairs, "Details:", err.Error())
	}
	return err
}