go语言操作redis连接池的方法

本文实例讲述了go语言操作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)

    ...

}

希望本文所述对大家的Go语言程序设计有所帮助。