Go应用中如何设计管理DB与Redis连接的ProductService服务层

阿华AIGC实验室

2026-5-19

Go小应用原型：ProductService结构与连接管理建议

嘿，针对你做Go小应用原型的需求，我来分享下关于ProductService结构和连接管理的实用建议～

一、ProductService的合理结构

咱们完全不需要用全局变量来传递数据库和Redis连接，依赖注入才是更优雅的方案。简单来说，就是把数据库（sql.DB）和Redis客户端（比如redis.Client）作为参数传给ProductService的构造函数，让服务层明确持有自己需要的资源。

举个具体的代码例子：

import (
    "context"
    "database/sql"
    "fmt"
    "time"

    "github.com/go-redis/redis/v8"
)

// Product 定义产品实体
type Product struct {
    ID    int64   `json:"id"`
    Name  string  `json:"name"`
    Price float64 `json:"price"`
}

// ProductService 封装所有产品相关业务逻辑的服务层
type ProductService struct {
    db  *sql.DB          // 数据库连接实例
    rdb *redis.Client    // Redis客户端实例
}

// NewProductService ProductService的构造函数，接收依赖的连接对象
func NewProductService(db *sql.DB, rdb *redis.Client) *ProductService {
    return &ProductService{
        db:  db,
        rdb: rdb,
    }
}

// GetProductByID 示例方法：从缓存或数据库获取产品详情
func (s *ProductService) GetProductByID(id int64) (*Product, error) {
    // 先尝试从Redis缓存读取
    cacheKey := fmt.Sprintf("product:%d", id)
    var product Product
    err := s.rdb.Get(context.Background(), cacheKey).Scan(&product)
    if err == nil {
        return &product, nil
    }

    // 缓存未命中，回源数据库查询
    err = s.db.QueryRow("SELECT id, name, price FROM products WHERE id = ?", id).
        Scan(&product.ID, &product.Name, &product.Price)
    if err != nil {
        return nil, err
    }

    // 将查询结果写入Redis，设置1小时过期时间
    _, err = s.rdb.Set(context.Background(), cacheKey, &product, 1*time.Hour).Result()
    return &product, err
}

这个结构的优势很明显：

依赖关系一目了然，别人看代码就能知道ProductService需要哪些资源
单元测试时可以轻松传入mock的数据库/Redis客户端，不用依赖真实的存储服务
耦合度低，后续如果要替换数据库或Redis的实现，只需要修改构造函数的参数即可

二、关于全局变量/单例的误区

我非常不推荐用全局变量来管理数据库和Redis连接，原因有几个：

耦合度太高：其他模块直接依赖全局变量，后续要修改或替换连接时，会牵扯到大量代码
初始化风险：全局变量的初始化顺序不好控制，容易出现“未初始化就使用”的panic
扩展性差：如果以后要支持多数据库实例或Redis集群，全局变量的方式会变得极其麻烦

那正确的姿势是什么？在应用启动阶段统一初始化连接，然后把它们注入到需要的服务中就行。比如main函数里的写法：

import (
    "context"
    "database/sql"
    "log"

    _ "github.com/go-sql-driver/mysql"
    "github.com/go-redis/redis/v8"
)

func main() {
    // 1. 初始化数据库连接（这里以MySQL为例）
    db, err := sql.Open("mysql", "user:password@tcp(localhost:3306)/your_db")
    if err != nil {
        log.Fatalf("数据库连接失败: %v", err)
    }
    // 别忘了验证连接是否有效
    if err = db.Ping(); err != nil {
        log.Fatalf("数据库ping失败: %v", err)
    }
    defer db.Close()

    // 2. 初始化Redis客户端
    rdb := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379",
        Password: "", // 根据你的Redis配置修改
        DB:       0,
    })
    if err = rdb.Ping(context.Background()).Err(); err != nil {
        log.Fatalf("Redis连接失败: %v", err)
    }
    defer rdb.Close()

    // 3. 创建ProductService实例，传入依赖的连接
    productService := NewProductService(db, rdb)

    // 接下来就可以把productService传给路由处理函数、其他服务等
    // 比如用Gin框架的话，你可以把它挂载到上下文或者直接传入处理函数
}

另外要注意：sql.DB和redis.Client本身就是连接池，初始化一次之后就可以在整个应用中复用，不需要额外做单例——它们内部已经帮你管理了连接的创建、复用和销毁。