diff --git a/pkg/apigateway/options/options.go b/pkg/apigateway/options/options.go index 4f79e8eb63..5a2df99e14 100644 --- a/pkg/apigateway/options/options.go +++ b/pkg/apigateway/options/options.go @@ -29,7 +29,7 @@ type GatewayOptions struct { SqlitePath string `help:"sqlite db path" default:"/etc/yunion/data/yunionapi.db"` - common_options.CommonOptions + common_options.CommonOptions `"request_worker_count->default":"32"` } var ( diff --git a/pkg/apigateway/service/service.go b/pkg/apigateway/service/service.go index ab0532d034..ccd089cb53 100644 --- a/pkg/apigateway/service/service.go +++ b/pkg/apigateway/service/service.go @@ -44,6 +44,10 @@ func StartService() { common_options.StartOptionManager(opts, opts.ConfigSyncPeriodSeconds, api.SERVICE_TYPE, api.SERVICE_VERSION, options.OnOptionsChange) + if commonOpts.RequestWorkerCount < 32 { + commonOpts.RequestWorkerCount = 32 + } + if opts.DisableModuleApiVersion { mcclient.DisableApiVersionByModule() } diff --git a/pkg/cloudcommon/app/app.go b/pkg/cloudcommon/app/app.go index bff0cb1ec9..44cc574b2f 100644 --- a/pkg/cloudcommon/app/app.go +++ b/pkg/cloudcommon/app/app.go @@ -28,6 +28,7 @@ import ( func InitApp(options *common_options.BaseOptions, dbAccess bool) *appsrv.Application { // cache := appsrv.NewCache(options.AuthTokenCacheSize) + log.Infof("RequestWorkerCount: %d", options.RequestWorkerCount) app := appsrv.NewApplication(options.ApplicationID, options.RequestWorkerCount, dbAccess) app.CORSAllowHosts(options.CorsHosts) diff --git a/pkg/cloudcommon/options/options.go b/pkg/cloudcommon/options/options.go index bf6e3d137f..7d3dbebcb2 100644 --- a/pkg/cloudcommon/options/options.go +++ b/pkg/cloudcommon/options/options.go @@ -58,7 +58,7 @@ type BaseOptions struct { TempPath string `help:"Path for store temp file, at least 40G space" default:"/opt/yunion/tmp"` ApplicationID string `help:"Application ID"` - RequestWorkerCount int `default:"4" help:"Request worker thread count, default is 4"` + RequestWorkerCount int `default:"8" help:"Request worker thread count, default is 8"` EnableSsl bool `help:"Enable https"` SslCaCerts string `help:"ssl certificate ca root file, separating ca and cert file is not encouraged" alias:"ca-file"`