这篇文章主要介绍了php代码实现mysql连接池效果,需要的朋友可以参考下。

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

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

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

1. <?php 
2.  
3. /** 
4.  * @author xuleyan 
5.  * @title mysql类 
6.  */ 
7.  
8. class DbHelper{ 
9.   //连接池 
10.   private $_pools = []; 
11.  
12.   //连接池大小 
13.   const POOLSIZE = 5; 
14.  
15.   const USERNAME = "root"; 
16.   const PASSWORD = "root"; 
17.   const HOST = "127.0.0.1"; 
18.   const DB = "test"; 
19.  
20.   public function __construct()   
21.   { 
22.     $db = self::DB; 
23.     $username = self::USERNAME; 
24.     $password = self::PASSWORD; 
25.     $host = self::HOST; 
26.  
27.     //持久化连接 
28.     $presistent = array(PDO::ATTR_PERSISTENT => true); 
29.  
30.     for ($i=0; $i < self::POOLSIZE; $i++) {  
31.       $connection = new PDO("mysql:dbname=$db;host=$host", $username, $password); 
32.       // sleep(3); 
33.       array_push($this->_pools, $connection); 
34.     } 
35.   } 
36.  
37.   //从数据库连接池中获取一个数据库链接资源 
38.   public function getConnection() 
39.   { 
40.     echo 'get' . count($this->_pools) . "<br>"; 
41.     if (count($this->_pools) > 0) { 
42.       $one = array_pop($this->_pools); 
43.       echo 'getAfter' . count($this->_pools) . "<br>"; 
44.       return $one; 
45.     } else { 
46.       throw new ErrorException ( "<mark>数据库连接池中已无链接资源，请稍后重试!</mark>" ); 
47.     } 
48.   } 
49.  
50.   //将用完的数据库链接资源放回到数据库连接池 
51.   public function release($conn) 
52.   { 
53.     echo 'release' . count($this->_pools) . "<br>"; 
54.     if (count($this->_pools) >= self::POOLSIZE) { 
55.       throw new ErrorException ( "<mark>数据库连接池已满!</mark>" ); 
56.     } else { 
57.       array_push($this->_pools, $conn); 
58.       // $conn = null; 
59.       echo 'releaseAfter' . count($this->_pools) . "<br>"; 
60.     } 
61.   } 
62.  
63.   public function query($sql) 
64.   { 
65.     try { 
66.       $conn = $this->getConnection(); 
67.       $res = $conn->query($sql); 
68.       $this->release($conn); 
69.       return $res; 
70.     } catch (ErrorException $e) { 
71.       print 'error:' . $e->getMessage(); 
72.       die; 
73.     } 
74.   } 
75.  
76.   public function queryAll($sql) 
77.   { 
78.     try { 
79.       $conn = $this->getConnection(); 
80.       $sth = $conn->prepare($sql); 
81.       $sth->execute(); 
82.       $result = $sth->fetchAll(); 
83.       return $result; 
84.     } catch (PDOException $e) { 
85.       print 'error:' . $e->getMessage(); 
86.       die; 
87.     } 
88.   } 
89. } 

在另外的文件这样调用

1. <?php  
2.  
3. require_once 'db.php'; 
4. $sql = 'select * from user'; 
5.  
6. $dbhelper = new DbHelper; 
7. for ($i=0; $i < 10; $i++) {  
8.   $res = $dbhelper->query($sql); 
9.   // var_dump($res) . PHP_EOL; 
10. } 

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

1. class BaseMysql extends Model { 
2.   protected $connection = array( 
3.     'db_type' => 'mysql', 
4.     'db_user' => '***', 
5.     'db_pwd' => '*******', 
6.     'db_host' => '*******', 
7.     'db_port' => '3306', 
8.     'db_name' => 'custom', 
9.     'db_params' => array('persist' => true), 
10.   ); 
11. } 

如果你认为，配置这个就万事大吉了，那就大错特错了。

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

Tags: mysql连接池

分享到：