dsbqj_admin/main-subscribe/main.go

package main

import (
	"dsbqj-admin/app/router"
	"dsbqj-admin/app/task"
	"dsbqj-admin/model/mongo"
	"dsbqj-admin/pkg/logger"
	"dsbqj-admin/pkg/validator"
	"fmt"
	"log"
	"net/http"
	"os"
	"time"

	"github.com/gin-gonic/gin"
	"github.com/joho/godotenv"
)

// @title           后端接口API文档
// @version         1.0
// @description     这里展示所有当前web端API接口信息

// @host      localhost:30101
// @BasePath  /web/v1

// @securityDefinitions.apikey cxy_token
// @name __CXY_TOKEN_
// @in header
// @securityDefinitions.apikey cxy_uid
// @name __CXY_UID_
// @in header

func main() {
	err := godotenv.Load()
	if err != nil {
		log.Fatal("Error loading .env file")
		return
	}
	validator.Init()
	logger.Init("")
	//cache.Redis()
	// 连接数据库
	//mysql.Database(os.Getenv("MYSQL_DSN"))
	mongo.Database(os.Getenv("MONGO_DSN"))
	// 启动任务
	//task.VersionInit(task.VersionInit, 5*time.Minute)
	task.Run(task.SubscribeInit(), 1*time.Second)

	if os.Getenv("GIN_MODE") == "release" {
		gin.SetMode(gin.ReleaseMode)
	}

	// 装载路由
	routersInit := router.NewSubscribeRouter()
	readTimeout := 60 * time.Second
	writeTimeout := 200 * time.Second
	endPoint := fmt.Sprintf("0.0.0.0:%s", os.Getenv("LISTEN_PORT"))
	maxHeaderBytes := 1 << 20

	server := &http.Server{
		Addr:           endPoint,
		Handler:        routersInit,
		ReadTimeout:    readTimeout,
		WriteTimeout:   writeTimeout,
		MaxHeaderBytes: maxHeaderBytes,
	}

	logger.Info("start http version listening %s", endPoint)
	err = server.ListenAndServe()
	fmt.Println(err)
}