一文搞懂Go语言操作Redis的方法

目录

• 前言
• 安装依赖包
• 连接redis
• redis连接池
• 总结

前言

Redis是一个开源的内存数据库，在项目开发中redis的使用也比较频繁，本文介绍了Go语言中go-redis库的基本使用。感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。

安装依赖包

Go语言中使用第三方库go-redis

go-redis支持连接哨兵及集群模式的Redis。

使用以下命令下载并安装:

go get -u github.com/go-redis/redis/v8

连接redis

新建go文件，在项目中引入github.com/go-redis/redis/v8，

初始化redis.Client，废话不多说，直接上代码。

package main

import (
        "context"
        "fmt"
        "github.com/go-redis/redis/v8"
)

// 定义一个全局变量
var redisdb *redis.Client
var ctx = context.Background()

func initRedis()(err error){
        redisdb = redis.NewClient(&redis.Options{
                Addr: "127.0.0.1:6379",  // 指定
                Password: "",
                DB:0,           // redis一共16个库，指定其中一个库即可
        })
        _,err = redisdb.Ping(ctx).Result()
        return
}

func main() {
        err := initRedis()
        if err != nil {
                fmt.Printf("connect redis failed! err : %v\n",err)
                return
        }
        fmt.Println("redis连接成功！")
}

注意： 最新版本的go-redis库的相关命令都需要传递context.Context参数。

redis连接池

通过golang对redis操作，还可以通过redis连接池，流程如下：

（1）事先初始化一定数量的连接，投入到连接池；

（2）当go需要操作redis时，直接从连接池取出连接即可；

（3）这样可以节省临时获取redis的时间，从而提高效率；

go-redis模块自带连接池，所有参数都是可选的，参数配置说明示例如下：

redisdb = redis.NewClient(&redis.Options{
                Addr: "127.0.0.1:6379",  // 指定
                Password: "",
                DB:0,           // redis一共16个库，指定其中一个库即可

                //连接池容量及闲置连接数量
                PoolSize:     15, // 连接池最大socket连接数，默认为4倍CPU数， 4 * runtime.NumCPU
                MinIdleConns: 10, //在启动阶段创建指定数量的Idle连接，并长期维持idle状态的连接数不少于指定数量；。

                //超时
                DialTimeout:  5 * time.Second, //连接建立超时时间，默认5秒。
                ReadTimeout:  3 * time.Second, //读超时，默认3秒， -1表示取消读超时
                WriteTimeout: 3 * time.Second, //写超时，默认等于读超时
                PoolTimeout:  4 * time.Second, //当所有连接都处在繁忙状态时，客户端等待可用连接的最大等待时长，默认为读超时+1秒。

                //闲置连接检查包括IdleTimeout，MaxConnAge
                IdleCheckFrequency: 60 * time.Second, //闲置连接检查的周期，默认为1分钟，-1表示不做周期性检查，只在客户端获取连接时对闲置连接进行处理。
                IdleTimeout:        5 * time.Minute,  //闲置超时，默认5分钟，-1表示取消闲置超时检查
                MaxConnAge:         0 * time.Second,  //连接存活时长，从创建开始计时，超过指定时长则关闭连接，默认为0，即不关闭存活时长较长的连接

                //命令执行失败时的重试策略
                MaxRetries:      0,                      // 命令执行失败时，最多重试多少次，默认为0即不重试
                MinRetryBackoff: 8 * time.Millisecond,   //每次计算重试间隔时间的下限，默认8毫秒，-1表示取消间隔
                MaxRetryBackoff: 512 * time.Millisecond, //每次计算重试间隔时间的上限，默认512毫秒，-1表示取消间隔

                //可自定义连接函数
                Dialer: func(ctx context.Context, network, addr string) (net.Conn, error) {
                        netDialer := &net.Dialer{
                                Timeout:   5 * time.Second,
                                KeepAlive: 5 * time.Minute,
                        }
                        return netDialer.Dial("tcp", "127.0.0.1:6379")
                },

                //钩子函数
                OnConnect: func(ctx context.Context, conn *redis.Conn) error { //仅当客户端执行命令时需要从连接池获取连接时，如果连接池需要新建连接时则会调用此钩子函数
                        fmt.Printf("conn=%v\n", conn)
                        return nil
                },
        })

总结

本文主要为您介绍了，如何使用go的第三方包go-redis连接Redis。

更多详情操作请查看官方文档

原文地址：https://juejin.cn/post/7140125858978758664