swoole实现数据库链接池

原生 PHP CURD

让咱们来回顾一下PHP中数据库的使用

<?php
# curd.php

$id   = 1;

$dbh  = new PDO();
$stmt = $dbh->prepare('SELECT * FROM  `user` WHERE `id`=:id');
$stmt ->bindValue(':id', $id);
$user = $stmt->fetch();

var_dump($user);

上述代码, 自己是没有任何问题。这里咱们也不是来挑出问题的，只是以一位多年PHPer的经验与你们交流下。

上面程序执行过程是什么样子的呢？

_______________________
                |                       |
    [浏览器请求] ==>   [mod_php/php-fpm]  |
                |           ||          |
                |           ||          |
                |           \/          |
                |       [curd.php]      |
                |           ||          |
                |           ||          |
                |           \/          |
                |    [PDO::_construct]  | <== 请求的开销
                |           ||          |
                |           ||          |
                |           \/          |
    [Response] <==      [PDO::CURD]     |
                |           ||          |
                |           ||          |
                |           \/          |
                |       [PDO::close]    |
                |_______________________|

Swoole PHP CURD

Java应用中，你们在进行数据库CURD的时候，会维护一个数据库链接池。在PHP的世界中，要想作链接池挺困难的：

• PHP web应用不可长驻运行

• 不可借助第三方服务如KV转存句柄

而在Swoole中咱们就能够实现链接池了！

<?php
$http = new swoole_http_server('0.0.0.0', 80, SWOOLE_BASE);
$http->db->dbh = new PDO();

$http->on('request', function(swoole_http_request $req, swoole_http_response $res) use($http) {
    $id = 1;
    $stmt = $http->db->dbh->prepare('SELECT * FROM  `user` WHERE `id`=:id');
    $stmt ->bindValue(':id', $id);
    $user = $stmt->fetch();

    $res->end(var_export($user, true));
    unset($stmt);
});

执行流程

[php app.php]
                           ||
                           ||
                           \/
                    [PDO::__construct]
                           ||
               ____________||________________
              |            \/                |
  [浏览器请求] ==>   [ ->onRequest(\Closure) ] |
              |            ||                |
              |            ||                | <== 请求开销
              |            \/                |
  [Response] <==      [PDO::CURD]            |
              |____________||________________|
                           ||
                           \/
                     [PDO::close]

分析上面流程, Swoole不用再每次请求时去创建数据库链接, 既避免了给数据库过多压力, 也更迅速的处理核心业务逻辑. 也许你以为这优点不明显, 可是在c10k问题(Connections over 10,000)场景中, 优点就很是明显了吧?固然, 上面的demo只是抛砖引玉, 没有实现multi connections pool, 若是你们要作生产化代码, 务必实现链接池, idle链接数按照业务须要, 好比80%的时间链接数200, 设置200个idle的链接池是最优的.

PHP有了链接池，咱们的应用就能够不用再在收到请求时去建立数据库链接了。
试试上面的代码，与曾经碰到过3000+数据库链接的烦恼bye bye吧～

[本节完, 文字未校对, 程序未测试]