PHP implémente l'effet du pool de connexions MySQL

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

En raison 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 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)<🎜. >

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),
  );
}

[mysqld]

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

[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

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.

Aperçu :

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.

ajout, suppression, modification de la base de données de la version thinkphp3.2.3 et vérification du code d'implémentation

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!