Gin Web 开发脚手架技术文档
项目概述
本项目是一个基于 Gin 框架的 Go Web 开发脚手架模板,提供了完整的项目结构、配置管理、日志记录、MySQL 和 Redis 数据库连接等常用功能集成。
项目结构
gindemo/
├── gindemo.exe # 编译后的可执行文件
├── go.mod # Go 模块定义文件
├── main.go # 应用程序入口点
├── conf/ # 配置文件目录
│ ├── config.yaml # 主配置文件
│ └── dev.yaml # 开发环境配置文件
├── dao/ # 数据访问层
│ ├── mysql/ # MySQL 相关
│ │ └── mysql.go
│ └── redis/ # Redis 相关
│ └── redis.go
├── logger/ # 日志模块
│ └── logger.go
├── router/ # 路由层
│ └── route.go
└── setting/ # 配置管理└── setting.go
配置文件
name: "ginweb"
mode: "release"
port: 8080
version: "v.0.0.1"
start_time: "2025-09-01"
machine_id: 1log:level: "info"filename: "web_app.log"max_size: 200max_age: 30max_backups: 7mysql:host: 127.0.0.1port: 13306dbname: "ginweb"user: "root"password: "root"max_open_conns: 200max_idle_conns: 50redis:host: 127.0.0.1port: 6379password: ""db: 0pool_size: 100
核心模块详解
1. 应用程序入口 (main.go)
package mainimport ("fmt""gindemo/dao/mysql""gindemo/dao/redis""gindemo/logger""gindemo/router""gindemo/setting""os"
)// Go Web 开发通用的脚手架模板
func main() {if len(os.Args) < 2 {fmt.Printf("need config file.eg: conf config.yaml")return}fmt.Println("load config file:", os.Args[1])// 加载配置if err := setting.Init(os.Args[1]); err != nil {fmt.Printf("load config failed, err:%v\n", err)return}//日志if err := logger.Init(setting.Conf.LogConfig, setting.Conf.Mode); err != nil {fmt.Printf("init logger failed, err:%v\n", err)return}// mysqlif err := mysql.Init(setting.Conf.MysqlConfig); err != nil {fmt.Printf("init mysql failed, err:%v\n", err)return}defer mysql.Close()// redisif err := redis.Init(setting.Conf.RedisConfig); err != nil {fmt.Printf("init redis failed, err:%v\n", err)return}defer redis.Close()//注册路由r := router.SetupRouter(setting.Conf.Mode)err := r.Run(fmt.Sprintf(":%d", setting.Conf.Port))if err != nil {fmt.Printf("start server failed, err:%v\n", err)return}
}
功能特点:
- 命令行参数验证,要求指定配置文件路径
- 模块化初始化流程:配置 → 日志 → MySQL → Redis → 路由
- 完善的错误处理和资源清理(defer 关闭数据库连接)
2. 配置管理模块 (setting.go)
package settingimport ("fmt""github.com/fsnotify/fsnotify""github.com/spf13/viper"
)type AppConfig struct {Name string `mapstructure:"name,omitempty"`Mode string `mapstructure:"mode,omitempty"`Version string `mapstructure:"version,omitempty"`StartTime string `mapstructure:"start_time,omitempty"`machineId string `mapstructure:"machine_id,omitempty"`Port int `mapstructure:"port,omitempty"`*LogConfig `mapstructure:"log,omitempty"`*MysqlConfig `mapstructure:"mysql,omitempty"`*RedisConfig `mapstructure:"redis,omitempty"`
}type LogConfig struct {Level string `mapstructure:"level,omitempty"`Filename string `mapstructure:"filename,omitempty"`MaxSize int `mapstructure:"max_size,omitempty"`MaxAge int `mapstructure:"max_age,omitempty"`MaxBackups int `mapstructure:"max_backups,omitempty"`
}
type MysqlConfig struct {Host string `mapstructure:"host,omitempty"`Port int `mapstructure:"port,omitempty"`DB string `mapstructure:"dbname,omitempty"`User string `mapstructure:"user,omitempty"`Password string `mapstructure:"password,omitempty"`MaxOpenConns int `mapstructure:"max_open_conns,omitempty"`MaxIdleConns int `mapstructure:"max_idle_conns,omitempty"`
}type RedisConfig struct {Host string `mapstructure:"host,omitempty"`Port int `mapstructure:"port,omitempty"`Password string `mapstructure:"password,omitempty"`DB int `mapstructure:"db,omitempty"`PoolSize int `mapstructure:"pool_size,omitempty"`MinIdleConns int `mapstructure:"min_idle_conns,omitempty"`
}var Conf = new(AppConfig)func Init(filePath string) (err error) {viper.SetConfigFile(filePath)//读取配置信息err = viper.ReadInConfig()if err != nil {fmt.Printf("viper.ReadInConfig() failed, err:%v\n", err)return}//把读取到的配置信息反序列化到 Conf 变量中if err := viper.Unmarshal(Conf); err != nil {fmt.Printf("viper.Unmarshal() failed, err:%v\n", err)}viper.WatchConfig()viper.OnConfigChange(func(e fsnotify.Event) {fmt.Printf("Config file changed, filename:%s\n", e.Name)if err2 := viper.Unmarshal(Conf); err2 != nil {fmt.Printf("viper.Unmarshal() failed, err:%v\n", err2)}})return
}
功能特点:
- 使用 viper 库实现 YAML 配置文件的读取和解析
- 支持配置热加载,文件变更时自动重新加载配置
- 结构化的配置定义,类型安全
3. 日志模块 (logger.go)
package loggerimport ("gindemo/setting""net""net/http""net/http/httputil""os""runtime/debug""strings""time""github.com/gin-gonic/gin""go.uber.org/zap""go.uber.org/zap/zapcore""gopkg.in/natefinch/lumberjack.v2"
)var lg *zap.Logger// Init 初始化lg
func Init(cfg *setting.LogConfig, mode string) (err error) {writeSyncer := getLogWriter(cfg.Filename, cfg.MaxSize, cfg.MaxBackups, cfg.MaxAge)encoder := getEncoder()var l = new(zapcore.Level)err = l.UnmarshalText([]byte(cfg.Level))if err != nil {return}var core zapcore.Coreif mode == "dev" {// 进入开发模式,日志输出到终端consoleEncoder := zapcore.NewConsoleEncoder(zap.NewDevelopmentEncoderConfig())core = zapcore.NewTee(zapcore.NewCore(encoder, writeSyncer, l),zapcore.NewCore(consoleEncoder, zapcore.Lock(os.Stdout), zapcore.DebugLevel),)} else {core = zapcore.NewCore(encoder, writeSyncer, l)}lg = zap.New(core, zap.AddCaller())zap.ReplaceGlobals(lg)zap.L().Info("init logger success")return
}func getEncoder() zapcore.Encoder {encoderConfig := zap.NewProductionEncoderConfig()encoderConfig.EncodeTime = zapcore.ISO8601TimeEncoderencoderConfig.TimeKey = "time"encoderConfig.EncodeLevel = zapcore.CapitalLevelEncoderencoderConfig.EncodeDuration = zapcore.SecondsDurationEncoderencoderConfig.EncodeCaller = zapcore.ShortCallerEncoderreturn zapcore.NewJSONEncoder(encoderConfig)
}func getLogWriter(filename string, maxSize, maxBackup, maxAge int) zapcore.WriteSyncer {lumberJackLogger := &lumberjack.Logger{Filename: filename,MaxSize: maxSize,MaxBackups: maxBackup,MaxAge: maxAge,}return zapcore.AddSync(lumberJackLogger)
}// GinLogger 接收gin框架默认的日志
func GinLogger() gin.HandlerFunc {return func(c *gin.Context) {start := time.Now()path := c.Request.URL.Pathquery := c.Request.URL.RawQueryc.Next()cost := time.Since(start)lg.Info(path,zap.Int("status", c.Writer.Status()),zap.String("method", c.Request.Method),zap.String("path", path),zap.String("query", query),zap.String("ip", c.ClientIP()),zap.String("user-agent", c.Request.UserAgent()),zap.String("errors", c.Errors.ByType(gin.ErrorTypePrivate).String()),zap.Duration("cost", cost),)}
}// GinRecovery recover掉项目可能出现的panic,并使用zap记录相关日志
func GinRecovery(stack bool) gin.HandlerFunc {return func(c *gin.Context) {defer func() {if err := recover(); err != nil {// Check for a broken connection, as it is not really a// condition that warrants a panic stack trace.var brokenPipe boolif ne, ok := err.(*net.OpError); ok {if se, ok := ne.Err.(*os.SyscallError); ok {if strings.Contains(strings.ToLower(se.Error()), "broken pipe") || strings.Contains(strings.ToLower(se.Error()), "connection reset by peer") {brokenPipe = true}}}httpRequest, _ := httputil.DumpRequest(c.Request, false)if brokenPipe {lg.Error(c.Request.URL.Path,zap.Any("error", err),zap.String("request", string(httpRequest)),)// If the connection is dead, we can't write a status to it.c.Error(err.(error)) // nolint: errcheckc.Abort()return}if stack {lg.Error("[Recovery from panic]",zap.Any("error", err),zap.String("request", string(httpRequest)),zap.String("stack", string(debug.Stack())),)} else {lg.Error("[Recovery from panic]",zap.Any("error", err),zap.String("request", string(httpRequest)),)}c.AbortWithStatus(http.StatusInternalServerError)}}()c.Next()}
}
功能特点:
- 基于 zap 高性能日志库
- 支持日志轮转(lumberjack)
- 开发模式同时输出到文件和控制台
- 提供 Gin 框架的日志中间件和异常恢复处理
- 智能处理 broken pipe 等连接异常
4. MySQL 数据访问模块 (mysql.go)
package mysqlimport ("fmt""gindemo/setting"_ "github.com/go-sql-driver/mysql""github.com/jmoiron/sqlx"
)var db *sqlx.DBfunc Init(cfg *setting.MysqlConfig) (err error) {dsn := fmt.Sprintf("%s:%s@tcp(%s:%d)/%s?parseTime=true&loc=Local", cfg.User, cfg.Password, cfg.Host, cfg.Port, cfg.DB)db, err = sqlx.Connect("mysql", dsn)if err != nil {return}db.SetMaxIdleConns(cfg.MaxIdleConns)db.SetMaxOpenConns(cfg.MaxOpenConns)return
}func Close() {_ = db.Close()
}
功能特点:
- 使用 sqlx 增强的 MySQL 驱动
- 支持连接池配置
- 自动处理时区问题(loc=Local)
5. Redis 数据访问模块 (redis.go)
package redisimport ("fmt""gindemo/setting""github.com/go-redis/redis"
)var (client *redis.ClientNil = redis.Nil
)func Init(cfg *setting.RedisConfig) (err error) {client = redis.NewClient(&redis.Options{Addr: fmt.Sprintf("%s:%d", cfg.Host, cfg.Port),Password: cfg.Password,DB: cfg.DB,PoolSize: cfg.PoolSize,MinIdleConns: cfg.MinIdleConns,})_, err = client.Ping().Result()if err != nil {return err}return nil
}func Close() {_ = client.Close()
}
功能特点:
- 使用 go-redis 客户端库
- 支持连接池配置
- 导出 Nil 错误常量便于处理键不存在的情况
6. 路由管理模块 (route.go)
package routerimport ("gindemo/logger""net/http""github.com/gin-gonic/gin"
)func SetupRouter(mode string) *gin.Engine {if mode == gin.ReleaseMode {// gin 设置成发布模式gin.SetMode(gin.ReleaseMode)}router := gin.New()router.Use(logger.GinLogger(), logger.GinRecovery(true))router.GET("/ping", func(c *gin.Context) {c.String(http.StatusOK, "pong")})return router
}
功能特点:
- 根据运行模式自动设置 Gin 模式
- 集成 zap 日志中间件和异常恢复
- 提供健康检查端点 /ping
启动和运行
编译项目
go build -o gindemo.exe main.go
运行项目
./gindemo.exe conf/config.yaml
测试服务
curl http://localhost:8080/ping
配置说明
应用配置
name
: 应用名称mode
: 运行模式(debug/release/test)port
: HTTP 服务监听端口version
: 应用版本号start_time
: 启动时间标识machine_id
: 机器标识,用于分布式部署
日志配置
level
: 日志级别(debug/info/warn/error)filename
: 日志文件名max_size
: 单个日志文件最大大小(MB)max_age
: 日志保留天数max_backups
: 最大备份文件数
MySQL 配置
- 连接参数:主机、端口、数据库名、用户名、密码
- 连接池:最大打开连接数、最大空闲连接数
Redis 配置
- 连接参数:主机、端口、密码、数据库编号
- 连接池:连接池大小、最小空闲连接数
扩展开发指南
添加新的配置项
- 在
setting.go
的对应配置结构体中添加字段 - 在配置文件中添加相应的配置项
- 在需要使用的地方通过
setting.Conf
访问
添加新的路由
在 router.go
的 SetupRouter
函数中添加新的路由定义:
router.GET("/new-endpoint", func(c *gin.Context) {// 处理逻辑
})
添加业务模块
- 创建新的包目录
- 实现相关功能
- 在
main.go
中初始化和集成
总结
这个 Gin Web 开发脚手架提供了一个结构清晰、功能完整的起点,具有以下特点:
- 模块化设计:各功能模块职责清晰,便于维护和扩展
- 配置驱动:所有可变参数都通过配置文件管理
- 生产就绪:包含日志、监控、异常处理等生产环境必需功能
- 高性能:基于 Gin 和 zap 等高性能库
- 易于扩展:清晰的架构便于添加新功能
该项目适合作为中小型 Web 服务的开发基础,可根据具体需求进行进一步定制和扩展。