• Mysql协程连接池
    • 添加数据库配置
    • 注意
    • 基础使用
    • 自动回收
      • invoke
      • defer
    • 预创建链接

    Mysql协程连接池

    参考Demo: Pool连接池

    demo中有封装好的mysql连接池以及mysql类，复制demo中的MysqlPool.php和MysqlObject.php并放入App/Utility/Pool中即可使用

    添加数据库配置

    在dev.php,produce.php中添加配置信息：

    1. /*################ MYSQL CONFIG ##################*/
    3. 'MYSQL' => [
    4.     'host'          => '192.168.75.1',
    5.     'port'          => '3306',
    6.     'user'          => 'root',
    7.     'timeout'       => '5',
    8.     'charset'       => 'utf8mb4',
    9.     'password'      => 'root',
    10.     'database'      => 'cry',
    11.     'POOL_MAX_NUM'  => '20',
    12.     'POOL_TIME_OUT' => '0.1',
    13. ],

    在EasySwooleEvent.php的initialize方法中注册连接池对象(注意命名空间,新版本可以无需注册,自动注册)

    1. <?php
    2. // 注册mysql数据库连接池
    3.         PoolManager::getInstance()->register(MysqlPool::class,Config::getInstance()->getConf('MYSQL.POOL_MAX_NUM'));
    4.         //注册之后会返回conf配置,可继续配置,如果返回null代表注册失败

    可通过register返回的PoolConf对象去配置其他参数

    注意

    连接池不是跨进程的，进程间的连接池连接数是相互独立的，默认最大值是10个；如果开了4个worker，最大连接数可以达到40个。

    基础使用

    在控制器 通过mysql连接池获取mysql操作对象

    1. <?php
    2. /**
    3.  * Created by PhpStorm.
    4.  * User: Tioncico
    5.  * Date: 2019/3/5 0005
    6.  * Time: 21:07
    7.  */
    8. namespace App\HttpController;
    9. use App\Utility\Pool\MysqlPool;
    10. use EasySwoole\Component\Pool\PoolManager;
    11. use EasySwoole\Http\AbstractInterface\Controller;
    13. class Index extends Controller
    14. {
    15.     function index()
    16.     {
    17.         $db = PoolManager::getInstance()->getPool(MysqlPool::class)->getObj();
    18.         $data = $db->get('test');
    19.         //使用完毕需要回收
    20.         PoolManager::getInstance()->getPool(MysqlPool::class)->recycleObj($db);
    21.         $this->response()->write(json_encode($data));
    22.         // TODO: Implement index() method.
    23.     }
    24. }

    直接getobj时,可能会出现没有连接(返回null)的情况,需要增加判断

    用完mysql连接池对象之后记得用recycleObj回收(新版本可使用invoker.defer方法自动回收) 

    1. <?php
    2. PoolManager::getInstance()->getPool(MysqlPool::class)->recycleObj($db);

    自动回收

    invoke

    可通过invoke静态方法直接从连接池取出一个连接,直接使用,回调函数结束后自动回收: 

    1. <?php
    2.     try {
    3.         MysqlPool::invoke(function (MysqlObject $mysqlObject) {
    4.             $model = new UserModel($mysqlObject);
    5.             $model->insert(new UserBean($this->request()->getRequestParam()));
    6.         });
    7.     } catch (\Throwable $throwable) {
    8.         $this->writeJson(Status::CODE_BAD_REQUEST, null, $throwable->getMessage());
    9.     }catch (PoolEmpty $poolEmpty){
    10.         $this->writeJson(Status::CODE_BAD_REQUEST, null, '没有链接可用');
    12.     }catch (PoolUnRegister $poolUnRegister){
    13.         $this->writeJson(Status::CODE_BAD_REQUEST, null, '连接池未注册');
    14.     }

    defer

    使用defer方法直接获取一个连接池连接,直接使用,协程结束后自动回收: 

    1. <?php  
    2. $db = MysqlPool::defer();  
    3. $model = new UserModel($db);
    4. $model->insert(new UserBean($this->request()->getRequestParam()));

    异常拦截,当invoke,defer调用,内部发生(连接不够,连接对象错误)等异常情况时,会抛出PoolEmpty和PoolException,可在控制器基类拦截或直接忽略,EasySwoole内部有做异常拦截处理,将直接拦截并返回错误到前端.

    只要使用以上两个方法,就无需关注连接回收问题,将自动回收

    预创建链接

    新增preload方法,可在程序启动后预创建连接,避免在启动时突然大量请求,造成连接来不及创建从而失败的问题.
    示例:
    在EasySwooleEvent文件,mainServerCreate事件中增加onWorkerStart回调事件中预热启动:

    1. <?php
    2. //注册onWorkerStart回调事件
    3. public static function mainServerCreate(EventRegister $register)
    4. {
    5.     $register->add($register::onWorkerStart, function (\swoole_server $server, int $workerId) {
    6.     if ($server->taskworker == false) {
    7.         PoolManager::getInstance()->getPool(MysqlPool::class)->preLoad(1);
    8.         //PoolManager::getInstance()->getPool(RedisPool::class)->preLoad(预创建数量,必须小于连接池最大数量);
    9.     }
    11.         // var_dump('worker:' . $workerId . 'start');
    12.     });
    13. }