Explication détaillée du code pour implémenter l'effet de pool de connexions MySQL en PHP

Cet article présente principalement le code PHP pour implémenter l'effet du pool de connexions mysql. Les amis qui en ont besoin peuvent se référer à

Loop pour obtenir des connexions à partir du pool de connexions mysql sans créer de nouvelles connexions à plusieurs reprises.

Modification de la configuration de référence : Vous pouvez vous référer à l'article suivant

Eviter que le nombre de visites soit trop important et remplir le nombre de connexions

<?php

/**
 * @author xuleyan
 * @title mysql类
 */

class DbHelper{
  //连接池
  private $_pools = [];

  //连接池大小
  const POOLSIZE = 5;

  const USERNAME = "root";
  const PASSWORD = "root";
  const HOST = "127.0.0.1";
  const DB = "test";

  public function __construct()  
  {
    $db = self::DB;
    $username = self::USERNAME;
    $password = self::PASSWORD;
    $host = self::HOST;

    //持久化连接
    $presistent = array(PDO::ATTR_PERSISTENT => true);

    for ($i=0; $i < self::POOLSIZE; $i++) { 
      $connection = new PDO("mysql:dbname=$db;host=$host", $username, $password);
      // sleep(3);
      array_push($this->_pools, $connection);
    }
  }

  //从数据库连接池中获取一个数据库链接资源
  public function getConnection()
  {
    echo &#39;get&#39; . count($this->_pools) . "<br>";
    if (count($this->_pools) > 0) {
      $one = array_pop($this->_pools);
      echo &#39;getAfter&#39; . count($this->_pools) . "<br>";
      return $one;
    } else {
      throw new ErrorException ( "<mark>数据库连接池中已无链接资源，请稍后重试!</mark>" );
    }
  }

  //将用完的数据库链接资源放回到数据库连接池
  public function release($conn)
  {
    echo &#39;release&#39; . count($this->_pools) . "<br>";
    if (count($this->_pools) >= self::POOLSIZE) {
      throw new ErrorException ( "<mark>数据库连接池已满!</mark>" );
    } else {
      array_push($this->_pools, $conn);
      // $conn = null;
      echo &#39;releaseAfter&#39; . count($this->_pools) . "<br>";
    }
  }

  public function query($sql)
  {
    try {
      $conn = $this->getConnection();
      $res = $conn->query($sql);
      $this->release($conn);
      return $res;
    } catch (ErrorException $e) {
      print &#39;error:&#39; . $e->getMessage();
      die;
    }
  }

  public function queryAll($sql)
  {
    try {
      $conn = $this->getConnection();
      $sth = $conn->prepare($sql);
      $sth->execute();
      $result = $sth->fetchAll();
      return $result;
    } catch (PDOException $e) {
      print &#39;error:&#39; . $e->getMessage();
      die;
    }
  }
}

Appelez ceci dans un autre fichier

<?php 

require_once &#39;db.php&#39;;
$sql = &#39;select * from user&#39;;

$dbhelper = new DbHelper;
for ($i=0; $i < 10; $i++) { 
  $res = $dbhelper->query($sql);
  // var_dump($res) . PHP_EOL;
}

Comment utiliser le pool de connexions de ThinkPHP pour se connecter à MySQL

A cause d'un petit bug, le projet a envoyé un grand nombre de requêtes de connexion à mysql une nuit. Au même moment, il y avait un problème avec le dns du serveur mysql, provoquant l'anti. -délai d'expiration de la solution. Finalement, le serveur MySQL a été ramené vivant.

Enfin le bug a été corrigé et nous avons étudié comment augmenter le pool de connexions mysql.

Après avoir cherché au cours des deux derniers jours, j'ai découvert qu'il n'y avait aucune documentation relative au pooling de connexions dans la documentation ThinkPHP. J'ai donc étudié le code moi-même.

Tout d'abord : il existe trois bibliothèques d'extensions mysql couramment utilisées pour PHP : mysql, mysqli, pdo_mysql.

* mysqli ne prend pas en charge le pooling de connexions.
* pdo_mysql est pris en charge, cependant, l'extension pdo de thinkPHP ne prend pas en charge mysql, mais prend uniquement en charge : 'MSSQL', 'ORACLE', 'Ibase', 'OCI' (Voir la ligne 59 de Pdo.class.php)

* Prise en charge de MySQL, via la méthode : mysql_pconnect. (Pour les paramètres spécifiques, veuillez consulter la documentation officielle de php)

1 La façon d'activer les connexions longues dans ThinkPHP est :

class BaseMysql extends Model {
  protected $connection = array(
    'db_type' => 'mysql',
    'db_user' => '***',
    'db_pwd' => '*******',
    'db_host' => '*******',
    'db_port' => '3306',
    'db_name' => 'custom',
    'db_params' => array('persist' => true),
  );
}

Si vous pensez que tout ira bien rien qu'en configurant cela, vous vous trompez totalement.

2 mysql -> my.cnf configuration modifiée :

[mysqld]

interactive_timeout =60 // Temps d'expiration de la connexion interactive (client mysql).

wait_timeout =30 //Délai d'expiration d'une longue connexion. Cela doit être changé ! La valeur par défaut est de 8 heures. Si le volume de requêtes est important, le nombre de connexions sera bientôt complet.
max_connections = 100 //Le nombre maximum de connexions peut être considéré comme la taille du pool de connexions

3 modifications php.ini :

[MySql]
mysql.allow_persistent = On
mysql. max_persistent = 99 // Doit être inférieur au nombre maximum de connexions configurées par mysql
mysql.max_links = 99

4 Si le serveur Web est Apache, keep-alive doit être activé. Sinon, une fois la requête terminée, la longue connexion ne pourra pas être réutilisée.

Webserver est le cas de nginx :
pm = Dynamic // Démarre certains sous-processus par défaut pour gérer les requêtes http.
pm.max_children // Nombre maximum de processus enfants. Cette configuration doit être plus petite que max_connections de MySQL.

5 Si vous constatez qu'il ne peut toujours pas être utilisé, veuillez vérifier si le keepalive du système d'exploitation est activé.

Aperçu :

Vous devez activer simultanément le maintien en vie et la connexion longue à la base de données, sinon la connexion longue occupera en vain le nombre de ressources de connexion MySQL et ne peut pas être réutilisé.

Pour le cas de nginx + php-fpm, la longue connexion entre le sous-processus php-fpm et mysql est effectivement maintenue. À quel sous-processus php-fpm la requête http frontale est affectée, le sous-processus réutilisera sa longue connexion avec mysql.

Ce qui précède est le résultat d'une journée entière de recherche. Merci de signaler d'éventuelles imperfections et merci d'avance !

Recommandations associées :

Explication détaillée de la façon d'utiliser PHP CURL et Java http

Transfert temporaire des enregistrements WeChat pour Développement PHP WeChat Compétences php de stockage permanent

Compétences php d'analyse de modèle d'arbre d'enregistrement de modèle de conception PHP

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!