什么是連接池
連接池是創(chuàng)建和管理一個(gè)連接的緩沖池的技術(shù),這些連接準(zhǔn)備好被任何需要它們的線程使用。
簡(jiǎn)單來(lái)說(shuō),就是創(chuàng)建一個(gè)容器,并且把資源提前準(zhǔn)備好放在里面,比如我們常用的redis連接、mysql連接。
連接池的優(yōu)點(diǎn)
計(jì)算機(jī)是由許多零件組裝而成,比如CPU、內(nèi)存、硬盤(pán)等等。
當(dāng)我們進(jìn)行網(wǎng)絡(luò)連接、請(qǐng)求的時(shí)候,就需要在不同組件中傳遞和返回各種信號(hào)、數(shù)據(jù)
比如在CPU、內(nèi)存、網(wǎng)卡中,數(shù)據(jù)的傳遞,請(qǐng)求,獲取。
如果在短時(shí)間內(nèi)進(jìn)行一萬(wàn)次mysql的連接,就需要在這個(gè)往返過(guò)程循環(huán),在路上浪費(fèi)了很多時(shí)間、性能消耗。
如果我們先把連接連接好,并且放在連接池中,程序中需要使用就從池中獲取,執(zhí)行操作。
就省去了反復(fù)創(chuàng)建連接、斷開(kāi)連接的操作。
可以減少I/O操作,提高資源利用率。
連接池?cái)?shù)量如何設(shè)置
那么一個(gè)池需要設(shè)置多少數(shù)量比較合適呢?是不是越多越好?
連接數(shù)量需要根據(jù)并發(fā)數(shù),以及數(shù)據(jù)庫(kù)的處理情況來(lái)決定的,
比如你的數(shù)據(jù)庫(kù)最大只能處理500個(gè)連接,那你設(shè)置700個(gè),數(shù)據(jù)庫(kù)照樣處理不過(guò)來(lái),設(shè)置過(guò)多并沒(méi)有什么用處,反而可能會(huì)讓數(shù)據(jù)庫(kù)宕機(jī)
所以,一般情況下,連接池總數(shù)設(shè)置為100-200左右就夠了(相當(dāng)于200的并發(fā))
這里的連接池?cái)?shù)量,說(shuō)的是總數(shù)量,在easyswoole中,需要根據(jù)進(jìn)程來(lái)看,每個(gè)進(jìn)程*連接池配置數(shù)量=總數(shù)量,比如easyswoole中worker進(jìn)程為8,那你設(shè)置20個(gè),那就是20*8=160的總數(shù)
easyswoole中為什么會(huì)pool empty
這個(gè)問(wèn)題有好幾個(gè)可能性。
- 連接信息錯(cuò)誤,導(dǎo)致一個(gè)資源都沒(méi)有
- 程序有問(wèn)題,把資源拿出去,沒(méi)有歸還到池內(nèi),后續(xù)就拿到空了
- 并發(fā)高,池的數(shù)量少,需要檢查資源占用率,如果占用率沒(méi)問(wèn)題,則提高池內(nèi)的數(shù)量
連接錯(cuò)誤
如果我們的mysql配置信息錯(cuò)誤,在easyswoole框架啟動(dòng)之后,就會(huì)去初始化連接池。
此時(shí)一直連接失敗,也就沒(méi)有產(chǎn)生資源,也沒(méi)有將資源放在池內(nèi)
當(dāng)你在后續(xù)程序獲取池內(nèi)資源的時(shí)候。自然就報(bào)了空池的錯(cuò)誤提示。
程序問(wèn)題
先來(lái)一個(gè)連接池的偽代碼
<?php
class Pool{
public static function getIn(){
// 單例模式
}
/**
* 初始化
*/
public function init()
{
// pool準(zhǔn)備好就填充指定的資源 比如10個(gè)連接
$this->pool = $array;
}
public function get(){
return array_pop($this->pool);
}
public function push($obj)
{
$this->pool[] = $obj;
}
}
如果我們的程序有這樣子的使用場(chǎng)景
<?php
$db = Pool::getIn()->get();
$res = $db->query('sql語(yǔ)句');
然后沒(méi)有進(jìn)行push 歸還操作,那么池內(nèi)資源一旦拿完,就沒(méi)有資源可用了。
在easyswoole框架中,有提供以下方法獲取資源(以mysql-pool為例)
$db = MysqlPool::defer();
$db->rawQuery('select version()');
$data = MysqlPool::invoker(function (MysqlConnection $db){
return $db->rawQuery('select version()');
});
$db = PoolManager::getInstance()->getPool(MysqlPool::class)->getObj();
$data = $db->get('test');
//使用完畢需要回收
PoolManager::getInstance()->getPool(MysqlPool::class)->recycleObj($db);
defer方法將會(huì)在本次請(qǐng)求協(xié)程退出的時(shí)候自動(dòng)回收
invoker是閉包函數(shù)方式 一次運(yùn)行完馬上自動(dòng)回收
get方式 就是我們偽代碼的方式 需要自己回收 使用這種方式就需要特別注意啦~!!!
兩種自動(dòng)回收方式怎么選擇 請(qǐng)接著往下看!
并發(fā)高 資源占用率
上面說(shuō)到兩種自動(dòng)回收資源的方式,defer和invoker
首先我們來(lái)看一個(gè)點(diǎn),defer是在協(xié)程退出時(shí)自動(dòng)回收,正常來(lái)說(shuō),在一個(gè)請(qǐng)求到達(dá)的時(shí)候,swoole會(huì)自動(dòng)創(chuàng)建一個(gè)協(xié)程給他,比如我們一個(gè)http api的請(qǐng)求,就需要整個(gè)api跑完,這個(gè)協(xié)程才會(huì)退出
(相當(dāng)于我們傳統(tǒng)fpm php中 一個(gè)腳本全部執(zhí)行完)
這個(gè)時(shí)候問(wèn)題來(lái)了,如果我們的業(yè)務(wù)是這樣子的
<?php
$db = MysqlPool::defer();
$db->rawQuery('select version()');
// 執(zhí)行好mysql了 做其他任務(wù)
// 耗時(shí)1.5s 完成其他
實(shí)際上使用到mysql資源的可能只有0.1s不到,但是其他運(yùn)算占用了腳本大量執(zhí)行時(shí)間,要等全部執(zhí)行完,協(xié)程退出了,資源才會(huì)回收,這個(gè)時(shí)候就比較浪費(fèi)資源的利用率了。占用率比較低。 ! 如果可以的話 ,我們推薦使用invoker 執(zhí)行一條 馬上回收資源
此時(shí)要注意一個(gè)點(diǎn),如果程序有比較多執(zhí)行語(yǔ)句,要么在一個(gè)invoker里執(zhí)行,要么合理使用invoker
不然就會(huì)把性能消耗轉(zhuǎn)移到不斷get recycle上了
如果以上排查都沒(méi)問(wèn)題,并且確認(rèn)你的用戶量比較多,并發(fā)高,就可以適當(dāng)提高pool的number