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/sync.go | 25 +++++++++++++++++++++++++ 1 files changed, 25 insertions(+), 0 deletions(-) diff --git a/system-service/serf/sync.go b/system-service/serf/sync.go index ed1089c..c5710da 100644 --- a/system-service/serf/sync.go +++ b/system-service/serf/sync.go @@ -6,6 +6,7 @@ "basic.com/valib/bhomeclient.git" "basic.com/valib/logger.git" "context" + "encoding/json" "github.com/gogo/protobuf/proto" "nanomsg.org/go-mangos" "nanomsg.org/go-mangos/protocol/req" @@ -112,6 +113,30 @@ select { case <-ctx.Done(): return + case b := <-SyncProcMessageChan: + { + var procMsg ProcMessageEvent + err := json.Unmarshal(b, &procMsg) + if err != nil { + logger.Error("Unmarshal ProcMessageEvent ", err.Error()) + } else { + err = hms.Publish(procMsg.Topic, procMsg.Payload) + if err != nil { + logger.Error("hms.Publish error ", err.Error()) + } + } + + } + default: + time.Sleep(50 * time.Millisecond) + } + } + }() + go func() { + for { + select { + case <-ctx.Done(): + return case b := <-syncSdkCompareCacheChan: { logger.Debug("SyncSdkCompareCache in,len(b):", len(b)) -- Gitblit v1.8.0