workerman寫mysql連線池

首先要了解為什麼用連接池，連接池能為你解決什麼問題

連接池主要的作用

1、減少與數據伺服器建立TCP連線三次握手及連線關閉四次揮手的開銷，從而降低客戶端和mysql服務端的負載，縮短請求響應時間

2、減少資料庫的並發連線數，即解決應用伺服器過多導致的資料庫too many connections 問題

如果是為了解決問題1

則在workerman中資料庫連線池不是最有效率的方法，反而是自找麻煩的做法。由於PHP是單進程單線程的，使用PHP實現資料庫連接池，所以肯定需要用單獨的進程去做，那麼就會涉及到進程間的通訊，使得原本和mysql直接通訊的過程變成與連接池再到mysql的通訊，增加了應用端的負載。

解決問題1最有效率的方法是為每個業務進程建立一個資料庫單例（例如workerman提供的DB類別），實現資料庫長連接，這樣每個進程的所有請求都使用自己的這一個資料庫長連接，整個進程的生命週期只有一次TCP握手和斷開連接揮手的開銷，並且應用與mysql直接通訊，沒有連接池那樣中間一層進程間IPC通訊，性能是最高的，沒有之一。

如果是為了問題2

先看下自己到底有多少台應用程式伺服器，每台伺服器與mysql有多收並發連線。假如你只有10台應用伺服器，每個伺服器50個進程，每個進程1個資料庫連接，那麼到mysql服務端總共只有10*50=500個並發連接（並非活躍連接），500個並發連接對於mysql來說就是小菜一碟，為了解決問題2完全沒有使用連接池的必要。

假如你有1000台應用伺服器，那麼連接池是有必要的，但是這個連接池不能是運行在本地應用伺服器上的連接池，因為1000台應用伺服器就有1000個連接池，即使每個連接池只開10個連接，那麼資料庫的連線數也會輕鬆打滿。所以不要指望在目前伺服器上開幾個task進程實現的連線池就能解決這個問題。

1000台應用程式伺服器的集群，每台伺服器上搞幾個進程實現連接池同樣是不靠譜的方法。真正能夠解決問題2的方法是建立一個獨立的資料庫連接池伺服器或說集群，全域管理所有的資料庫連結。

綜上所述，

如果單獨是為了問題1實作php的mysql連線池，那麼資料庫單例是比所謂的連線池更簡單更有效率的做法。

如果是為了實現問題2，那麼想必業務也有一定的規模了，如果真心是想用workerman做個單獨的連接池集群，下面是大概簡單的做法，建立一些task進程，每個進程創建一個資料庫連接，task進程收到sql請求後發送給mysql伺服器，mysql伺服器返回後task進程再把結果發給sql發起者。

連接池代碼類似如下如果是多台伺服器組成的連接池集群，前面最好加一個lvs

// task worker，使用Text协议
$task_worker = new Worker('Text://0.0.0.0:1234');
$task_worker->count = 64;
$task_worker->name = 'MysqlTask';
$task_worker->onMessage = function($connection, $sql)
{
     // 执行sql.... 得到结果，这里省略....
     $sql_result = your_mysql_query($sql);
     // 发送结果
     $connection->send(json_encode($sql_result));
};

在workerman中調用

use \Workerman\Connection\AsyncTcpConnection;
// 与远程连接池服务建立异步链接，ip为远程连接池服务的ip，如果是集群就是lvs的ip
$sql_connection = new AsyncTcpConnection('Text://ip:1234');
// 发送sql
$sql_connection->send("SELECT ... FROM .....");
// 异步获得sql结果
$sql_connection->onMessage = function($sql_connection, $sql_result)
{
     // 这里只是打印结果
     var_dump(json_decode($task_result));
};
// 执行异步链接
$sql_connection->connect();

更多workerman知識請關注workerman教學專欄。

以上是workerman寫mysql連線池的詳細內容。更多資訊請關注PHP中文網其他相關文章！