Golang如何实现连接池的方法-创新互联

Golang如何实现连接池的方法?这个问题可能是我们日常学习或工作经常见到的。希望通过这个问题能让你收获颇深。下面是小编给大家带来的参考内容,让我们一起来看看吧!

创新互联建站网站建设提供从项目策划、软件开发,软件安全维护、网站优化(SEO)、网站分析、效果评估等整套的建站服务,主营业务为网站设计制作、成都网站设计,成都app软件开发公司以传统方式定制建设网站,并提供域名空间备案等一条龙服务,秉承以专业、用心的态度为用户提供真诚的服务。创新互联建站深信只要达到每一位用户的要求,就会得到认可,从而选择与我们长期合作。这样,我们也可以走得更远!

问题引入

作为一名Golang开发者,线上环境遇到过好几次连接数暴增问题(mysql/redis/kafka等)。

纠其原因,Golang作为常驻进程,请求第三方服务或者资源完毕后,需要手动关闭连接,否则连接会一直存在。而很多时候,开发者不一定记得关闭这个连接。

这样是不是很麻烦?于是有了连接池。顾名思义,连接池就是管理连接的;我们从连接池获取连接,请求完毕后再将连接还给连接池;连接池帮我们做了连接的建立、复用以及回收工作。

在设计与实现连接池时,我们通常需要考虑以下几个问题:

  • 连接池的连接数目是否有限制,大可以建立多少个连接?
  • 当连接长时间没有使用,需要回收该连接吗?
  • 业务请求需要获取连接时,此时若连接池无空闲连接且无法新建连接,业务需要排队等待吗?
  • 排队的话又存在另外的问题,队列长度有无限制,排队时间呢?

Golang连接池实现原理

我们以Golang HTTP连接池为例,分析连接池的实现原理。

结构体Transport

Transport结构定义如下:

type Transport struct {
  //操作空闲连接需要获取锁
  idleMu    sync.Mutex
  //空闲连接池,key为协议目标地址等组合
  idleConn   map[connectMethodKey][]*persistConn // most recently used at end
  //等待空闲连接的队列,基于切片实现,队列大小无限制
  idleConnWait map[connectMethodKey]wantConnQueue // waiting getConns
  
  //排队等待建立连接需要获取锁
  connsPerHostMu  sync.Mutex
  //每个host建立的连接数
  connsPerHost   map[connectMethodKey]int
  //等待建立连接的队列,同样基于切片实现,队列大小无限制
  connsPerHostWait map[connectMethodKey]wantConnQueue // waiting getConns
  
  //大空闲连接数
  MaxIdleConns int
  //每个目标host大空闲连接数;默认为2(注意默认值)
  MaxIdleConnsPerHost int
  //每个host可建立的大连接数
  MaxConnsPerHost int
  //连接多少时间没有使用则被关闭
  IdleConnTimeout time.Duration
  
  //禁用长连接,使用短连接
  DisableKeepAlives bool
}

当前名称:Golang如何实现连接池的方法-创新互联
文章地址:http://pwwzsj.com/article/dpsgjp.html