裁剪集群操作的无关动作

zhangzengfei

2023-09-07 55aa27a6ad0e012d62dcea2db37528a1b18836fb

 system-service/main.go

@@ -3,13 +3,12 @@
import (
   "context"
   "flag"
   "net/http"
   _ "net/http/pprof"
   "os"
   "os/signal"
   "syscall"
   "vamicro/config"
   "vamicro/extend/util"
   //"vamicro/extend/util"
   "vamicro/system-service/broadcast"
   "vamicro/system-service/controllers"
   "vamicro/system-service/models"
@@ -68,29 +67,33 @@
   q := make(chan os.Signal, 1)
   signal.Notify(q, os.Interrupt, os.Kill, syscall.SIGTERM)

   ms, err := bhomeclient.NewMicroNode(ctx, q, config.Server.AnalyServerId, reg, logger.Debug)
   ms, err := bhomeclient.NewMicroNode(ctx, q, config.Server.AnalyServerId, reg, nil)
   if err != nil {
      return
   }

   bhomedbapi.InitGetNetNode(ms.GetLocalNetNodeByTopic)
   bhomedbapi.InitDoReq(ms.RequestOnly)
   bhomedbapi.InitLog(logger.Debug)
   //bhomedbapi.InitLog(logger.Debug)

   util.AuthCheck(ctx) //授权检查
   //util.AuthCheck(ctx) //授权检查

   go ms.StartServer(fm)
   go dealSubMsg(ctx, ms)

   serf.InitBusH(ms)
   serf.InitAgent(ctx)

   go service.WatchEsAndWeedfsIp(ms)
   //go service.WatchEsAndWeedfsIp(ms)
   go serf.StartSyncSqlToSerf()

   go service.StartSyncDev()
   //go service.StartSyncDev()

   go broadcast.StartServer() //设备可以被广播搜索

   //go service.CollectDeviceInfo(ctx, ms)

   go service.WatchAuthSetChange(ms) //根据授权文件监视通道数量变化
   //go service.WatchAuthSetChange(ms) //根据授权文件监视通道数量变化

   //统计系统运行状态
   go sys.GatherStat()