添加订阅查询接口

zhangzengfei

2024-05-17 3e9a1a28b1283e40bc7edb94e2370c74e7fd68e0

 main.go

@@ -3,15 +3,14 @@
import (
   "context"
   "fmt"
   "gat1400Exchange/client"
   "gat1400Exchange/cron"
   "net/http"
   "os"
   "os/signal"
   "syscall"
   "time"

   "gat1400Exchange/client"
   "gat1400Exchange/config"
   "gat1400Exchange/cron"
   "gat1400Exchange/models"
   "gat1400Exchange/pkg/logger"
   "gat1400Exchange/routes"
@@ -39,10 +38,13 @@
   }

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

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

   go service.InitSubscribeTask()

   // 启动定时任务
   cron.Init()
@@ -69,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!")
}