Mysql协程连接池参考Demo: Pool连接池
demo中有封装好的mysql连接池以及mysql类，复制demo中的和并放入App/Utility/Pool中即可使用
添加数据库配置
在,中添加配置信息：
/*################ MYSQL CONFIG ##################*/
'MYSQL'=>[
'host'=>'192.168.75.1',
'port'=>'3306',
'user'=>'root',
'timeout'=>'5',
'charset'=>'utf8mb4',
'password'=>'root',
'database'=>'cry',
'POOL_MAX_NUM'=>'20',
'POOL_TIME_OUT'=>'0.1',
],
在的initialize方法中注册连接池对象(注意命名空间,新版本可以无需注册,自动注册)
// 注册mysql数据库连接池
PoolManager::getInstance()->register(MysqlPool::class,Config::getInstance()->getConf('MYSQL.POOL_MAX_NUM'));
//注册之后会返回conf配置,可继续配置,如果返回null代表注册失败
可通过register返回的PoolConf对象去配置其他参数
注意
连接池不是跨进程的，进程间的连接池连接数是相互独立的，默认最大值是10个；如果开了4个worker，最大连接数可以达到40个。
基础使用
在控制器 通过mysql连接池获取mysql操作对象
/**
* Created by PhpStorm.
* User: Tioncico
* Date: 2019/3/5 0005
* Time: 21:07
*/
namespaceApp\HttpController;
useApp\Utility\Pool\MysqlPool;
useEasySwoole\Component\Pool\PoolManager;
useEasySwoole\Http\AbstractInterface\Controller;
classIndexextendsController
{
functionindex()
{
$db=PoolManager::getInstance()->getPool(MysqlPool::class)->getObj();
$data=$db->get('test');
//使用完毕需要回收
PoolManager::getInstance()->getPool(MysqlPool::class)->recycleObj($db);
$this->response()->write(json_encode($data));
// TODO: Implement index() method.
}
}
直接getobj时,可能会出现没有连接(返回null)的情况,需要增加判断
用完mysql连接池对象之后记得用recycleObj回收(新版本可使用方法自动回收)
PoolManager::getInstance()->getPool(MysqlPool::class)->recycleObj($db);
自动回收
invoke
可通过invoke静态方法直接从连接池取出一个连接,直接使用,回调函数结束后自动回收:
try{
MysqlPool::invoke(function(MysqlObject$mysqlObject){
$model=newUserModel($mysqlObject);
$model->insert(newUserBean($this->request()->getRequestParam()));
});
}catch(\Throwable $throwable){
$this->writeJson(Status::CODE_BAD_REQUEST,null,$throwable->getMessage());
}catch(PoolEmpty$poolEmpty){
$this->writeJson(Status::CODE_BAD_REQUEST,null,'没有链接可用');
}catch(PoolUnRegister$poolUnRegister){
$this->writeJson(Status::CODE_BAD_REQUEST,null,'连接池未注册');
}
defer
使用defer方法直接获取一个连接池连接,直接使用,协程结束后自动回收:
$db=MysqlPool::defer();
$model=newUserModel($db);
$model->insert(newUserBean($this->request()->getRequestParam()));
异常拦截,当invoke,defer调用,内部发生(连接不够,连接对象错误)等异常情况时,会抛出PoolEmpty和PoolException,可在控制器基类拦截或直接忽略,EasySwoole内部有做异常拦截处理,将直接拦截并返回错误到前端.
只要使用以上两个方法,就无需关注连接回收问题,将自动回收
预创建链接
新增preload方法,可在程序启动后预创建连接,避免在启动时突然大量请求,造成连接来不及创建从而失败的问题.
示例:
在EasySwooleEvent文件,mainServerCreate事件中增加onWorkerStart回调事件中预热启动:
//注册onWorkerStart回调事件
publicstaticfunctionmainServerCreate(EventRegister$register)
{
$register->add($register::onWorkerStart,function(\swoole_server $server,int$workerId){
if($server->taskworker==false){
PoolManager::getInstance()->getPool(MysqlPool::class)->preLoad(1);
//PoolManager::getInstance()->getPool(RedisPool::class)->preLoad(预创建数量,必须小于连接池最大数量);
}
// var_dump('worker:' . $workerId . 'start');
});
}