1. Redis连接池

  1. package main
  2. import(
  3.     "fmt"
  4.     "github.com/garyburd/redigo/redis"
  5. )
  7. var pool *redis.Pool  //创建redis连接池
  9. func init(){
  10.     pool = &redis.Pool{     //实例化一个连接池
  11.         MaxIdle:16,    //最初的连接数量
  12.         // MaxActive:1000000,    //最大连接数量
  13.         MaxActive:0,    //连接池最大连接数量,不确定可以用0（0表示自动定义），按需分配
  14.         IdleTimeout:300,    //连接关闭时间 300秒 （300秒不使用自动关闭）    
  15.         Dial: func() (redis.Conn ,error){     //要连接的redis数据库
  16.             return redis.Dial("tcp","localhost:6379")
  17.         },
  18.     }
  19. }
  21. func main(){
  22.     c := pool.Get() //从连接池，取一个链接
  23.     defer c.Close() //函数运行结束 ，把连接放回连接池
  25.         _,err := c.Do("Set","abc",200)
  26.         if err != nil {
  27.             fmt.Println(err)
  28.             return
  29.         }
  31.         r,err := redis.Int(c.Do("Get","abc"))
  32.         if err != nil {
  33.             fmt.Println("get abc faild :",err)
  34.             return
  35.         }
  36.         fmt.Println(r)
  37.         pool.Close() //关闭连接池
  38. }

运行结果：

  1.     200

Redis命令行：

  1.     127.0.0.1:6379> get abc
  2.     "200"