、大家好，我是社区主编彬哥，本篇文章是给大家转载一篇关于连接池的文章。

连接池在编程中并不少见,链接数据库,redis等操作都需要连接池,否则就会出现并发问题,如果每次操作都建立一条新的链接将会大大消耗资源,笔者也是在使用thrift-Clinet链接Service端使用的时候出现了并发问题,然后找到了一个通用的连接池的库在这里分享给大家.

附上:

喵了个咪的博客:w-blog.cn go-commons-pool-Github地址:github.com/jolestar/go-commons-pool

1.连接池

在使用之前我们需要先了解清楚连接池的概念,总结下来连接池主要解决以下几类问题:

  • 减少连接创建时间 与数据库还是Thrift等程序建立连接都是有开销的。如果这类连接是“循环”使用的，使用该方式这些花销就可避免。
  • 简化的编程模式 当使用连接池时，具体的操作都是统一的不用关心初始化等各项关心点
  • 受控的资源使用 如果用户不使用连接池，而是每当需要时创建一个新的连接，那么用户的应用程序的资源使用会产生非常大的浪费并且可能会导致高负载下的异常发生。

2.go-commons-pool 使用

喵咪写了一个demo使用方式如下:

  1. package main
  3. import (
  4. "github.com/jolestar/go-commons-pool"
  5. "fmt"
  6. "time"
  7. )
  9. var pCommonPool *pool.ObjectPool
  11. type PoolTest struct{}
  13. func (this *PoolTest) Test() string {
  14. return "PoolTest"
  15. }
  17. func init() {
  18. // 初始化连接池配置项
  19. PoolConfig := pool.NewDefaultPoolConfig()
  20. // 连接池最大容量设置
  21. PoolConfig.MaxTotal = 1000
  22. WithAbandonedConfig := pool.NewDefaultAbandonedConfig()
  23. // 注册连接池初始化链接方式
  24. pCommonPool = pool.NewObjectPoolWithAbandonedConfig(pool.NewPooledObjectFactorySimple(
  25. func() (interface{}, error) {
  26. return Link()
  27. }), PoolConfig, WithAbandonedConfig)
  28. }
  30. // 初始化链接类
  31. func Link() (*PoolTest, error) {
  32. fmt.Println("初始化PoolTest类!!!")
  33. return &PoolTest{}, nil
  34. }
  36. func main() {
  38. //----------------------------------第一次使用将会调用初始化方法---------------------------------
  39. fmt.Println("第一次使用将会调用初始化方法")
  40. Test()
  42. //----------------------------------第二次使用将会复用初始化好的对象---------------------------------
  43. fmt.Println("第二次使用将会复用初始化好的实例")
  44. Test()
  46. //----------------------------------连续多次并发调用当连接池不够用的会扩充连接池---------------------------
  47. fmt.Println("连续多次并发调用当连接池不够用的会扩充连接池")
  48. go Test()
  49. go Test()
  50. go Test()
  51. go Test()
  52. go Test()
  54. time.Sleep(1 * time.Second)
  55. }
  57. func Test() {
  58. var client *PoolTest
  59. // 从连接池中获取一个实例
  60. obj, _ := pCommonPool.BorrowObject()
  61. // 转换为对应实体
  62. if obj != nil {
  63. client = obj.(*PoolTest)
  64. }
  65. // 调用需要的方法
  66. fmt.Println(client.Test())
  67. // 交还连接池
  68. pCommonPool.ReturnObject(client)
  69. }

输出如下:

第一次使用将会调用初始化方法
初始化PoolTest类!!!PoolTest
第二次使用将会复用初始化好的实例
PoolTest
连续多次并发调用当连接池不够用的会扩充连接池
PoolTest
初始化PoolTest类!!!PoolTest
PoolTest
初始化PoolTest类!!!PoolTest
PoolTest

3 总结

在使用过程中要是有任何问题都可以直接在文章下留言,希望这篇文章可以帮助大家解决眼前的问题,多谢大家的支持!

注:笔者能力有限有说的不对的地方希望大家能够指出,也希望多多交流!