Explication détaillée des étapes pour implémenter l'effet du pool de connexions MySQL en php

Cette fois, je vais vous donner une explication détaillée des étapes pour implémenter l'effet de pool de connexion mysql en php. Quelles sont les précautions pour que php implémente l'effet de pool de connexion mysql. cas, jetons un coup d'oeil.

Boucle 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

Empêcher 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 'get' . count($this->_pools) . "<br>";
    if (count($this->_pools) > 0) {
      $one = array_pop($this->_pools);
      echo 'getAfter' . count($this->_pools) . "<br>";
      return $one;
    } else {
      throw new ErrorException ( "<mark>数据库连接池中已无链接资源，请稍后重试!</mark>" );
    }
  }
  //将用完的数据库链接资源放回到数据库连接池
  public function release($conn)
  {
    echo 'release' . count($this->_pools) . "<br>";
    if (count($this->_pools) >= self::POOLSIZE) {
      throw new ErrorException ( "<mark>数据库连接池已满!</mark>" );
    } else {
      array_push($this->_pools, $conn);
      // $conn = null;
      echo 'releaseAfter' . 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 'error:' . $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 'error:' . $e->getMessage();
      die;
    }
  }
}

Appeler ça 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 connexion requêtes à mysql une nuit, et en même temps, le serveur mysql Il y a un problème avec le DNS, provoquant l'expiration du délai de la solution inverse. 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 regroupement 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 ThinkPHP pour activer les connexions longues est la suivante :

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.

Je pense que vous maîtrisez la méthode après avoir lu le cas dans cet article. Pour des informations plus intéressantes, veuillez prêter attention aux autres articles connexes sur le site Web chinois de php !

Lecture recommandée :

Explication détaillée des étapes de mise en œuvre de l'algorithme de courbe de simulation de régression linéaire multiple en PHP

Accès au tableau éléments entre guillemets doubles en PHP Comment gérer les rapports d'erreurs

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!