zhangqian
2023-10-13 f838162ed0ee7f2832924c2399eddd461760135a
main.go
@@ -25,11 +25,6 @@
      return
   }
   if err := crontask.InitTask(); err != nil {
      logx.Errorf("crontab task Init err:%v", err)
      return
   }
   //加载plc写入地址
   plc_address.LoadAddressFromFile()
@@ -54,6 +49,11 @@
         logx.Errorf("nsq Init err:%v", err)
         return
      }
      crontask.Once()
      if err := crontask.StartTask(); err != nil {
         logx.Errorf("crontab task Init err:%v", err)
         return
      }
   }
   logx.Infof("apsClient start serve...")
@@ -73,8 +73,14 @@
         logx.Errorf("nsq Init err:%v", err)
         return
      }
      crontask.Once()
      if err := crontask.StartTask(); err != nil {
         logx.Errorf("crontab task Init err:%v", err)
         return
      }
   case serf.EventJoinCluster, serf.EventMaster2Slave:
      nsq.Stop()
      crontask.StopTask()
   }
   logx.Infof("serf cluster event: %v", stat)