网上大家好多连接池没有wait这个参数,在连接池链接数达到上限时会报错,影响程序的正常执行,这是不应该的,正常的应该添加这个参数并设置值为true,这样即使链接被用完,会阻塞等待其他协程用完归还之后继续执行:
//初始化一个pool
func NewRedisPool(server, password string) *redis.Pool {
return &redis.Pool{
MaxIdle: 30,
MaxActive: 1000,
IdleTimeout: 240 * time.Second,
Wait: true,
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, err
},
TestOnBorrow: func(c redis.Conn, t time.Time) error {
if time.Since(t) < time.Minute {
return nil
}
_, err := c.Do("PING")
return err
},
}
}
另外就是在使用连接池的过程中,动作执行完毕,及时的归还资源,防止资源被浪费。如果因为资源没有归还,而又达到了最大连接数,而且连接池的wait参数值为true,那么程序将被永远的阻塞: