集群退出密码

zhangzengfei

2023-10-24 c5654846d3b8b002284dee57aa50e95d67649f0e

 system-service/serf/sync.go

@@ -52,9 +52,11 @@
      nodes, e := nodeE.FindNodesByClusterId(c.ClusterId)
      if e == nil && nodes != nil && len(nodes) > 0 {
         var nodeIps []string
         for _, n := range nodes {
         for idx, n := range nodes {
            if n.NodeId != config.Server.AnalyServerId {
               nodeIps = append(nodeIps, n.NodeIp)
            } else {
               nodeE = nodes[idx]
            }
         }

@@ -69,6 +71,21 @@
         Agent, err = sdb.Init(c.ClusterId, c.Password, config.Server.AnalyServerId, nodeIps, config.ClusterSet.SerfSnapShotPath, conf)
         if Agent != nil {
            Agent.RegisterHandleEventFunc(HandleSerfEvent)

            logger.Debugf("local node:", nodeE)
            if nodeE.DriftState == "slave" {
               chMsg := protomsg.DbChangeMessage{
                  Id:     nodeE.ClusterId,
                  Table:  protomsg.TableChanged_T_Cluster,
                  Action: protomsg.DbAction_Insert,
                  Info:   "master2slave",
               }
               b, _ := json.Marshal(chMsg)
               err = hms.Publish(bhomeclient.Proc_System_Service, b)
               if err != nil {
                  logger.Error(err.Error())
               }
            }
            logger.Debug("sync.Agent init success!")
         } else {
            logger.Debug("sync.Agent init fail!")