负载同步

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

@@ -125,22 +125,26 @@ func (p *ActorSaves) savePlayerDB() {
 	newPlayers := mdb.RDB.HGetAll(ctx, constant.NewPlayers).Val()
 	updPlayer := []string{}
 	for k, _ := range newPlayers {
+		if key < 10000 {
+			var player models.Player
+			acc, _ := mdb.RDB.Get(ctx, fmt.Sprintf("%v:%v", constant.CNamePlayer, k)).Bytes()
+			if len(acc) > 0 {
+				err := jsoniter.Unmarshal(acc, &player)
+				if err != nil {
+					continue
+				}
+			}
+			filter := bson.M{"openId": player.OpenId}
+			update := bson.M{"$set": &player}
+			bulkUpdOps = append(bulkUpdOps, mongo.NewUpdateOneModel().SetFilter(filter).SetUpdate(update))
+			updPlayer = append(updPlayer, player.OpenId)
+		}
+		key++
 		if key > 10000 {
 			break
 		}
-		var player models.Player
-		acc, _ := mdb.RDB.Get(ctx, fmt.Sprintf("%v:%v", constant.CNamePlayer, k)).Bytes()
-		if len(acc) > 0 {
-			err := jsoniter.Unmarshal(acc, &player)
-			if err != nil {
-				continue
-			}
-		}
-		filter := bson.M{"openId": player.OpenId}
-		update := bson.M{"$set": &player}
-		bulkUpdOps = append(bulkUpdOps, mongo.NewUpdateOneModel().SetFilter(filter).SetUpdate(update))
-		updPlayer = append(updPlayer, player.OpenId)
 	}
+
 	if len(bulkUpdOps) > 0 {
 		_, err := mdb.MDB.Collection(constant.CNamePlayer).BulkWrite(context.Background(), bulkUpdOps)
 		if err != nil {