Go语言中怎么使用Redis
作者:归人云淡风轻
时间:2023-04-29
浏览:4
Redis Assistant
Redis Assistant 是一款为Redis设计的高效可视化管理与监控工具,提供多种操作模式,高效处理服务器数据。日常使用里的持续防护和信息管理会更突出,适合把安全控制放进长期使用流程中的场景。
¥19
Windows/macOS/Linux
2026-08-22
安装依赖包Go语言中使用第三方库go-redisgo-redis支持连接哨兵及集群模式的Redis。使用以下命令下载并安装:goget-ugithub.com/go-redis/redis/v8连接redis新建go文件,在项目中引入github.com/go-redis/redis/v8,初始化redis.Client,废话不多说,直接上代码。packagemainimport("context""fmt""github.com/go-redis/redis/v8")//定义一个全局变量varredis
本文目录
安装依赖包
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
},
})
作者最新文章
解决win10运行3DMAX自动重启的方法
2026-10-13 17:08
哔哩哔哩投稿封面上传失败怎么解决
2026-10-13 15:55
漫蛙漫画官网免费漫画入口
2026-10-13 13:19
漫蛙漫画app免费下载安装最新版
2026-10-13 13:18
漫蛙漫画官网登录入口
2026-10-13 13:18
热门文章
更多
精品专题
更多
Mac软件
更多
WINDOWS
更多










































