swoole管道mysql_swoole2-mysqlpool：基于 Swoole 2 协程特性实现的 MySQL 连接池

不念不忘少年蓝@ 2022-10-25 05:59 178阅读 0赞

![a4df18e884d933a30f4ba3dabc605d6f.gif][]

若文章排版不清或需要查看文中链接，请点击文章左下角的“阅读原文”

开源地址：https://github.com/yangxikun/swoole2-mysqlpool

基于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)

使用示例

$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个请求。

压测结果：

![a6ab91d49846cf3371465e054650f840.png][]

压测时连接情况，20并发，最大连接数限制为10，所以最多只会与数据库建立10条连接：

![e4fb85c2cdffbd348f9922a9fec55415.png][]

压测后连接情况，设置了最大空闲连接数为5，所以现在没有客户端请求时，空闲连接数维持为5：

![979b20e0192a32d4309cba3dab8fc8ee.png][]

这里服务端只有1个worker进程在工作，完成100个请求，且每个请求的SQL查询是sleep 1秒，花了约11秒，如果是php-fpm+mysqli这样的模式，1个worker进程，那么得花100秒。

所以这正是协程的优势所在，利用非阻塞IO+协程切换，1个worker进程能同时处理多个客户端请求，大大提高了吞吐量。

关注微信公众号：PHP技术大全

PHPer升级为大神并不难！

![98609c54b8c4ed55215de53f465c4ea5.gif][]

[a4df18e884d933a30f4ba3dabc605d6f.gif]: /images/20221024/665ce3bdea1941779d02412959e07563.png
[a6ab91d49846cf3371465e054650f840.png]: /images/20221024/f094e76728044dc893588fa54629479a.png
[e4fb85c2cdffbd348f9922a9fec55415.png]: /images/20221024/7c5ad6db1bf541e3a566da47f2dd22d5.png
[979b20e0192a32d4309cba3dab8fc8ee.png]: /images/20221024/41a555bb3b0c40d19632d9b39f1cb928.png
[98609c54b8c4ed55215de53f465c4ea5.gif]: /images/20221024/0418f4ad6e6942feb1cdf364a257cfc9.png