
本文介绍如何使用 redigo 的 redis.pool 在多个 http 路由间复用 redis 连接,避免重复拨号与认证,同时保证并发安全与资源可控。
本文介绍如何使用 redigo 的 redis.pool 在多个 http 路由间复用 redis 连接,避免重复拨号与认证,同时保证并发安全与资源可控。
在 Go Web 开发中,若每个 HTTP 处理函数(如 Gin 或 net/http 的 handler)都独立调用 redis.Dial() 并执行 AUTH,不仅造成大量 TCP 连接开销,还会因连接未复用而显著降低性能,更严重的是——裸连接不具备并发安全性:redigo.Conn 实例不可被多个 goroutine 同时读写,直接跨路由共享单个连接将引发竞态甚至 panic。
正确解法是使用连接池(redis.Pool),它能自动管理连接的创建、复用、回收与超时释放。关键在于:所有初始化逻辑(包括网络拨号与身份认证)应封装在 Pool.Dial 回调中,而非全局变量声明里——因为 Go 不允许在包级作用域执行函数调用(如 redis.Dial),var 块仅用于声明,不能运行语句。
以下是推荐的初始化方式,放在 init() 函数中确保应用启动时完成配置:
import (
"time"
"github.com/garyburd/redigo/redis"
)
var redisPool *redis.Pool
const (
server = "localhost:6379"
password = "testing"
)
func init() {
redisPool = &redis.Pool{
MaxIdle: 3, // 最大空闲连接数
IdleTimeout: 240 * time.Second, // 空闲连接最大存活时间
Dial: func() (redis.Conn, error) {
c, err := redis.Dial("tcp", server)
if err != nil {
return nil, err
}
// 认证失败时务必关闭连接,防止泄露
if _, err := c.Do("AUTH", password); err != nil {
c.Close()
return nil, err
}
return c, nil
},
}
}在任意路由处理函数中,只需按需获取并归还连接:
func handleUserGet(w http.ResponseWriter, r *http.Request) {
conn := redisPool.Get()
defer conn.Close() // 注意:Close() 是归还至池,非销毁连接
// 检查连接是否健康(如网络中断、认证失效等)
if err := conn.Err(); err != nil {
http.Error(w, "Redis connection error: "+err.Error(), http.StatusInternalServerError)
return
}
// 执行业务操作,例如获取用户信息
data, err := redis.String(conn.Do("GET", "user:123"))
if err != nil && err != redis.ErrNil {
http.Error(w, "Redis GET failed: "+err.Error(), http.StatusInternalServerError)
return
}
w.Header().Set("Content-Type", "application/json")
json.NewEncoder(w).Encode(map[string]string{"data": data})
}⚠️ 重要注意事项:
- ✅ 始终调用 conn.Close() 归还连接(不是 conn.Quit()),否则连接将永久泄漏;
- ✅ 务必检查 conn.Err() —— 它捕获的是连接建立或认证阶段的错误,应在任何 Do() 调用前验证;
- ✅ 避免在 handler 中长期持有连接(如循环中反复 Do 而不释放),应尽量缩短 Get() 到 Close() 的作用域;
- ✅ 根据实际负载调整 MaxIdle 和 MaxActive(后者需显式设置,未设则无上限),防止连接数失控;
- ✅ 若使用 Redis Sentinel 或集群,请改用支持高可用的客户端(如 github.com/go-redis/redis/v8),redigo 原生不支持自动故障转移。
通过连接池模式,你既消除了重复拨号与认证的冗余逻辑,又获得了线程安全、资源可控、可监控的 Redis 访问能力——这是构建高性能 Go Web 服务的基础设施实践之一。











