golang操作redis连接池

func newPool(server,password string) *redis.Pool {
    return &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,err
        },TestOnBorrow: func(c redis.Conn,t time.Time) error {
            _,err := c.Do("PING")
            return err
        },}
}
var (
    pool *redis.Pool
    redisServer = flag.String("redisServer",":6379","")
    redisPassword = flag.String("redisPassword","","")
)

func main() {
    flag.Parse()
    pool = newPool(*redisServer,*redisPassword)
    ...
}

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!