liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

上传客户端redis链接池优化

Browse Source
This commit is contained in:
liwei1dao 2023-09-13 17:14:01 +08:00
parent ba2f8c4ba2
commit 90b70f315f
4 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
lego/sys/redis/cluster/core.go
View File

@ -8,7 +8,7 @@ import (
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v8"
) )
func NewSys(RedisUrl []string, RedisPassword string, poolSize int, timeOut time.Duration, func NewSys(RedisUrl []string, RedisPassword string, poolSize, minConns int, timeOut time.Duration,
codec core.ICodec, codec core.ICodec,
) (sys *Redis, err error) { ) (sys *Redis, err error) {
var ( var (
@ -18,6 +18,7 @@ func NewSys(RedisUrl []string, RedisPassword string, poolSize int, timeOut time.
Addrs: RedisUrl, Addrs: RedisUrl,
Password: RedisPassword, Password: RedisPassword,
PoolSize: poolSize, PoolSize: poolSize,
MinIdleConns: minConns,
DialTimeout: timeOut, DialTimeout: timeOut,
ReadTimeout: timeOut, ReadTimeout: timeOut,
WriteTimeout: timeOut, WriteTimeout: timeOut,

7
lego/sys/redis/options.go
View File

@ -23,6 +23,7 @@ type Options struct {
Redis_Cluster_Addr []string Redis_Cluster_Addr []string
Redis_Cluster_Password string Redis_Cluster_Password string
PoolSize int PoolSize int
MinConns int
TimeOut time.Duration TimeOut time.Duration
Codec core.ICodec Codec core.ICodec
} }
@ -82,7 +83,8 @@ func newOptions(config map[string]interface{}, opts ...Option) Options {
Redis_Single_DB: 1, Redis_Single_DB: 1,
Redis_Cluster_Addr: []string{"127.0.0.1:6379"}, Redis_Cluster_Addr: []string{"127.0.0.1:6379"},
Redis_Cluster_Password: "", Redis_Cluster_Password: "",
PoolSize: 200, PoolSize: 64,
MinConns: 32,
TimeOut: time.Second * 3, TimeOut: time.Second * 3,
} }
if config != nil { if config != nil {
@ -101,7 +103,8 @@ func newOptionsByOption(opts ...Option) Options {
Redis_Single_DB: 1, Redis_Single_DB: 1,
Redis_Cluster_Addr: []string{"127.0.0.1:6379"}, Redis_Cluster_Addr: []string{"127.0.0.1:6379"},
Redis_Cluster_Password: "", Redis_Cluster_Password: "",
PoolSize: 200, PoolSize: 64,
MinConns: 32,
TimeOut: time.Second * 3, TimeOut: time.Second * 3,
} }
for _, o := range opts { for _, o := range opts {

2
lego/sys/redis/redis.go
View File

@ -31,6 +31,7 @@ func (this *Redis) init() (err error) {
this.options.Redis_Single_Password, this.options.Redis_Single_Password,
this.options.Redis_Single_DB, this.options.Redis_Single_DB,
this.options.PoolSize, this.options.PoolSize,
this.options.MinConns,
this.options.TimeOut, this.options.TimeOut,
this, this,
) )
@ -39,6 +40,7 @@ func (this *Redis) init() (err error) {
this.options.Redis_Cluster_Addr, this.options.Redis_Cluster_Addr,
this.options.Redis_Cluster_Password, this.options.Redis_Cluster_Password,
this.options.PoolSize, this.options.PoolSize,
this.options.MinConns,
this.options.TimeOut, this.options.TimeOut,
this, this,
) )

3
lego/sys/redis/single/core.go
View File

@ -8,7 +8,7 @@ import (
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v8"
) )
func NewSys(RedisUrl, RedisPassword string, RedisDB int, poolSize int, timeOut time.Duration, func NewSys(RedisUrl, RedisPassword string, RedisDB int, poolSize, minConns int, timeOut time.Duration,
codec core.ICodec, codec core.ICodec,
) (sys *Redis, err error) { ) (sys *Redis, err error) {
var ( var (
@ -19,6 +19,7 @@ func NewSys(RedisUrl, RedisPassword string, RedisDB int, poolSize int, timeOut t
Password: RedisPassword, Password: RedisPassword,
DB: RedisDB, DB: RedisDB,
PoolSize: poolSize, PoolSize: poolSize,
MinIdleConns: minConns,
DialTimeout: timeOut, DialTimeout: timeOut,
WriteTimeout: timeOut, WriteTimeout: timeOut,
ReadTimeout: timeOut, ReadTimeout: timeOut,