這篇文章主要介紹了php程式碼實現mysql連接池效果,需要的朋友可以參考下
循環從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 '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; } } }
在另外的檔案這樣呼叫
<?php require_once 'db.php'; $sql = 'select * from user'; $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( 'db_type' => 'mysql', 'db_user' => '***', 'db_pwd' => '*******', 'db_host' => '*******', 'db_port' => '3306', 'db_name' => 'custom', 'db_params' => array('persist' => 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 的長連線。
上述是一整天的研究結果,不完備的地方,請大家指出,在此先行謝過!
以上就是這篇文章的全部內容了,感謝大家的閱讀,更多相關內容請關注PHP中文網!
相關建議:
以上是php實作mysql連線池的效果的詳細內容。更多資訊請關注PHP中文網其他相關文章!