redigo连接池——redigo: connection pool exhausted

网上大家好多连接池没有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,那么程序将被永远的阻塞:

redigo连接池——redigo: connection pool exhausted

上一篇:【AT2645】Exhausted?


下一篇:php遇到Allowed memory size of 134217728 bytes exhausted问题解决方法