8.Redis连接池
最后更新于：2022-04-02 04:51:27
~~~
package main
import(
"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() //关闭连接池
}
~~~
运行结果：
~~~
200
~~~
Redis命令行：
~~~
127.0.0.1:6379> get abc
"200"
~~~
';