go-redis支持连接哨兵及集群模式的redis。
使用以下命令下载并安装:
go get -u github.com/go-redis/redis/v8
连接redis新建go文件,在项目中引入github.com/go-redis/redis/v8,
初始化redis.client,废话不多说,直接上代码。
package mainimport ( "context" "fmt" "github.com/go-redis/redis/v8")// 定义一个全局变量var redisdb *redis.clientvar 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语言中怎么使用redis的详细内容。
