首頁  >  文章  >  後端開發  >  完全掌握php實作mysql連線池效果實作方法

完全掌握php實作mysql連線池效果實作方法

小云云
小云云原創
2018-01-27 09:19:062684瀏覽

循環從mysql連接池中取得連接,不需要重複建立新的連接。本文主要介紹了php程式碼實現mysql連線池效果,需要的朋友可以參考下,希望能幫助大家。

參考配置修改:可以參考下面的文章

防止訪問量過大,把連接數佔滿了


<?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;
    }
  }
}

在另外的檔案這樣呼叫


<?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;
}

ThinkPHP連接MySQL的連接池使用方法

因為一個小bug,導致專案在某個晚上向mysql發送了大量的連線請求,同時mysql伺服器的dns出現問題,導致反解逾時。最後活活的把mysql伺服器拖掛了。

最後bug修復了,並研究了一下增加 mysql連接池的辦法。

這兩天搜了一下,發現ThinkPHP文件裡沒有連接池的相關文件。所以自己研究了下程式碼。

首先: PHP常用的mysql擴充函式庫有三種 : mysql, mysqli, pdo_mysql.

* mysqli 是不支援連接池的。
* pdo_mysql 支持,但是,thinkPHP的pdo擴充不支援mysql,只支援:'MSSQL','ORACLE','Ibase','OCI' . ( 見Pdo.class.php 的第59行)

* mysql 支持,透過方法:mysql_pconnect .(具體參數可以看php官方文件)

1 使ThinkPHP啟用長連接的方式是:


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

如果你認為,配置這個就萬事大吉了,那就大錯特錯了。

2 mysql -> my.cnf修改設定:
[mysqld]

interactive_timeout =60 // 互動連線(mysql-client)的過期時間。
wait_timeout =30 // 長連線的過期時間時間。 這個一定要改啊!預設是8小時。 如果請求量大點,很快​​連線數就佔滿了。
max_connections = 100 //最大連接數,可以認為是連接池的大小

3 php.ini 修改:
[MySql]
mysql.allow_persistent = On
mysql. max_persistent = 99 // 要小於mysql配置的最大連線數
mysql.max_links = 99

4 webserver如果是apache ,需要啟用keep-alive。 否則,一旦請求退出,長連線將無法再重複使用。
webserver 是nginx的情況:
pm = dynamic // 預設啟動一些子進程,用於處理http請求。
pm.max_children // 最大的子行程數。 這個配置要小於 mysql 的max_connections。

5 如果發現還是不能用,請檢查作業系統的keepalive 是否啟用。

綜述:

需要 keep-alive 和 資料庫長連線同時啟用,否則長連接回白白的佔用mysql的連線數資源,而無法重複使用。
對於 nginx + php-fpm 的情況,其實是保持了 php-fpm 子程序與mysql的長連結。 前端的http請求被指派給哪個 php-fpm子程序,該子程序就重複使用自己與mysql 的長連線。

相關推薦:

連接池配置的10篇內容推薦

PHP實作資料庫連線池的具體分析

轉一個SQL Ralay資料庫連接池的PHP操作類別

以上是完全掌握php實作mysql連線池效果實作方法的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn