用swoole簡單實現MySQL連接池
阿新 • • 發佈:2018-05-09
nmp 當前 async 技術 .com 增加 關閉 失敗 長連接
MySQL連接池
在傳統的網站開發中,比如LNMP模式,由Nginx的master進程接收請求然後分給多個worker進程,每個worker進程再鏈接php-fpm的master進程,php-fpm再根據當前情況去調用其worker進程然後處理PHP,如果需要MySQL,在與MySQL建立連接,這個時候,如果有1000個請求打過來,就需要與MySQL建立1000個連接。如果請求達到萬級或者百萬級,這時數據庫的壓力就會非常大了。連接池技術就可以派上用場了,可以大大降低數據庫連接數,還可以降低IO消耗。
為什麽可以降低IO消耗?
MySQL短連接每次請求操作數據庫都需要建立與MySQL服務器建立TCP連接,這是需要時間開銷的。TCP連接需要3次網絡通信。這樣就增加了一定的延時和額外的IO消耗。請求結束後會關閉MySQL連接,還會發生3/4次網絡通信。
而連接池采用的是MySQL的長連接模式,會一直保持與MySQL的連接,重用連接進行MySQL的操作,從而節省了建立連接和斷開連接的消耗。
為什麽可以降低數據連接數呢?
據的連接池為維持若幹個長連接,當新請求到達的時候,如果連接池空閑,就分配給連接池去處理,否則,後面的數據庫連接請求將被加入到等待隊列中。
用swoole實現一個簡單的MySQL連接池
<?php $serv = new swoole_server(‘0.0.0.0‘, 9509); $serv->set(array( ‘worker_num‘ => 50, //worker進程數量 ‘task_worker_num‘ => 10, //task進程數量 即為維持的MySQL連接的數量 )); function my_onReceive($serv, $fd, $from_id, $data) { echo "收到數據".$data.PHP_EOL; //taskwait就是投遞一條任務,這裏直接傳遞SQL語句了 //然後阻塞等待SQL完成,並返回結果 $result = $serv->taskwait($data); echo "任務結束".PHP_EOL; if ($result !== false) { list($status, $db_res) = explode(‘:‘, $result, 2); if ($status == ‘OK‘) { //數據庫操作成功了,執行業務邏輯代碼,這裏就自動釋放掉MySQL連接的占用 //將處理結果發送給客戶端 $serv->send($fd, var_export(unserialize($db_res), true) . "\n"); } else { $serv->send($fd, $db_res); } return; } else { $serv->send($fd, "Error. Task timeout\n");//如果返回的是false,則說明taskwait等待超時,可以設置相應的等待超時時間 } } function my_onTask($serv, $task_id, $from_id, $sql) { echo "開始做任務 task id:".$task_id.PHP_EOL; static $link = null; HELL: if ($link == null) { $link = @mysqli_connect("127.0.0.1", "root", "passwd", "database"); if (!$link) { $link = null; $serv->finish("ER:" . mysqli_error($link)); return; } } $result = $link->query($sql); if (!$result) { //如果查詢失敗了 if(in_array(mysqli_errno($link), [2013, 2006])){//錯誤碼為2013,或者2006,則重連數據庫,重新執行sql $link = null; goto HELL; }else{ $serv->finish("ER:" . mysqli_error($link)); return; } } if(preg_match("/^select/i", $sql)){//如果是select操作,就返回關聯數組 $data = $result->fetch_assoc(); }else{//否則直接返回結果 $data = $result; } $serv->finish("OK:" . serialize($data));//調用finish方法,用於在task進程中通知worker進程,投遞的任務已完成 //return "OK:".serialize($data); } function my_onFinish($serv, $task_id, $data) { echo "任務完成";//taskwait 沒有觸發這個函數。。 echo "AsyncTask Finish:Connect.PID=" . posix_getpid() . PHP_EOL; } $serv->on(‘receive‘, ‘my_onReceive‘); $serv->on(‘task‘, ‘my_onTask‘); $serv->on(‘Finish‘, ‘my_onFinish‘); $serv->start();//啟動server
用swoole簡單實現MySQL連接池