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