添加订阅查询接口

zhangzengfei

2024-05-17 3e9a1a28b1283e40bc7edb94e2370c74e7fd68e0

 main.go

@@ -7,9 +7,10 @@
   "os"
   "os/signal"
   "syscall"
   "time"

   "gat1400Exchange/client"
   "gat1400Exchange/config"
   "gat1400Exchange/cron"
   "gat1400Exchange/models"
   "gat1400Exchange/pkg/logger"
   "gat1400Exchange/routes"
@@ -36,9 +37,17 @@
      Handler: r,
   }

   // 启动1400客户端
   ctx, cancel := context.WithCancel(context.Background())
   go client.Init1400Client(ctx)

   // 启动网络视频字符叠加器服务
   go service.NVCSServer()
   go service.DeviceInfoReportTask()
   go service.StartNVCSServer()

   go service.InitSubscribeTask()

   // 启动定时任务
   cron.Init()

   // Initializing the server in a goroutine so that
   // it won't block the graceful shutdown handling below
@@ -62,11 +71,13 @@

   // The context is used to inform the server it has 5 seconds to finish
   // the request it is currently handling
   ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
   //ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
   defer cancel()
   if err := srv.Shutdown(ctx); err != nil {
      logger.Error("Server forced to shutdown:", err)
   }

   service.StopSubscribeTask()

   logger.Info("Server exiting!")
}