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

开发技术 作者: 2024-08-18 17:40:01
这篇文章主要介绍了php代码实现mysql连接池效果,需要的朋友可以参考下

循环从MysqL连接池中获取连接,不需要重复创建新的连接。

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

防止访问量过大,把连接数占满了

/**

  • @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;
}
}
}

在另外的文件这样调用

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启用 长连接的方式是:

'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 的长连接。

上述是一整天的研究结果,不完备的地方,请大家指出,在此先行谢过!

原创声明
本站部分文章基于互联网的整理,我们会把真正“有用/优质”的文章整理提供给各位开发者。本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
本文链接:http://www.jiecseo.com/news/show_64486.html
mysql 连接池