集群架构

src/server/conf/server.json

@@ -22,12 +22,12 @@
 	"ServerOpenTime": "2018-01-01 00:00:00",
 	"ServerName": "Merge_Pet",
 	"ServerStatus" : 1,
-	"ServerCenter" : 1,
+	"ServerCenter" : 0,
 	"GameConfPath": "D:/Github/pet_home_server/src/server/gamedata/config/",
 
 	"ListenAddr":":9001",
-	"CenterAddr": "pethome.bywaystudios.com:9000",
-	"RemoteAddr":"host.docker.internal:9001",
+	"CenterAddr": "127.0.0.1:9000",
+	"RemoteAddr":"127.0.0.1:9001",
 	
 	"RedisAddr":"127.0.0.1",          
 	"RedisPort" :"6379",             

src/server/game/UnitTest.go

@@ -3,10 +3,12 @@ package game
 import (
 	"fmt"
 	"math"
+	"server/GoUtil"
 	mergeDataCfg "server/conf/mergeData"
 	orderCfg "server/conf/order"
 	"server/game/mod/decorate"
 	"server/game/mod/item"
+	MsgMod "server/game/mod/msg"
 	"server/game/mod/order"
 	"server/game/mod/quest"
 	"server/msg"
@@ -371,3 +373,50 @@ func UnitOrderPetReward(p *Player) error {
 	}
 	return nil
 }
+
+func UnitClusterChampship(p *Player) error {
+	ChampshipMod := p.PlayMod.getChampshipMod()
+	Score := float64(ChampshipMod.GetScore())
+	//更新排行榜
+	m := &MsgMod.Msg{
+		Type:  MsgMod.HANDLE_TYPE_CHAMPSHIP_INRANK,
+		SendT: GoUtil.Now(),
+		Extra: CRank{
+			Uid:   int(p.M_DwUin),
+			Score: Score,
+			H:     ChampshipMod.GetH(),
+			N:     ChampshipMod.GetN(),
+		},
+	}
+
+	time.Sleep(5 * time.Second)
+	SendMsgToCenter(m)
+	<-p.msgChan
+	return nil
+}
+
+func UnitClusterChampshipCall(p *Player) error {
+	ChampshipMod := p.PlayMod.getChampshipMod()
+	Score := float64(ChampshipMod.GetScore())
+	//更新排行榜
+	m := &MsgMod.Msg{
+		Type:  MsgMod.HANDLE_TYPE_CHAMPSHIP_MY_RANK,
+		SendT: GoUtil.Now(),
+		From:  int(p.M_DwUin),
+		Extra: CRank{
+			Uid:   int(p.M_DwUin),
+			Score: Score,
+			H:     ChampshipMod.GetH(),
+			N:     ChampshipMod.GetN(),
+		},
+	}
+	SendMsgToCenter(m)
+	time.Sleep(5 * time.Second)
+	r, err := CallMsgToCenter(m)
+	if err != nil {
+		log.Debug(err.Error())
+		return err
+	}
+	fmt.Print(r)
+	return nil
+}