feat: 优化

This commit is contained in:
meilin.huang
2022-01-13 17:06:04 +08:00
parent 1216ce3b52
commit 1df943d825
13 changed files with 67 additions and 44 deletions

View File

@@ -1,11 +1,13 @@
package global
import (
"github.com/go-redis/redis"
"github.com/sirupsen/logrus"
"gorm.io/gorm"
)
var (
Log *logrus.Logger // 日志
Db *gorm.DB // gorm
Log *logrus.Logger // 日志
Db *gorm.DB // gorm
RedisCli *redis.Client // redis
)

14
base/starter/banner.go Normal file
View File

@@ -0,0 +1,14 @@
package starter
import "fmt"
func PrintBanner() {
fmt.Print(`
__ _
_ __ ___ __ _ _ _ / _| |_ _ __ _ ___
| '_ ' _ \ / _' | | | | |_| | | | |_____ / _' |/ _ \
| | | | | | (_| | |_| | _| | |_| |_____| (_| | (_) |
|_| |_| |_|\__,_|\__, |_| |_|\__, | \__, |\___/
|___/ |___/ |___/
`)
}

View File

@@ -10,6 +10,10 @@ import (
"gorm.io/gorm/schema"
)
func InitDb() {
global.Db = GormMysql()
}
func GormMysql() *gorm.DB {
m := config.Conf.Mysql
if m == nil || m.Dbname == "" {

View File

@@ -8,11 +8,16 @@ import (
"github.com/go-redis/redis"
)
func InitRedis() {
global.RedisCli = ConnRedis()
}
func ConnRedis() *redis.Client {
// 设置redis客户端
redisConf := config.Conf.Redis
if redisConf == nil {
global.Log.Panic("未找到redis配置信息")
return nil
}
global.Log.Infof("连接redis [%s:%d]", redisConf.Host, redisConf.Port)
rdb := redis.NewClient(&redis.Options{

View File

@@ -1,13 +1,21 @@
package starter
import (
"mayfly-go/base/biz"
"mayfly-go/base/config"
"mayfly-go/base/ctx"
"mayfly-go/base/global"
"github.com/gin-gonic/gin"
"mayfly-go/server/initialize"
)
func RunWebServer(web *gin.Engine) {
func RunWebServer() {
// 权限处理器
ctx.UseBeforeHandlerInterceptor(ctx.PermissionHandler)
// 日志处理器
ctx.UseAfterHandlerInterceptor(ctx.LogHandler)
// 注册路由
web := initialize.InitRouter()
server := config.Conf.Server
port := server.GetPort()
if app := config.Conf.App; app != nil {
@@ -16,9 +24,11 @@ func RunWebServer(web *gin.Engine) {
global.Log.Infof("Listening and serving HTTP on %s", port)
}
var err error
if server.Tls != nil && server.Tls.Enable {
web.RunTLS(port, server.Tls.CertFile, server.Tls.KeyFile)
err = web.RunTLS(port, server.Tls.CertFile, server.Tls.KeyFile)
} else {
web.Run(port)
err = web.Run(port)
}
biz.ErrIsNilAppendErr(err, "服务启动失败: %s")
}