讓我們先從pool的數(shù)據(jù)結(jié)構(gòu)說起:
Dial:是必須要實現(xiàn)的神得,就是調(diào)用普通的的redis.Dial即可负拟。
TestOnBorrow:在獲取conn的時候會調(diào)用一次這個方法抓歼,來保證連接可用(其實也不是一定可用钞螟,因為test成功以后依然有可能被干掉)舟山,這個方法是可選項绸狐,一般這個方法是去調(diào)用一個redis的ping方法,看項目需求了累盗,如果并發(fā)很高寒矿,想極限提高速度,這個可以不設(shè)置若债。如果想增加點連接可用性符相,還是加上比較好〈懒眨看個人取舍了啊终。
MaxIdle镜豹,idle,IdleTimeout:都是idle相關(guān)設(shè)置蓝牲,MaxIdle決定idle的列表長度趟脂,IdleTimeout決定了idle列表中conn的生命周期,默認(rèn)為0搞旭,即lifetime散怖,如果設(shè)置了idleTimeout的話,在獲取conn的時候會檢查idle隊列中的連接肄渗,把超時的連接關(guān)閉掉镇眷。
MaxActive:線程池的最大連接數(shù)。線程池都是優(yōu)先復(fù)用已有的連接翎嫡,但是不可避免總是會有新建連接的時候欠动,那么這個值就是限定了連接數(shù)的上限。
Wait:當(dāng)連接數(shù)已滿惑申,是否要阻塞等待獲取連接具伍。false表示不等待,直接返回錯誤圈驼。
下面我們分析一下核心的獲取連接的方法
// get prunes stale connections and returns a connection from the idle list or
// creates a new connection.
func (p *Pool) get() (Conn, error) {
p.mu.Lock()
// Prune stale connections.
//檢查超時的連接人芽,如果超時,則從idle隊列中移除
if timeout := p.IdleTimeout; timeout > 0 {
for i, n := 0, p.idle.Len(); i < n; i++ {
e := p.idle.Back()
if e == nil {
break
}
ic := e.Value.(idleConn)
if ic.t.Add(timeout).After(nowFunc()) {
break
}
p.idle.Remove(e)
p.release()
p.mu.Unlock()
ic.c.Close()
p.mu.Lock()
}
}
for {
// Get idle connection.
//從idle隊列中復(fù)用已有的連接
for i, n := 0, p.idle.Len(); i < n; i++ {
e := p.idle.Front()
if e == nil {
break
}
ic := e.Value.(idleConn)
p.idle.Remove(e)
test := p.TestOnBorrow
p.mu.Unlock()
if test == nil || test(ic.c, ic.t) == nil {
return ic.c, nil
}
ic.c.Close()
p.mu.Lock()
p.release()
}
// Check for pool closed before dialing a new connection.
if p.closed {
p.mu.Unlock()
return nil, errors.New("redigo: get on closed pool")
}
// Dial new connection if under limit.
//還沒達到最大連接數(shù)绩脆,idle中又沒有可用的連接萤厅,那么就new一個連接出來
if p.MaxActive == 0 || p.active < p.MaxActive {
dial := p.Dial
p.active += 1
p.mu.Unlock()
c, err := dial()
if err != nil {
p.mu.Lock()
p.release()
p.mu.Unlock()
c = nil
}
return c, err
}
if !p.Wait {
p.mu.Unlock()
return nil, ErrPoolExhausted
}
if p.cond == nil {
p.cond = sync.NewCond(&p.mu)
}
p.cond.Wait()
}
}
綜上可知,想提高redis的處理速度靴迫,可以把idle設(shè)置的大一點惕味,當(dāng)然active的值是一定要比idle大的(0表示不限制)。這里還有一點需要注意的redis本身支持的連接數(shù)設(shè)置問題玉锌,剛才分析的都是client端的情況名挥,如果server只支持100的連接數(shù),那客戶端的pool設(shè)定再多也沒有用主守,redis的連接數(shù)配置又是另外一個話題禀倔,這里就不展開講。