一、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())
}