From 2cd1af13bc4e7aec4c85b9fe88db2d294af6468f Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期日, 08 十月 2023 11:24:37 +0800
Subject: [PATCH] 修复集群同步功能
---
system-service/serf/handler.go | 21 +++++++++++++++++++--
1 files changed, 19 insertions(+), 2 deletions(-)
diff --git a/system-service/serf/handler.go b/system-service/serf/handler.go
index a6fc49b..c5546db 100644
--- a/system-service/serf/handler.go
+++ b/system-service/serf/handler.go
@@ -77,8 +77,25 @@
logger.Info("LTime:", ev.LTime, " Recevie virtualIp change")
SyncVirtualIpChan <- ev.Payload
}
+func HandleUserEventSyncMessage(ev serf.UserEvent) {
+ logger.Info("receive a UserEventSyncMessage event")
+ var procMsg ProcMessageEvent
+ err := json.Unmarshal(ev.Payload, &procMsg)
+ if err != nil {
+ logger.Error("sqlUe unmarshal err:", err)
+ return
+ }
-//鏀跺埌鍏跺畠鑺傜偣涓诲姩灏嗘敞鍐屼腑蹇冪殑鎵�鏈塼opic閫氱煡鍒伴泦缇や腑
+ // 鑷繁鍙戦�佺殑娑堟伅涓嶅鐞�
+ if procMsg.Owner != config.Server.AnalyServerId {
+ // 鍒ゆ柇鏄惁鏈夋寚瀹氱殑鎺ユ敹鐩爣
+ if procMsg.Target == "" || procMsg.Target == config.Server.AnalyServerId {
+ SyncProcMessageChan <- ev.Payload
+ }
+ }
+}
+
+// 鏀跺埌鍏跺畠鑺傜偣涓诲姩灏嗘敞鍐屼腑蹇冪殑鎵�鏈塼opic閫氱煡鍒伴泦缇や腑
func HandleSyncRegisterInfo(ev serf.UserEvent) {
logger.Debug("HandleSyncRegisterInfo")
var si bhome_msg_dev.MsgDevRegisterInfo
@@ -167,7 +184,7 @@
}
}
-//澶勭悊鍏朵粬鐨勪竴浜泀uery璇锋眰
+// 澶勭悊鍏朵粬鐨勪竴浜泀uery璇锋眰
func HandleOtherQuery(ev *serf.Query) {
var reqBody RequestSerfTopicMsg
var ret []byte
--
Gitblit v1.8.0