pet_home/pet_home_server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

系统优化

Browse Source
This commit is contained in:
hahwu 2025-03-19 17:24:52 +08:00
parent 29e3061fc7
commit fcb838fa9a
3 changed files with 41 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/server/conf/server.json
View File

@ -14,7 +14,7 @@
"AppPath": "./app",
"TELOGDIR" : "./teLog/",
"GameName": "Merge_Pet_Local",
"GameName": "pet_home",
"GameID": 1,
"ServerType":"node",

6
src/server/game/UnitTest.go
View File

@ -213,9 +213,7 @@ func UnitPlayroom(p *Player) error {
}
func UnitDailyTask(p *Player) error {
DailyTaskMod := p.PlayMod.getDailyTaskMod()
for i := 0; i < 1000; i++ {
DailyTaskMod.WeekUpdate()
}
FT := p.PlayMod.getFriendTreasureMod()
FT.ZeroUpdate()
return nil
}

42
src/server/middleware/kafka/kafka.go
View File

@ -15,18 +15,33 @@ var topic string
func init() {
topic = conf.Server.GameName
// 连接至Kafka集群的Leader节点
conn, err := kafka.DialLeader(context.Background(), "tcp", "kafka-server-3:9096", topic, conf.Server.Partition)
conn, err := kafka.DialContext(context.Background(), "tcp", "kafka-server:9092")
if err != nil {
log.Debug("kafka.DialLeader err: %v", err)
log.Debug("kafka.DialContext err: %v", err)
go reconnectKafka()
return
}
Partitions, err := conn.ReadPartitions(topic)
if err != nil {
log.Fatal("kafka.DialContext err: %v", err)
return
}
for _, p := range Partitions {
if p.Leader.Host == "kafka-server" {
conn, err := kafka.DialLeader(context.Background(), "tcp", "kafka-server:9092", topic, p.ID)
if err != nil {
log.Fatal("kafka.DialLeader err: %v", err)
return
}
log.Release("Reconnected to Kafka")
KafkaMod = conn
return
}
}
log.Fatal("kafka.DialLeader err: %v", "no leader")
}
func reconnectKafka() {
partition := 0
WaitTime := 5
for {
WaitTime--
@ -34,11 +49,24 @@ func reconnectKafka() {
log.Debug("Reconnected to Kafka failed")
return
}
conn, err := kafka.DialLeader(context.Background(), "tcp", "kafka-server:9092", topic, partition)
if err == nil {
conn, err := kafka.DialContext(context.Background(), "tcp", "kafka-server:9092")
if err != nil {
log.Fatal("kafka.DialContext err: %v", err)
return
}
Partitions, err := conn.ReadPartitions(topic)
for _, p := range Partitions {
if p.Leader.Host == "kafka-server" {
conn, err := kafka.DialLeader(context.Background(), "tcp", "kafka-server:9092", topic, p.ID)
if err != nil {
log.Fatal("kafka.DialLeader err: %v", err)
return
}
log.Release("Reconnected to Kafka")
KafkaMod = conn
log.Debug("Reconnected to Kafka")
break
return
}
}
time.Sleep(time.Second)
log.Debug("kafka.DialLeader retry err: %v", err)