背景：swoole的出現，包括PHP出現前，在新浪企業郵箱就有基于Sun Solaris 系統上面用c++寫Mysql的長連接，那時候的長連接是基于RPC實現，對mysql那一端形成一個遠程過程的調用，通過XDR數據結構進行解析mysql傳來的數據項(RPC也為sun最新提出并后來在linux上默認支持)，也就是說像用戶登錄驗證這一塊用Mysql的長連接來實現，提高其效率運行相當穩定，后面這個系統遷移到了FreeBSD后，出現了mysql長連接的服務經常出現假死，也就是說進程還在，但是已經連接不上mysql了，重新啟動這個RPC服務又好了，原因未知，當時我對c++不了解(現在也不太了解，只聽說要看是否形成coredump啥的)，當年我還寫過一個判斷死了就殺死，重啟動，判斷的程序也老半天回不來，于是我又改成了一個多進程，如果超時沒有回來，就干掉那個進程，重啟Rpc服務，再后來，這套C++的cgi被替換成了php，再后來基于FreeBSD的系統遷移到了Linux，也就是現在一直在linux上，linux也就強大了起來，回想起來，當年一個登錄服務如此極致，現在都變成了直接查詢mysql了，這個長連接技術有還有用嗎？我只能說對有上千臺上萬臺的服務器可能有用，能節省一定的機器成本罷。但是，追求技術永無止境，需要有這樣的一些東西來繁榮我們這個PHP的市場，長連接這個話題不再是Java做成了連接池，像c++也能做成連接池，像騰訊廣平就有c++團隊還有寫cgi實現長連接Mysql服務，據說前二年吧更多關注了H5，像實時技術，比如Tail技術在web上的實現，有轉向nodejs的趨勢，而此時的PHP拿不出這樣的技術，是很危險的，有了swoole起到填補作用，我更多的是覺得官方應該重視這個技術，而不是形成一個擴展，像H5的來到，像websocket的進入，這些東西對于Node來講，從前端向后端的統一，而PHp呢？沒有誰來解決，那么從用戶角度來講，開發者用戶的流失或遷移，對PHP本身也是一個損失，但我還是說PHP是最好的語言沒有之一，期望其能伴隨潮流，與時俱進。

PHP的數據庫連接池一直以來都是一個難題，很多從PHP語言轉向Java的項目，大多數原因都是因為Java有更好的連接池實現。PHP的MySQL擴展提供了長連接的API，但在PHP機器數量較多，規模較大的情況下，mysql_pconnect非但不能節約MySQL資源，反而會加劇數據庫的負荷。

假設有100臺PHP的應用服務器，每個機器需要啟動100個apache或fpm工作進程，那每個進程都會產生一個長連接到MySQL。這一共會產生1萬個My SQL連接。大家都知道MySQL是每個連接會占用1個線程。那MYSQL就需要創建1萬個線程，這樣大量的系統資源被浪費在線程間上下文切換上。而你的業務代碼中并不是所有地方都在做數據庫操作，所以這個就是浪費的。

連接池就不同了，100個worker進程，公用10個數據庫連接即可，當操作完數據庫后，立即釋放資源給其他worker進程。這樣就算有100臺PHP的服務器，那也只會創建1000個MySQL的連接，完全可以接受的。

以前確實沒有好的辦法來解決此問題的，現在有了swoole擴展，利用swoole提供的task功能可以很方便做出一個連接池來。

代碼如下：

$serv = new swoole_server("127.0.0.1", 9508);

$serv->set(array(

'worker_num' => 100,

'task_worker_num' => 10, //MySQL連接的數量

));

function my_onReceive($serv, $fd, $from_id, $data)

{

//taskwait就是投遞一條任務，這里直接傳遞SQL語句了

//然后阻塞等待SQL完成

$result = $serv->taskwait("show tables");

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");

}

}

function my_onTask($serv, $task_id, $from_id, $sql)

{

static $link = null;

if ($link == null) {

$link = mysqli_connect("127.0.0.1", "root", "root", "test");

if (!$link) {

$link = null;

$serv->finish("ER:" . mysqli_error($link));

return;

}

}

$result = $link->query($sql);

if (!$result) {

$serv->finish("ER:" . mysqli_error($link));

return;

}

$data = $result->fetch_all(MYSQLI_ASSOC);

$serv->finish("OK:" . serialize($data));

}

function my_onFinish($serv, $data)

