git/wechat
1
0
Fork 0
mirror of https://github.com/silenceper/wechat.git synced 2026-02-12 08:42:28 +08:00
Code Issues Projects Releases Wiki Activity

redis IdleTimeout 使用second

Browse Source
This commit is contained in:
wenzl
2017-10-26 15:10:39 +08:00
parent 7e16a9d0bb
commit 5fc3e236e4
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
cache/redis.go vendored
View File

@@ -14,12 +14,12 @@ type Redis struct {
//RedisOpts redis 连接属性 //RedisOpts redis 连接属性
type RedisOpts struct { type RedisOpts struct {
Host string Host string `yml:"host" json:"host"`
Password string Password string `yml:"password" json:"password"`
Database int Database int `yml:"database" json:"database"`
MaxIdle int MaxIdle int `yml:"max_idle" json:"max_idle"`
MaxActive int MaxActive int `yml:"max_active" json:"max_active"`
IdleTimeout time.Duration //second IdleTimeout int32 `yml:"idle_timeout" json:"idle_timeout"` //second
} }
//NewRedis 实例化 //NewRedis 实例化
@@ -27,7 +27,7 @@ func NewRedis(opts *RedisOpts) *Redis {
pool := &redis.Pool{ pool := &redis.Pool{
MaxActive: opts.MaxActive, MaxActive: opts.MaxActive,
MaxIdle: opts.MaxIdle, MaxIdle: opts.MaxIdle,
IdleTimeout: opts.IdleTimeout, IdleTimeout: time.Second * time.Duration(opts.IdleTimeout),
Dial: func() (redis.Conn, error) { Dial: func() (redis.Conn, error) {
return redis.Dial("tcp", opts.Host, return redis.Dial("tcp", opts.Host,
redis.DialDatabase(opts.Database), redis.DialDatabase(opts.Database),