负载同步

game/game_cluster/nodes/db/db.go

@@ -32,6 +32,5 @@ func main() {
 		&module.ActorSaves{},
 		&mdb.ActorDB{Name: nodeId},
 	)
-
 	app.Startup()
 }

game/game_cluster/nodes/db/module/actor_save_db.go

@@ -27,8 +27,16 @@ func (p *ActorSaves) AliasID() string {
 }
 
 func (p *ActorSaves) OnInit() {
-	p.Timer().Add(60*time.Second, p.saveAccountDB)
-	p.Timer().Add(60*time.Second, p.savePlayerDB)
+	p.Timer().Add(60*time.Second, p.saveAccountDB1)
+	p.Timer().Add(60*time.Second, p.savePlayerDB1)
+}
+
+func (p *ActorSaves) saveAccountDB1() {
+	go p.saveAccountDB()
+}
+
+func (p *ActorSaves) savePlayerDB1() {
+	go p.savePlayerDB()
 }
 
 func (p *ActorSaves) saveAccountDB() {

game/game_cluster/robot_client/main.go

@@ -17,8 +17,8 @@ import (
 func main() {
 
 	// 定义命令行标志
-	userOffset := flag.Int("userOffset", 600001, "用户偏移量")
-	count := flag.Int("count", 100000, "请求总数")
+	userOffset := flag.Int("userOffset", 200000, "用户偏移量")
+	count := flag.Int("count", 200000, "请求总数")
 	qps := flag.Int("qps", 500, "最大并发数")
 	url := flag.String("url", "http://127.0.0.1:20000", "请求url")
 	url1 := flag.String("url1", "http://127.0.0.1:20001", "请求url")