main.go
@@ -11,6 +11,7 @@ "apsClient/serf" "apsClient/service/plc_address" "fmt" "log" "net/http" "time" ) @@ -50,6 +51,8 @@ } // 判断当前集群状态 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)