main.go

package main

import (
	log "github.com/sirupsen/logrus"
	"github.com/zhanghe06/gin_project/config"
	"github.com/zhanghe06/gin_project/dbs"
	"github.com/zhanghe06/gin_project/logs"
	"github.com/zhanghe06/gin_project/rabbitmq"
	"github.com/zhanghe06/gin_project/routers"
	"github.com/zhanghe06/gin_project/validators"
)

func main() {
	// 初始化配置
	err := config.Init()
	if err != nil {
		log.Fatal(err)
	}
	config.Watch()

	// 初始化日志
	err = logs.Init()
	if err != nil {
		log.Fatal(err)
	}
	defer logs.Close()

	// 初始化数据库
	err = dbs.Init()
	if err != nil {
		log.Fatal(err)
	}
	defer dbs.Close()

	// 初始化消息队列
	err = rabbitmq.Init()
	if err != nil {
		log.Fatal(err)
	}
	defer rabbitmq.Close()

	// 断线重连
	go rabbitmq.MQ.Keepalive()

	// 初始化ETCD
	//err = etcds.Init()
	//if err != nil {
	//	log.Fatal(err)
	//}
	//defer etcds.Close()

	// 初始化路由
	router := routers.Init()

	// 注册校验器
	err = validators.Init()
	if err != nil {
		log.Fatal(err)
	}

	// 消息发送[测试数据]
	ex := "ex.project.topic"
	rk := "rk.project"
	body := "test msg"

	err = rabbitmq.MQ.Publish(ex, rk, body)
	if err != nil {
		log.Fatal(err)
	}

	// 启动服务
	err = router.Run()
	if err != nil {
		log.Fatal(err)
	}
}