debug

zhangqian

2023-10-20 a699ff979c84d024ca33fb1139224258f278319f

 main.go

@@ -11,6 +11,7 @@
   "apsClient/serf"
   "apsClient/service/plc_address"
   "fmt"
   "log"
   "net/http"
   "time"
)
@@ -30,6 +31,7 @@

   // 启动数据同步
   var serfStartChan = make(chan bool)

   // 需要同步的表
   var syncTables = []string{
      "procedures",
@@ -41,10 +43,17 @@

   agent := serf.InitAgent("apsClient", syncTables, sqlitex.GetDB())
   agent.RegisterClusterEvent(serfClusterEvent)

   go agent.Serve(serfStartChan)
   <-serfStartChan
   //if !<-serfStartChan {
   //   logx.Errorf("serf Init err, exit")
   //   return
   //}

   // 判断当前集群状态
   logx.Infof("current agent.ClusterStatus:%v", agent.ClusterStatus)
   log.Println("current agent.ClusterStatus:", agent.ClusterStatus)
   if agent.ClusterStatus != "slave" {
      if err := nsq.Init(); err != nil {
         logx.Errorf("nsq Init err:%v", err)