库中新增更新单条缓存

liujiandao

2024-02-20 07eea46970759aba106f3db3f4bc24c518ab41de

 main.go

@@ -131,7 +131,7 @@
               if compareEvent.EventType == protomsg.CompareEventType_ReInitCache { //加入集群后重新初始化缓存
                  cache.ReInitDbTablePersonsCache()
               } else if compareEvent.EventType == protomsg.CompareEventType_UpdateCache { //库中新增更新缓存
                  cache.UpdateDbPersonsCache()
                  cache.UpdateDbPersonsCacheById(string(compareEvent.Payload))
               }
            } else {
               logger.Debug("json unmarshal error")