基于serf的数据库同步模块库
liuxiaolong
2019-12-04 1f819a31e020d4c861807245d35f504ed0d910c3
agent.go
@@ -240,10 +240,19 @@
      if event.EventType() == serf.EventMemberLeave {
         if ev.Members !=nil && len(ev.Members) ==1 {
            leaveMember := ev.Members[0]
            leaveSql := "delete from cluster_node where node_id='"+leaveMember.Name+"'"
            leaveSql := "update cluster_node set isDelete=1 where node_id='"+leaveMember.Name+"'"
            ExecuteSqlByGorm([]string{ leaveSql })
            logger.Info("EventMemberLeave,current Members:",ev.Members)
         }
         return
      } else if event.EventType() == serf.EventMemberJoin {
         if ev.Members !=nil && len(ev.Members) ==1 {
            leaveMember := ev.Members[0]
            leaveSql := "update cluster_node set isDelete=0 where node_id='"+leaveMember.Name+"'"
            ExecuteSqlByGorm([]string{ leaveSql })
            logger.Info("EventMemberJoin,current Members:",ev.Members)
         }
         return
      }
@@ -496,6 +505,9 @@
      }
   }
   logger.Info("mbs:",mbs,"a.conf.BindAddr:",a.conf.BindAddr,"specmembername:",specmembername)
   if specmembername == "" {//如果未找到目标节点,说明当前集群内除了本节点,没有其他可用节点
      return nil,errors.New("specmembername not found")
   }
   //query: get db file.
   params := serf.QueryParam{