-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathmain.go
More file actions
134 lines (109 loc) · 3.26 KB
/
main.go
File metadata and controls
134 lines (109 loc) · 3.26 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
package main
import (
"ginDemo/apps"
"ginDemo/apps/count"
"ginDemo/apps/dingtalk"
"ginDemo/apps/pays"
"ginDemo/apps/test"
"ginDemo/apps/users"
"ginDemo/apps/wechat"
"ginDemo/global"
"ginDemo/initialization"
"ginDemo/middleware"
_ "github.com/apache/skywalking-go"
"go.uber.org/zap"
"os"
"os/signal"
"strconv"
"syscall"
)
// @title ginDemo
// @version 1.0
// @description 此项目用于学习Golang的gin框架
// @termsOfService http://swagger.io/terms/
// @contact.name root
// @contact.email root@adcwb.com
// @contact.url http://www.swagger.io/support
// @license.name Apache 2.0
// @license.url http://www.apache.org/licenses/LICENSE-2.0.html
// @host localhost:8000
// @BasePath /
// @securityDefinitions.apikey ApiKeyAuth
// @in header
// @name Authorization
func main() {
// 加载多个APP的路由配置
apps.Include(
users.Routers,
dingtalk.Routers,
pays.Routers,
count.Routers,
test.Routers,
wechat.Routers,
)
// 初始化配置文件
initialization.InitConfigFile()
initialization.InitCasDoorSDK()
// 初始化日志中间件
if err := middleware.InitLogger(); err != nil {
zap.L().Error("日志模块加载失败！")
}
var err error
// 初始化数据库
global.DB, _ = initialization.InitMySqlClient()
// 数据迁移
// err := global.DB.AutoMigrate(
// &users.User{},
// &pays.PayConfigData{},
// &pays.PayData{},
// )
// if err != nil {
// zap.L().Error("数据库自动迁移失败！", zap.Error(err))
// }
// 初始化MongoDB数据库
initialization.InitMongoDBClient()
// 初始化Redis数据库
initialization.InitRedisClient()
// 初始化InfluxDB数据库
initialization.InitInfluxDB()
// 初始化RabbitMQ消息队列
initialization.InitRabbitMQ()
// 初始化企业微信所需要的参数
//utils.InitWorkWechatData(global.CONFIG.GetString("WorkWechatOpenKfId"))
// 初始化阿里云OSS存储
//initialization.InitAliYunOss()
// 初始化定时任务
// global.JobS = gocron.NewScheduler(time.UTC)
// 运行定时任务，每十分钟执行一次
// _, err = global.JobS.Cron("* */1 * * *").Do(utils.TimeOutCheck)
// if err != nil {
// zap.L().Error("调度任务报错！", zap.Error(err))
// }
// 运行调度任务，共有两种方式
// global.JobS.StartAsync() // 异步启动调度器
// global.JobS.StartBlocking() // 启动调度器并阻塞当前执行路径
// 初始化路由
r := apps.Init()
// initialization.InitSocketIO()
if global.ConfigMap.RunningConfig.RunningTLS {
// 启用https
if err = r.RunTLS(
global.ConfigMap.RunningConfig.Host+":"+strconv.Itoa(global.ConfigMap.RunningConfig.Port),
global.ConfigMap.RunningConfig.RunningCertFile,
global.ConfigMap.RunningConfig.RunningKeyFile,
); err != nil {
zap.L().Error("项目启动失败！", zap.Error(err))
}
} else {
if err = r.Run(global.ConfigMap.RunningConfig.Host + ":" + strconv.Itoa(global.ConfigMap.RunningConfig.Port)); err != nil {
zap.L().Error("项目启动失败！", zap.Error(err))
}
}
// 接收退出的信号，并做处理
q := make(chan os.Signal)
// 接收ctrl + c ，kill(排除 kill -9)
signal.Notify(q, syscall.SIGINT, syscall.SIGTERM)
<-q
// 后续操作处理，比如主动从服务中心中移除当前节点
zap.L().Error("项目停止运行了......")
}