我要投稿

php数据库连接池-基于swoole扩展实现真正的PHP数据库连接池

bendan520 php

2023-09-05 0 4,369 百度已收录

进不了网站？换个网络试试！

PHP的数据库连接池一直是一个两难的问题。许多项目已从 PHP 语言切换到 Java。大部分原因是因为Java有更好的连接池实现。 PHP的MySQL扩展提供了长连接API，但是当PHP机器数量较多、规模较大时，mysql_pconnect不能节省MySQL资源php数据库连接池，反而会减慢数据库的负载。

假设有100台PHP应用服务器，每台机器需要启动100个apache或fpm工作进程，那么每个进程都会与MySQL形成长连接。这将形成总共 10,000 个 MySQL 连接。大家都知道MySQL每个连接占用一个线程。那么MYSQL需要创建10000个线程php数据库连接池，所以大量的系统资源浪费在线程之间的上下文切换上。并不是所有的数据库操作都在你的业务代码中执行，所以这是一种浪费。

连接池不一样。 100 个工作进程可以共享 10 个数据库连接。操作数据库后，资源立即释放给其他工作进程。这样，即使有100个PHP服务器，也只会创建1000个MySQL连接，这是完全可以接受的。

确实没有什么好的办法来解决这个问题，但是现在有了 swoole 扩展，借助 swoole 提供的任务功能就可以轻松创建连接池了。

代码如下所示：


$serv = new swoole_server("127.0.0.1", 9508);
$serv->set(array(
    'worker_num' => 100,
    'task_worker_num' => 10, //MySQL连接的数量
));
function my_onReceive($serv, $fd, $from_id, $data)
{
    //taskwait就是投递一条任务，这里直接传递SQL语句了
    //然后阻塞等待SQL完成
    $result = $serv->taskwait("show tables");
    if ($result !== false) {
        list($status, $db_res) = explode(':', $result, 2);
        if ($status == 'OK') {
            //数据库操作成功了，执行业务逻辑代码，这里就自动释放掉MySQL连接的占用
            $serv->send($fd, var_export(unserialize($db_res), true) . "n");
        } else {
            $serv->send($fd, $db_res);
        }
        return;
    } else {
        $serv->send($fd, "Error. Task timeoutn");
    }
}
function my_onTask($serv, $task_id, $from_id, $sql)
{
    static $link = null;
    if ($link == null) {
        $link = mysqli_connect("127.0.0.1", "root", "root", "test");
        if (!$link) {
            $link = null;
            $serv->finish("ER:" . mysqli_error($link));
            return;
        }
    }
    $result = $link->query($sql);
    if (!$result) {
        $serv->finish("ER:" . mysqli_error($link));
        return;
    }
    $data = $result->fetch_all(MYSQLI_ASSOC);
    $serv->finish("OK:" . serialize($data));
}
function my_onFinish($serv, $data)
{
    echo "AsyncTask Finish:Connect.PID=" . posix_getpid() . PHP_EOL;
}
$serv->on('Receive', 'my_onReceive');
$serv->on('Task', 'my_onTask');
$serv->on('Finish', 'my_onFinish');
$serv->start();

这里task_worker_num是要启用的数据库连接池的数量。当worker进程为100个时，连接池数量为10个，可设置为worker_num=100、task_worker_num=10。

收藏 (0) 打赏

感谢您的支持，我会继续努力的!