项目Redis配置
type Config struct {
// Network "tcp"
Network string
// Addr "127.0.0.1:6379"
Addr string
// Password string .If no password then no \'AUTH\'. Default ""
Password string
// If Database is empty "" then no \'SELECT\'. Default ""
Database string
// MaxIdle 0 no limit
MaxIdle int
// MaxActive 0 no limit
MaxActive int
// IdleTimeout time.Duration(5) * time.Minute
IdleTimeout time.Duration
// Prefix "myprefix-for-this-website". Default ""
Prefix string
}
-
Network: 连接类型。TCP
-
Addr: 即将连接的Redis服务主机IP。本实战项目的Redis服务部署在本机,因此主机ip为127.0.0.1。Redis服务默认端口为6379。因此,Addr在本实例项目中的配置值为127.0.0.1:6379。
-
Password: 登陆Redis的密码。默认配置为空。
-
Prefix:为要保存的所有的内容设置公共的前缀。默认设置为空。
-
IdleTimeout:设置Redis中的生效时长。这里我们设置time.Duration(24) * time.Hour。在实际的开发过程中,开发者可以根据自己的需求设定Redis的生效时长。
Redis在配置文件中的配置情况如下:
{
"app_name": "CmsProject",
"port": "8080",
"static_path": "/manage/static",
"database": {
"drive": "mysql",
"port": "3306",
"user": "root",
"pwd": "271400",
"database": "qfCms"
},
"redis": {
"network": "tcp",
"addr": "127.0.0.1",
"port": "6379",
"prefix": ""
},
"mode": "dev"
}
Redis连接对象实例化
我们通过读取配置文件完成配置内容的读取,利用Redis配置信息实例化Redis对象,Redis实例化如下:
var once sync.Once
/**
* 返回Redis实例
*/
func NewRedis() *redis.Database {
var database *redis.Database
once.Do(func() {
//项目配置
cmsConfig := config.InitConfig()
rd := cmsConfig.Redis
database = redis.New(service.Config{
Network: rd.NetWork,
Addr: rd.Addr + ":" + rd.Port,
IdleTimeout: time.Duration(24) * time.Hour,
Prefix: rd.Prefix,
})
})
return database
}
Redis的实例化使用到了单例方式实现。
将Session存储方式设置为Redis
redis := datasource.NewRedis()
//设置session的同步位置为redis
sessManager.UseDatabase(redis)
实战项目中Redis的操作与实现
-
Redis缓存管理员统计功能
adminStatis := sc.Session.Get(ADMINMODULE + date)
if adminStatis != nil {
adminStatis = adminStatis.(int64)
return mvc.Response{
Object: map[string]interface{}{
"status": utils.RECODE_OK,
"count": adminStatis,
},
}
} else {
result = sc.Service.GetAdminDailyCount(date)
sc.Session.Set(ADMINMODULE, result)
} -
Redis缓存订单统计功能
orderStatis := sc.Session.Get(ORDERMODULE + date)
if orderStatis != nil {
orderStatis = orderStatis.(int64)
return mvc.Response{
Object: map[string]interface{}{
"status": utils.RECODE_OK,
"count": orderStatis,
},
}
} else {
result = sc.Service.GetOrderDailyCount(date)
sc.Session.Set(ORDERMODULE+date, result)
}
-
Redis缓存用户统计功能
userResult := sc.Session.Get(USERMODULE + date)
if userResult != nil {
result = userResult.(int64)
return mvc.Response{
Object: map[string]interface{}{
"status": utils.RECODE_OK,
"count": userResult,
},
}
} else {
iris.New().Logger().Error(date) //时间
result = sc.Service.GetUserDailyCount(date)
//设置缓存
sc.Session.Set(USERMODULE+date, result)
}
查看Redis存储效果
-
开启Redis服务 在Mac下,启动redis服务使用如下命令:redis
-
开启Redis-cli客户端 在MacOS系统下,启动redis-cli工具的命令:redis-cli 如上我们可以通过keys命令来查看我们存储的所有的内容
-
get key读取具体信息 在查询所对应的key的redis存储内容值。
-
请发表评论