分享
Golang 通用连接池库 Golang-Pool
zhangboyu · · 4296 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
Golang 实现的连接池
功能:
* 连接池中连接类型为interface{},使得更加通用
* 链接的最大空闲时间,超时的链接将关闭丢弃,可避免空闲时链接自动失效问题
* 使用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() } //创建一个连接池: 初始化5,最大链接30 poolConfig := &pool.PoolConfig{ InitialCap: 5, MaxCap: 30, Factory: factory, Close: close, //链接最大空闲时间,超过该时间的链接 将会关闭,可避免空闲时链接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/silenceper/pool
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信4296 次点击
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
Golang 实现的连接池
功能:
* 连接池中连接类型为interface{},使得更加通用
* 链接的最大空闲时间,超时的链接将关闭丢弃,可避免空闲时链接自动失效问题
* 使用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() } //创建一个连接池: 初始化5,最大链接30 poolConfig := &pool.PoolConfig{ InitialCap: 5, MaxCap: 30, Factory: factory, Close: close, //链接最大空闲时间,超过该时间的链接 将会关闭,可避免空闲时链接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/silenceper/pool