负载同步

components/mongo/component.go

@@ -98,8 +98,12 @@ func CreateDatabase(uri, dbName string, timeout ...time.Duration) (*mongo.Databa
 	//	PreferServerCipherSuites: true,
 	//}
 	//o := options.Client().ApplyURI(uri).SetTLSConfig(tlsConfig)
-
-	o := options.Client().ApplyURI(uri).SetMaxPoolSize(500)
+	o := options.Client().ApplyURI(uri).SetMaxPoolSize(500). //最大连接
+									SetMinPoolSize(20).                  //最小连接
+									SetMaxConnIdleTime(3 * time.Minute). //连接空闲时间
+									SetMaxConnIdleTime(5 * time.Minute). //连接生命周期
+									SetConnectTimeout(10 * time.Second). //连接超时时间
+									SetSocketTimeout(10 * time.Second)   //套接字超时时间
 	if err := o.Validate(); err != nil {
 		return nil, err
 	}

game/game_cluster/robot_client/main.go

@@ -17,7 +17,7 @@ import (
 func main() {
 
 	// 定义命令行标志
-	userOffset := flag.Int("userOffset", 300001, "用户偏移量")
+	userOffset := flag.Int("userOffset", 400001, "用户偏移量")
 	count := flag.Int("count", 50000, "请求总数")
 	qps := flag.Int("qps", 200, "最大并发数")
 	url := flag.String("url", "http://127.0.0.1:20000", "请求url")