| | |
| | | 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" |
| | |
| | | } |
| | | |
| | | // 启动1400客户端 |
| | | go client.Init1400Client() |
| | | ctx, cancel := context.WithCancel(context.Background()) |
| | | go client.Init1400Client(ctx) |
| | | |
| | | // 启动网络视频字符叠加器服务 |
| | | go service.NVCSServer() |
| | |
| | | |
| | | // 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) |