{

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();

看完上面的，看完了，覺得真的很厲害。畢竟，現在來說可能是還沒有真正在PHP使用數據庫連接池的大應用。今天終于準備實驗實驗。

在開始之前，還是說一下測試環境吧：OS CentOS 6.4 x86；php 5.3.17；MySQL 5.5.28；Swoole 1.6.8。

首先，我們當然要把代碼寫好。下面是服務端代碼，很多是參考了上面文章里面的，當然也有自己的內容。

$serv = swoole_server_create('127.0.0.1', 3305, SWOOLE_PROCESS, SWOOLE_SOCK_TCP);//端口3305

swoole_server_set($serv, array(

'worker_num' => 2,??????//worker線程的數量

'task_worker_num' => 1, //MySQL連接的數量

));//作為小型測試，參數調得比較小

//這里有一個守護進程化的參數，由于是實驗，沒有加入

function my_onReceive($serv, $fd, $from_id, $data){

//執行查詢

$result = $serv->taskwait($data);

if ($result !== false) {

swoole_server_send($serv, $fd, $result);

return;

} else {

swoole_server_send($serv, $fd, "Error. Task timeout\n");

}

}

function my_onTask($serv, $task_id, $from_id, $sql){

static $link = NULL;

if ($link == NULL) {

$link = mysqli_connect('localhost', 'user', 'pw', 'db');

//localhost=>UNIX Socket , IP地址=>TCP/IP

}

$result = $link->query($sql);

if ($result === false) {

swoole_server_finish($serv, 'b:0;');//語句運行失敗，這是serialize后的false，下同理

return;

}

if ($result === true){

swoole_server_finish($serv, 'b:1;');//寫入操作成功

return;

}

$data = $result->fetch_all(MYSQLI_ASSOC);

swoole_server_finish($serv, serialize($data));

}

function my_onFinish($serv, $data){

//這次實驗就沒有寫東西了

//但是必須有這個函數定義

//其實可以寫日志什么的吧

}

swoole_server_handler($serv, 'onReceive', 'my_onReceive');

swoole_server_handler($serv, 'onTask', 'my_onTask');

swoole_server_handler($serv, 'onFinish', 'my_onFinish');

//上面是設置回調函數

swoole_server_start($serv);

swoole_event_wait();//實驗環境是PHP5.3，所以需要這個函數進行事件輪詢；5.4+就不需要了

如果把上面的連接池代碼和Rango的相比較，會發現我的對于錯誤的部分處理很少。其實這個時候用CLI運行這個連接池，然后使用Telnet已經就可以直接測試效果了。但是不管怎么說這個東西還是要應用在PHP上面的，我簡單地寫一下PHP方面的代碼。

$link=new swoole_client(SWOOLE_SOCK_TCP,SWOOLE_SOCK_SYNC);//TCP方式、同步

$link->connect('127.0.0.1',3305);//連接

$link->send('SELECT * FROM `table`');//執行查詢

$res=unserialize($link->recv());

if(!res){

echo 'Failed!';

}

else{

print_r($res);

}

$link->close();

//上面的是最簡單的測試，下面可以簡單地改寫成函數

function dbcp_query($sql){

$link=new swoole_client(SWOOLE_SOCK_TCP,SWOOLE_SOCK_SYNC);//TCP方式、同步

$link->connect('127.0.0.1',3305);//連接

$link->send($sql);//執行查詢

return unserialize($link->recv());

//swoole_client類析構時會自動關閉連接

}

現在可以運行了，本次實驗是成功的。但是如果使用dbcp_query()這個函數，每次調用都要發起一次TCP連接，執行的語句多了，肯定出問題。這個時候我們就可以把它封裝成一個類了，單純實現這個會比較的簡單，但是打出來要點時間，這里就不寫了。

最后：今天做的是數據庫連接池的實現。從上面的代碼我們可以看見，程序與連接池之間的數據交換是使用php序列進行的。這里會有兩次的serialize、unserialize，絕對也是一個開銷。Rango的文章里面有說到“MySQL是每個連接會占用1個線程……大量的系統資源被浪費在線程間上下文切換上……不是所有地方都在做數據庫操作，所以這個就是浪費的?！痹倏纯此瞧恼碌募僭O：“假設有100臺PHP的應用服務器，每個機器需要啟動100個apache或fpm工作進程?！边@肯定不是一個小項目，確實就適合用連接池了。寫的東西是用來練手或者解悶兒的？常規方法已經可以了。不要忘了一點：程序與連接池的交互我們應該還是用Swoole實現的，Swoole可是一個TCP/UDP擴展。而Swoole只能運行在Linux平臺上面，但是Linux平臺上的MySQL是可以用UNIX Socket通訊的。

P.S.：找個時間給epdb改寫一個支持數據庫連接池的版本。

來自：http://rango.swoole.com/archives/265

http://bokjan.com/prog/php-db-conn-pool-with-swoole.html

總結

以上是生活随笔為你收集整理的php cli swoole mysql_[了解实践]Swoole、PHP与MySQL：连接池,swoole扩展实现真正的PHP数据库连接池。...的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。