Comment configurer le pool de connexions à la base de données dans thinkphp

1. Qu'est-ce qu'un pool de connexions à une base de données

La connexion à une base de données traditionnelle est un moyen d'accéder à des ressources exclusives. S'il y a de nombreux utilisateurs simultanés, cela entraînera des problèmes tels qu'un gaspillage de ressources système et un délai de réponse. . Le pool de connexions à la base de données est une méthode de partage de connexions qui met en cache les connexions dans le pool de connexions. Plusieurs threads peuvent partager des connexions dans le même pool de connexions, réduisant ainsi la consommation des ressources système.

2. Comment configurer le pool de connexion à la base de données dans thinkphp

1 Ajoutez le contenu suivant au fichier de configuration de l'application

return [
    //数据库配置信息
    'database' => [
        // 数据库类型
        'type'            => 'mysql',
        // 服务器地址
        'hostname'        => '127.0.0.1',
        // 数据库名
        'database'        => 'test',
        // 用户名
        'username'        => 'root',
        // 密码
        'password'        => '',
        // 端口
        'hostport'        => '',
        // 数据库连接参数
        'params'          => [
            // 数据库连接池配置
            \think\helper\Arr::except(\Swoole\Coroutine::getContext(),'__timer'),
        ],
        // 数据库编码默认采用utf8
        'charset'         => 'utf8',
        // 数据库表前缀
        'prefix'          => 'think_',
    ],
];

2 Ajoutez le contenu suivant au fichier d'entrée index.php

use think\App;
use think\facade\Config;
use think\facade\Db;
use think\swoole\Server;
use think\swoole\websocket\socketio\Handler;
use think\swoole\websocket\Websocket;
use think\swoole\websocket\socketio\Packet;
use think\swoole\coroutine\Context;
use Swoole\Database\PDOPool;
use Swoole\Coroutine\Scheduler;

//定义应用目录
define('APP_PATH', __DIR__ . '/app/');

// 加载框架引导文件
require __DIR__ . '/thinkphp/vendor/autoload.php';
require __DIR__ . '/thinkphp/bootstrap.php';

// 扩展Loader注册到自动加载
\think\Loader::addNamespace('swoole', __DIR__ . '/thinkphp/library/swoole/');

// 初始化应用
App::getInstance()->initialize();

//获取数据库配置信息
$dbConfig = Config::get('database');

//创建数据库连接池
$pool = new PDOPool($dbConfig['type'], $dbConfig);

//设置连接池的参数
$options = [
    'min' => 5,
    'max' => 100,
];

$pool->setOptions($options);

//连接池单例模式
Context::set('pool', $pool);

//启动Swoole server
$http = (new Server())->http('0.0.0.0', 9501)->set([
    'enable_static_handler' => true,
    'document_root' => '/data/wwwroot/default/public/static',
    'worker_num' => 2,
    'task_worker_num' => 2,
    'daemonize' => false,
    'pid_file' => __DIR__.'/swoole.pid'
]);

$http->on('WorkerStart', function (swoole_server $server, int $worker_id) {

    //功能实现

});

$http->start();

La fonction de ce qui précède. Le code consiste à créer un pool de connexions PDOPool et à définir son nombre minimum de connexions à 5 et son nombre maximum de connexions à 100. Utilisez Context pour stocker les pools de connexions en mémoire afin de les utiliser par les applications thinkphp étendues.

3. Comment utiliser le pool de connexions

Dans le processus d'utilisation du pool de connexions, vous devez faire attention aux points suivants :

1. En mode singleton du pool de connexions, différentes fonctions utilisent la même connexion pool pour garantir la cohérence des paramètres du pool de connexions.

2. Ne fermez pas MySQL immédiatement après avoir effectué l'opération sur la base de données, mais renvoyez-le directement au pool de connexions. Parce que la connexion est en fait remise dans le pool de connexions et non fermée.

3. Ne considérez pas le pool de connexions comme un « corps immortel ». Il doit également être libéré. ​​La méthode pour libérer le pool de connexions est : $pool->close().

Voici un exemple utilisant le pooling de connexions :

<?php
namespace app\index\controller;

use think\Controller;
use Swoole\Database\PDOPool;

class Index extends Controller
{
    public function index()
    {
        //获取连接池
        $pool = \Swoole\Coroutine::getContext(&#39;pool&#39;);
        
        //从连接池中取出一个连接
        $connection = $pool->getConnection();
        
        //执行操作
        $result = $connection->query('SELECT * FROM `user`');
        
        //归还连接给连接池
        $pool->putConnection($connection);
        
        //返回结果
        return json($result);
    }
}

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!