一、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())
}
网友评论