php mysql连接池配置优化,php实现mysql连接池效果实现代码

灰太狼 2022-11-12 09:33 173阅读 0赞

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

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

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

php;" style="margin: 3px auto 0px; padding: 0px 0px 0px 5px; outline: none; background-image: initial; background-position: initial; background-size: initial; background-repeat: initial; background-attachment: initial; background-origin: initial; background-clip: initial; width: 640px; line-height: 20px; clear: both; border-left: 3px solid rgb(108, 226, 108);">

/\*\*

\* @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启用 长连接的方式是：

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 mysql连接池配置优化,php实现mysql连接池效果实现代码

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 MySQL连接池耗尽，服务中断：优化连接池管理

相关 PHP 数据库连接池实现

相关 mysql连接池

相关 mysql连接池

相关 Go-MySQL（二）Go实现MySQL连接池

相关 mysql 连接池频率_MySQL之长连接、短连接、连接池

相关 php连接mysql原生_PHP连接MySQL

相关 php mysql连接池配置优化,php实现mysql连接池效果实现代码

相关在PHP中使用redis实现连接池

相关数据库连接池代码实现