swoole2-mysqlpool:基于 Swoole 2 协程特性实现的 MySQL 连接池

Swoole MySQL   2017-05-11 14:39:23 发布
您的评价:
     
5.0
收藏     0收藏
文件夹
标签
(多个标签用逗号分隔)

基于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.open-open.com/lib/view/home/1494484763593

 

 

扩展阅读

PHP实现基于Swoole简单的HTTP服务器
PHP开发异步高性能的MySQL代理服务器
PHP高级Web开发框架 Swoole
一个运用php与swoole实现的统计监控系统
commonswoole - 通用的swoole http server框架

为您推荐

用lua扩展你的Nginx
PHP实现基于Swoole简单的HTTP服务器
thinkphp对mysql的CURD操作
开源大数据处理工具汇总(上)
Gearman及python客户端安装和简单试用

更多

Swoole
MySQL
相关文档  — 更多
相关经验  — 更多
相关讨论  — 更多