基于golang实现的redis连接池
代码篇:
package mainimport ( "fmt" "github.com/garyburd/redigo/redis")var pool *redis.Pool //创建redis连接池func init() { pool = &redis.Pool{ //实例化一个连接池 MaxIdle:16, //最初的连接数量 // MaxActive:1000000, //最大连接数量 MaxActive:0, //连接池最大连接数量,不确定可以用0(0表示自动定义),按需分配 IdleTimeout:300, //连接关闭时间 300秒 (300秒不使用自动关闭) Dial: func() (redis.Conn ,error){ //要连接的redis数据库 return redis.Dial("tcp","localhost:6379") }, }}func main() { c := pool.Get() //从连接池,取一个链接 defer c.Close() //函数运行结束 ,把连接放回连接池 _,err := c.Do("Set","abc",200) if err != nil { fmt.Println(err) return } r,err := redis.Int(c.Do("Get","abc")) if err != nil { fmt.Println("get abc faild :",err) return } fmt.Println(r) pool.Close() //关闭连接池 }
赞 (0)