diff --git a/lego/sys/redis/cluster/core.go b/lego/sys/redis/cluster/core.go index 596ffbe03..110a17ae6 100644 --- a/lego/sys/redis/cluster/core.go +++ b/lego/sys/redis/cluster/core.go @@ -8,7 +8,7 @@ import ( "github.com/go-redis/redis/v8" ) -func NewSys(RedisUrl []string, RedisPassword string, timeOut time.Duration, +func NewSys(RedisUrl []string, RedisPassword string, poolSize int, timeOut time.Duration, codec core.ICodec, ) (sys *Redis, err error) { var ( @@ -17,6 +17,7 @@ func NewSys(RedisUrl []string, RedisPassword string, timeOut time.Duration, client = redis.NewClusterClient(&redis.ClusterOptions{ Addrs: RedisUrl, Password: RedisPassword, + PoolSize: poolSize, DialTimeout: timeOut, ReadTimeout: timeOut, WriteTimeout: timeOut, diff --git a/lego/sys/redis/options.go b/lego/sys/redis/options.go index c4eaa6f68..a02917982 100644 --- a/lego/sys/redis/options.go +++ b/lego/sys/redis/options.go @@ -22,6 +22,7 @@ type Options struct { Redis_Single_DB int Redis_Cluster_Addr []string Redis_Cluster_Password string + PoolSize int TimeOut time.Duration Codec core.ICodec } @@ -81,6 +82,7 @@ func newOptions(config map[string]interface{}, opts ...Option) Options { Redis_Single_DB: 1, Redis_Cluster_Addr: []string{"127.0.0.1:6379"}, Redis_Cluster_Password: "", + PoolSize: 200, TimeOut: time.Second * 3, } if config != nil { @@ -99,6 +101,7 @@ func newOptionsByOption(opts ...Option) Options { Redis_Single_DB: 1, Redis_Cluster_Addr: []string{"127.0.0.1:6379"}, Redis_Cluster_Password: "", + PoolSize: 200, TimeOut: time.Second * 3, } for _, o := range opts { diff --git a/lego/sys/redis/redis.go b/lego/sys/redis/redis.go index d95c0b593..f09b074c1 100644 --- a/lego/sys/redis/redis.go +++ b/lego/sys/redis/redis.go @@ -30,6 +30,7 @@ func (this *Redis) init() (err error) { this.options.Redis_Single_Addr, this.options.Redis_Single_Password, this.options.Redis_Single_DB, + this.options.PoolSize, this.options.TimeOut, this, ) @@ -37,6 +38,7 @@ func (this *Redis) init() (err error) { this.client, err = cluster.NewSys( this.options.Redis_Cluster_Addr, this.options.Redis_Cluster_Password, + this.options.PoolSize, this.options.TimeOut, this, ) diff --git a/lego/sys/redis/single/core.go b/lego/sys/redis/single/core.go index b96d4448f..d90bf22fd 100644 --- a/lego/sys/redis/single/core.go +++ b/lego/sys/redis/single/core.go @@ -8,7 +8,7 @@ import ( "github.com/go-redis/redis/v8" ) -func NewSys(RedisUrl, RedisPassword string, RedisDB int, timeOut time.Duration, +func NewSys(RedisUrl, RedisPassword string, RedisDB int, poolSize int, timeOut time.Duration, codec core.ICodec, ) (sys *Redis, err error) { var ( @@ -18,6 +18,7 @@ func NewSys(RedisUrl, RedisPassword string, RedisDB int, timeOut time.Duration, Addr: RedisUrl, Password: RedisPassword, DB: RedisDB, + PoolSize: poolSize, DialTimeout: timeOut, WriteTimeout: timeOut, ReadTimeout: timeOut, diff --git a/services/cmd/main.go b/services/cmd/main.go index a3a774d31..2d3f4f5d4 100644 --- a/services/cmd/main.go +++ b/services/cmd/main.go @@ -373,6 +373,7 @@ func convertServiceSttings(config *comm.GameConfig, id int, stype string, ip str "RedisAddr": config.LoaclDB.RedisAddr, "RedisPassword": config.LoaclDB.RedisPassword, "RedisDB": config.LoaclDB.RedisDB, + "PoolSize": 300, "MongodbUrl": config.LoaclDB.MongodbUrl, "MongodbDatabase": config.LoaclDB.MongodbDatabase, "CrossConfig": crosspath,