库中新增更新缓存

liujiandao

2024-02-20 7779e07bd84d081a8f14ef976397dc4c19b0e994

 main.go

@@ -130,6 +130,8 @@
            } else if err = proto.Unmarshal(msg, &compareEvent); err == nil {
               if compareEvent.EventType == protomsg.CompareEventType_ReInitCache { //加入集群后重新初始化缓存
                  cache.ReInitDbTablePersonsCache()
               } else if compareEvent.EventType == protomsg.CompareEventType_UpdateCache { //库中新增更新缓存
                  cache.UpdateDbPersonsCache()
               }
            } else {
               logger.Debug("json unmarshal error")