添加主节点变更和主动切换功能

zhangzengfei

2023-10-20 71b8885babe6dfd25c91b007018347c0c1bfac74

 system-service/serf/serf.go

@@ -21,6 +21,7 @@
   UserEventSyncSql                = "SyncSql"
   UserEventSyncDbTablePersonCache = "SyncCache"
   UserEventSyncVirtualIp          = "SyncVirtualIp"              //漂移ip修改
   UserEventChangeMaster           = "ChangeMaster "              //修改节点状态
   UserEventSyncRegisterInfo       = "SyncRegisterInfo"           //同步注册信息
   DataSystemSerfSubscribe         = "data-system-serf-subscribe" //各app从serf订阅消息
   UserEventSyncMessage            = "SyncMessageForProc"         // 为其他进程同步消息
@@ -42,6 +43,8 @@
         HandleUserEventSyncDbTablePersonCache(ev)
      } else if ev.Name == UserEventSyncVirtualIp {
         HandleUserEventSyncVirtualIp(ev)
      } else if ev.Name == UserEventChangeMaster {
         HandleUserEventChangeMaster(ev)
      } else if ev.Name == UserEventSyncRegisterInfo {
         HandleSyncRegisterInfo(ev)
      } else if ev.Name == DataSystemSerfSubscribe {
@@ -61,8 +64,10 @@
   case serf.MemberEvent:
      if event.EventType() == serf.EventMemberLeave {
         HandleEventMemberLeave(ev)
      } else if event.EventType() == serf.EventMemberJoin {
      } else if event.EventType() == serf.EventMemberJoin || event.EventType() == serf.EventMemberUpdate {
         HandleEventMemberJoin(ev)
      } else if event.EventType() == serf.EventMemberFailed {
         HandleEventMemberFail(ev)
      }
      logger.Error("serf MemberEvent ", event.EventType())
   default:
@@ -90,11 +95,11 @@
               logger.Error("ExecuteSqlByGorm err:", err, ",sql:", sql)
               return false, err
            }
            if result.RowsAffected == 0 {
               logger.Debug("ExecuteSqlByGorm RowsAffected == 0", ",sql:", sql)
               err = errors.New("ExecuteSqlByGorm RowsAffected == 0")
               return false, err
            }
            //if result.RowsAffected == 0 {
            //   logger.Debug("ExecuteSqlByGorm RowsAffected == 0", ",sql:", sql)
            //   err = errors.New("ExecuteSqlByGorm RowsAffected == 0")
            //   return false, err
            //}
         }
         tx.Commit()
         return true, nil