php实现mysql连接池效果实现代码

发布时间：2022-07-15 12:17:59 所属栏目：PHP教程来源：互联网

导读：这篇文章主要介绍了php代码实现mysql连接池效果,需要的朋友可以参考下。循环从mysql连接池中获取连接，不需要重复创建新的连接。参考配置修改：可以参考下面的文章防止访问量过大，把连接数占满了 ?php /** * @author xuleyan * @title mysql类 */ class

这篇文章主要介绍了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) . " ";
　　 if (count($this->_pools) > 0) {
　　 $one = array_pop($this->_pools);
　　 echo 'getAfter' . count($this->_pools) . " ";
　　 return $one;
　　 } else {
　　 throw new ErrorException ( "数据库连接池中已无链接资源，请稍后重试!" );
　　 }
　　 }
　　
　　 //将用完的数据库链接资源放回到数据库连接池
　　 public function release($conn)
　　 {
　　 echo 'release' . count($this->_pools) . " ";
　　 if (count($this->_pools) >= self::POOLSIZE) {
　　 throw new ErrorException ( "数据库连接池已满!" );
　　 } else {
　　 array_push($this->_pools, $conn);
　　 // $conn = null;
　　 echo 'releaseAfter' . count($this->_pools) . " ";
　　 }
　　 }
　　
　　 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 的长连接。

（编辑：濮阳站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!