目录
- 概述
- 学习目标
- mysql连接池应用场景
- 连接池定义
- 查看当前mysql连接数
- 创建连接池代码示例
- swoole中使用连接池对象
- php7进阶到架构师相关阅读
概述
这是关于php进阶到架构之 swoole 系列学习课程：第三节：mysql连接池
学习目标 ：
了解什么是mysql连接池，以及mysql使用场景。能在实际工作使用连接池（数据库连接池，redis连接池等等）解决高并发带来的问题。
mysql连接池应用场景
场景 ：
每秒同时1000个并发，但mysql数据库同时只支持400个连接，这样mysql就会宕机
解决方案 ：
使用连接池，这个连接池建立了300个与mysql的连接对象，这1000个并发有序地共享连接池里的300个连接。
连接池的使用不但解决了mysql在高并发情况下宕机问题，还额外提高了性能。因为和mysql建立连接，消耗较大。使用连接池只需要连接一次mysql。
连接池定义
永不断开，需要程序常驻内存，这就需要借助swoole实现。
数据库连接池是程序启动时，建立足够的数据库连接，并将这些连接组成一个连接。由程序动态的对连接池中的连接进行申请，使用，释放和回补。
查看当前mysql连接数
show processlist 创建连接池代码示例
/**
* MYSQL连接池，这个类只能被实例化一次（单例模式）
* Class MysqlConnectionPool
*/class MysqlConnectionPool
{
/**
* 单例对象
* @var MysqlConnectionPool
*/ private static $instance;
/**
* 连接池连接数量
* @var int
*/ private $connNum = 20;
/**
* 连接对象列表，即连接池对象列表
* @var array
*/ private $connObjList = [];
/**
* 可用连接数
* @var int
*/ private $avilaConnNum = 20;
/**
* 构造方法连接mysql，创建20mysql连接
* MysqlConnectionPool constructor.
*/ private function __construct()
{
for($i=0; $i<$this->connNum; $i++){
$dsn = "mysql:host=127.0.0.1;dbname=test";
$this->connObjList[] = new Pdo($dsn,'root','123456');
}
}
private function __clone()
{
}
/**
* 获取连接池对象，单例
* @return MysqlConnectionPool
*/ public static function getInstance()
{
if(is_null(self::$instance)){
self::$instance = new self();
}
return self::$instance;
}
//执行sql操作
public function query($sql)
{
if($this->avilaConnNum < 1){
throw new Exception("暂时没有可用的连接诶，请稍后");
}
//从连接池获取一个连接对象，并删除（array_pop）
$pdo = array_pop($this->connObjList);
//可用连接数减1
$this->avilaConnNum --;
//使用从连接池中取出的mysql连接执行查询，并且把数据取成关联数组
$rows = $pdo->query($sql)->fetchAll(PDO::FETCH_ASSOC);
//把mysql连接放回连接池，可用连接数+1
array_push($this->connObjList,$pdo);
$this->avilaConnNum ++;
return $rows;
}
}
swoole中使用连接池对象
/创建swoole的http服务器对象
$serv = new swoole_http_server('0.0.0.0',8080);
//当浏览器链接点这个http服务器的时候,向浏览器发送helloworld
$serv->on('request', function($request,$response){
$sql = "SELECT xxx";//实际查询的sql语句
$rows = MysqlConnectionPool::getInstance()->query($sql);
$response->end(json_encode($rows));
});
//启动http服务器
$serv->start(); 
