Golang 实现的连接池
- 连接池中连接类型为
interface{}，使得更加通用 - 连接的最大空闲时间，超时的连接将关闭丢弃，可避免空闲时连接自动失效问题
- 支持用户设定 ping 方法，检查连接的连通性，无效的连接将丢弃
- 使用channel处理池中的连接，高效
//factory 创建连接的方法
factory := func() (interface{}, error) { return net.Dial("tcp", "127.0.0.1:4000") }
//close 关闭连接的方法
close := func(v interface{}) error { return v.(net.Conn).Close() }
//ping 检测连接的方法
//ping := func(v interface{}) error { return nil }
//创建一个连接池： 初始化5，最大连接30
poolConfig := &pool.PoolConfig{
InitialCap: 5,
MaxCap: 30,
Factory: factory,
Close: close,
//Ping: ping,
//连接最大空闲时间，超过该时间的连接 将会关闭，可避免空闲时连接EOF，自动失效的问题
IdleTimeout: 15 * time.Second,
}
p, err := pool.NewChannelPool(poolConfig)
if err != nil {
fmt.Println("err=", err)
}
//从连接池中取得一个连接
v, err := p.Get()
//do something
//conn=v.(net.Conn)
//将连接放回连接池中
p.Put(v)
//释放连接池中的所有连接
p.Release()
//查看当前连接中的数量
current := p.Len()
该连接池参考 https://github.com/fatih/pool 实现，改变以及增加原有的一些功能。
The MIT License (MIT) - see LICENSE for more details