swoole2-mysqlpool：基于 Swoole 2 協程特性實現的 MySQL 連接池

基于Swoole2協程特性實現的MySQL連接池

使用Swoole2的\Swoole\Coroutine\MySQL創建連接，通過靜態類和靜態成員屬性維護連接池，不同協程可以共享該連接池。

排隊機制（先進先出）使用協程的特殊功能實現：

• \Swoole\Coroutine::resume($name) ：從$name隊列中恢復一個掛起的協程執行；
• \Swoole\Coroutine::suspend($name) ：將當前協程掛起到$name隊列上。

限制

• 每個worker都有各自的MySQL連接池，且不同worker之間無法共享彼此的MySQL連接池；
• 可能存在各個worker進程連接池利用率不同（依賴業務實現）。

優點

• 與獨立的連接池（worker進程間可共享的連接池實現）對比，無進程間通信開銷；
• 獨立的連接池需要增加運維成本。

使用方法

/**
 * 初始化連接池
 *
 * @param array $connsConfig 配置數組
 *   [
 *       'connName1' => [
 *          'serverInfo' => ['host' => '127.0.0.1', 'user' => 'test', 'password' => 'pass', 'database' => 'tt', 'charset' => 'utf8'], //\Swoole\Coroutine\MySQL的connect參數
 *          'maxSpareConns' => 5, //最大空閑連接數
 *          'maxConns' => 10, //最大連接數
 *       ],
 *       'connName2' => [
 *          'serverInfo' => ['host' => '127.0.0.2', 'user' => 'test', 'password' => 'pass', 'database' => 'tt', 'charset' => 'utf8'], //\Swoole\Coroutine\MySQL的connect參數
 *          'maxSpareConns' => 5, //最大空閑連接數
 *          'maxConns' => 10, //最大連接數
 *       ],
 *   ]
 */
Swoole\Coroutine\Pool\MySQLPool::init(array $connsConfig)

/**
 * 回收連接，該連接必須是從連接池中獲取的連接
 *
 * @param \Swoole\Coroutine\MySQL $conn 從連接池中獲取的連接
 */
Swoole\Coroutine\Pool\MySQLPool::recycle(\Swoole\Coroutine\MySQL $conn)

/**
 * 從連接池中獲取一條連接
 *
 * @param string $connName init時配置的連接，根據連接名稱獲取對應的連接
 * @return \Swoole\Coroutine\MySQL 返回一個連接實例
 */
Swoole\Coroutine\Pool\MySQLPool::fetch($connName)

使用示例

<?php
require 'MySQLPool.php';
use Swoole\Coroutine\Pool\MySQLPool;

$server = new Swoole\Http\Server("127.0.0.1", 9502, SWOOLE_BASE);
$server->set([
        'worker_num' => 1,
]);
$server->on('Request', function($request, $response) {
        MySQLPool::init([
                'test' => [
                        'serverInfo' => ['host' => '192.168.244.128', 'user' => 'mha_manager', 'password' => 'mhapass', 'database' => 'tt', 'charset' => 'utf8'],
                        'maxSpareConns' => 5,
                        'maxConns' => 10
                ],
        ]);
        $swoole_mysql = MySQLPool::fetch('test');
        $ret = $swoole_mysql->query('select sleep(1)');
        MySQLPool::recycle($swoole_mysql);
        $response->end('Test End');
});
$server->start();

壓測命令： ab -c 20 -n 100 -s 100 http://127.0.0.1:9502/ ，20并發，共100個請求。

壓測結果：

壓測時連接情況，20并發，最大連接數限制為10，所以最多只會與數據庫建立10條連接：

壓測后連接情況，設置了最大空閑連接數為5，所以現在沒有客戶端請求時，空閑連接數維持為5：

這里服務端只有1個worker進程在工作，完成100個請求，且每個請求的SQL查詢是sleep 1秒，花了約11秒，如果是php-fpm+mysqli這樣的模式，1個worker進程，那么得花100秒。

所以這正是協程的優勢所在，利用非阻塞IO+協程切換，1個worker進程能同時處理多個客戶端請求，大大提高了吞吐量。

項目主頁：http://www.baiduhome.net/lib/view/home/1494484763593