c8ffbedf75
- config: Viper YAML 配置 + 环境变量覆盖 - logs: zap 结构化日志 + trace_id 链路追踪 + 敏感信息脱敏 - db: PostgreSQL (GORM) + Redis (go-redis) 连接管理 - middleware: Trace/Logger/CORS/Recovery 四层中间件 - provider: Wire 编译时依赖注入 - main.go: 优雅启动/关闭 HTTP 服务 Made-with: Cursor
41 lines
890 B
Go
41 lines
890 B
Go
package db
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/echochat/backend/config"
|
|
"github.com/echochat/backend/pkg/logs"
|
|
"github.com/redis/go-redis/v9"
|
|
"go.uber.org/zap"
|
|
)
|
|
|
|
// Redis 全局 Redis 客户端实例
|
|
var Redis *redis.Client
|
|
|
|
// NewRedis 初始化 Redis 客户端连接
|
|
func NewRedis(cfg *config.RedisConfig) (*redis.Client, error) {
|
|
funcName := "db.NewRedis"
|
|
ctx := context.Background()
|
|
|
|
logs.Info(ctx, funcName, "正在连接 Redis",
|
|
zap.String("addr", cfg.Addr()),
|
|
zap.Int("db", cfg.DB),
|
|
)
|
|
|
|
client := redis.NewClient(&redis.Options{
|
|
Addr: cfg.Addr(),
|
|
Password: cfg.Password,
|
|
DB: cfg.DB,
|
|
})
|
|
|
|
if err := client.Ping(ctx).Err(); err != nil {
|
|
logs.Error(ctx, funcName, "Redis 连接失败", zap.Error(err))
|
|
return nil, fmt.Errorf("连接 Redis 失败: %w", err)
|
|
}
|
|
|
|
Redis = client
|
|
logs.Info(ctx, funcName, "Redis 连接成功")
|
|
return client, nil
|
|
}
|