定时任务分master模式和非master模式

zhangqian

2023-10-17 f75b6f9ee6b2c542d52b4a11113bd281b421c4c0

 main.go

@@ -50,11 +50,12 @@
         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
      }

   }
   crontask.Once(agent.ClusterStatus != "slave")
   if err := crontask.StartTask(agent.ClusterStatus != "slave"); err != nil {
      logx.Errorf("crontab task Init err:%v", err)
      return
   }

   logx.Infof("apsClient start serve...")
@@ -70,18 +71,22 @@
func serfClusterEvent(stat int) {
   switch stat {
   case serf.EventCreateCluster, serf.EventSlave2Master, serf.EventLeaveCluster:
      if err := nsq.Init(); err != nil {
      if err := nsq.Init(); err != nil { //开启nsq
         logx.Errorf("nsq Init err:%v", err)
         return
      }
      crontask.Once()
      if err := crontask.StartTask(); err != nil {
      crontask.Once(true)
      if err := crontask.RestartTask(true); err != nil { //以master方式重启task
         logx.Errorf("crontab task Init err:%v", err)
         return
      }
   case serf.EventJoinCluster, serf.EventMaster2Slave:
      nsq.Stop()
      crontask.StopTask()
      nsq.Stop() //关闭nsq
      crontask.Once(false)
      if err := crontask.RestartTask(false); err != nil { //以非master方式重启task
         logx.Errorf("crontab task Init err:%v", err)
         return
      }
   }

   logx.Infof("serf cluster event: %v", stat)