Goframe框架对redis的支持

2022-07-16  本文已影响0人  小陈工

一、Redis-配置管理

配置文件(推荐)

绝大部分情况下推荐使用g.Redis单例方式来操作redis。因此同样推荐使用配置文件来管理Redis配置,在config.yaml中的配置示例如下:

单实例配置

# Redis 配置示例redis:

# 单实例配置示例1

default:

address:127.0.0.1:6379

db:1

# 单实例配置示例2

cache:

address:127.0.0.1:6379

db:1

pass:123456

idleTimeout:600

集群化配置

# Redis 配置示例redis:

# 集群模式配置方法

group:

address:127.0.0.1:6379,127.0.0.1:6370

db:1

配置项说明

配置项名称是否必须默认值说明

address是-格式:地址:端口

支持Redis单实例模式和集群模式配置,使用,分割多个地址。例如:

192.168.1.1:6379, 192.168.1.2:6379

db否0数据库索引

pass否-访问授权密码

minIdle否0允许闲置的最小连接数

maxIdle否10允许闲置的最大连接数(0表示不限制)

maxActive否100最大连接数量限制(0表示不限制)

idleTimeout否10连接最大空闲时间,使用时间字符串例如30s/1m/1d

maxConnLifetime否30连接最长存活时间,使用时间字符串例如30s/1m/1d

waitTimeout否0等待连接池连接的超时时间,使用时间字符串例如30s/1m/1d

dialTimeout否0TCP连接的超时时间,使用时间字符串例如30s/1m/1d

readTimeout否0TCP的Read操作超时时间,使用时间字符串例如30s/1m/1d

writeTimeout否0TCP的Write操作超时时间,使用时间字符串例如30s/1m/1d

masterName否-哨兵模式下使用, 设置MasterName

tls否false是否使用TLS认证

tlsSkipVerify否false通过TLS连接时,是否禁用服务器名称验证

二、Redis-基本使用

Do方法

我们最常用的是Do方法,执行同步指令,通过向Redis Server发送对应的Redis API命令,来使用Redis Server的服务。Do方法最大的特点是内部自行从连接池中获取连接对象,使用完毕后自动丢回连接池中,开发者无需手动调用Close方法,方便使用。

基本使用

funcmain(){

var(

ctx=gctx.New()

)

v,_:=g.Redis().Do(ctx,"SET","k","v")

fmt.Println(v.String())}

HSET/HGETALL操作

funcmain(){

var(

errerror

result*gvar.Var

key="user"

ctx=gctx.New()

)

_,err=g.Redis().Do(ctx,"HSET",key,"id",10000)

iferr!=nil{

panic(err)

}

_,err=g.Redis().Do(ctx,"HSET",key,"name","john")

iferr!=nil{

panic(err)

}

result,err=g.Redis().Do(ctx,"HGETALL",key)

iferr!=nil{

panic(err)

}

fmt.Println(result.Map())

}

HMSET/HMGET操作

我们可以通过map参数执行HMSET操作。

funcmain(){

var(

ctx=gctx.New()

key="user_100"

data=g.Map{

"name":"gf",

"sex":0,

"score":100,

}

)

_,err:=g.Redis().Do(ctx,"HMSET",append(g.Slice{key},gutil.MapToSlice(data)...)...)

iferr!=nil{

g.Log().Fatal(ctx,err)

}

v,err:=g.Redis().Do(ctx,"HMGET",key,"name")

iferr!=nil{

g.Log().Fatal(ctx,err)

}

fmt.Println(v.Slice())

}

我们可以通过 struct 参数执行HMSET操作。

自动序列化/反序列化

当给定的参数为map, slice, struct时,gredis内部支持自动对其使用json序列化,并且读取数据时可使用gvar.Var的转换功能实现反序列化。

三、Redis-Conn对象

使用Do方法已经能够满足绝大部分的场景需要,如果需要更复杂的Redis操作(例如订阅发布),那么我们可以使用Conn方法从连接池中获取一个连接对象,随后使用该连接对象进行操作。但需要注意的是,该连接对象不再使用时,应当显式调用Close方法进行关闭(丢回连接池)。

基本使用

funcmain(){

var(

ctx=gctx.New()

)

conn,_:=g.Redis().Conn(ctx)

deferconn.Close(ctx)

conn.Do(ctx,"SET","k","v")

v,_:=conn.Do(ctx,"GET","k")

fmt.Println(gconv.String(v))}

订阅/发布

我们可以通过Redis的SUBSCRIBE/PUBLISH命令实现订阅/发布模式。

四、Redis-结果处理

可以看到通过客户端方法Do/Receive获取可供方便转换的gvar.Var通用变量结果。通过gvar.Var的强大转换功能可以转换为任意的数据类型,如基本数据类型Int,String,Strings,或者结构体Struct等等。

Do示例

funcmain(){

var(

ctx=gctx.New()

)

conn,_:=g.Redis().Conn(ctx)

deferconn.Close(ctx)

conn.Do(ctx,"SET","k","v")

v,_:=conn.Do(ctx,"GET","k")

fmt.Println(v.String())}

HashSet示例

HashSet是我们比较常用的Redis数据结构,我们可以非常方便地将Redis中的HashSet获取并转换为Golang Map。

funcmain(){

var(

ctx=gctx.New()

errerror

result*gvar.Var

key="user"

)

_,err=g.Redis().Do(ctx,"HSET",key,"id",10000)

iferr!=nil{

panic(err)

}

_,err=g.Redis().Do(ctx,"HSET",key,"name","john")

iferr!=nil{

panic(err)

}

result,err=g.Redis().Do(ctx,"HGETALL",key)

iferr!=nil{

panic(err)

}

        fmt.Println(result.Map())

}

上一篇下一篇

猜你喜欢

热点阅读