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() //关闭连接池
}
转藏 分享
QQ空间 QQ好友 新浪微博 微信
献花(0) +1

来自: >