修复集群同步功能

zhangzengfei

2023-10-08 2cd1af13bc4e7aec4c85b9fe88db2d294af6468f

 sysinfo-service/main.go

@@ -18,10 +18,10 @@

var (
   procName = service.ProcName
   proc = &bhomeclient.ProcInfo{
   proc     = &bhomeclient.ProcInfo{
      Name: procName, //进程名称
      ID: procName, //进程id
      Info: "", //进程的描述信息，用于区分同一进程名称下多个进程
      ID:   procName, //进程id
      Info: "",       //进程的描述信息，用于区分同一进程名称下多个进程
   }
   env = flag.String("e", "pro", "")
)
@@ -33,24 +33,24 @@
   config.Init(*env)

   // 日志初始化
   var logFile = config.LogConf.Path + "vamicro-"+procName+".log"
   var logFile = config.LogConf.Path + "vamicro-" + procName + ".log"
   logger.InitLogger(logFile, config.LogConf.Level, config.LogConf.MaxSize, config.LogConf.MaxBackups, config.LogConf.MaxAge)
   logger.Info("log init success !")
}

func main(){
func main() {
   // pprof 用于分析性能
   //go func() {
   //   logger.Info(http.ListenAndServe("0.0.0.0:6079", nil))
   //}()

   fm,pubTopics := initFuncMap()
   fm, pubTopics := initFuncMap()
   ctx, cancel := context.WithCancel(context.Background())
   var reg = &bhomeclient.RegisterInfo {
      Proc: *proc,
      Channel: nil,
      PubTopic: pubTopics,
      SubTopic: []string{},
   var reg = &bhomeclient.RegisterInfo{
      Proc:        *proc,
      Channel:     nil,
      PubTopic:    pubTopics,
      SubTopic:    []string{},
      SubNetTopic: []string{},
   }

@@ -58,7 +58,7 @@
   signal.Notify(q, os.Interrupt, os.Kill, syscall.SIGTERM)

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

@@ -76,6 +76,7 @@
}

const urlPrefix = "/data/api-v"

func initFuncMap() (map[string]bhomeclient.MicroFunc, []string) {
   funcMap := make(map[string]bhomeclient.MicroFunc)

@@ -84,8 +85,9 @@
   funcMap[urlPrefix+"/sysinfo/showProcesses"] = controllers.ShowVasystemProcesses

   var pubTopics []string
   for key,_ := range funcMap {
   for key, _ := range funcMap {
      pubTopics = append(pubTopics, key)
   }

   return funcMap, pubTopics
}