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

 更新时间:2018年01月25日 21:04:32   作者:乐乐的博客  
这篇文章主要介绍了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 的长连接。

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

相关文章

  • 提示Trying to clone an uncloneable object of class Imagic的解决

    提示Trying to clone an uncloneable object of class Imagic的解

    使用网上流传的一个程序实现pdf截图为png,需要使用Imagic扩展,安装后出现Trying to clone an uncloneable object of class Imagic提示,下面是具体的解决方法分享。
    2011-10-10
  • php+mysql+jquery实现日历签到功能

    php+mysql+jquery实现日历签到功能

    本文主要介绍了php+mysql+jquery实现日历签到功能的过程与步骤,具有很好的参考价值,下面跟着小编一起来看下吧
    2017-02-02
  • PHP+redis实现的购物车单例类示例

    PHP+redis实现的购物车单例类示例

    这篇文章主要介绍了PHP+redis实现的购物车单例类,涉及php连接、操作redis数据库及购物车功能相关定义与使用技巧,需要的朋友可以参考下
    2019-02-02
  • PHP实现的方程求解示例分析

    PHP实现的方程求解示例分析

    这篇文章主要介绍了PHP实现的方程求解,结合具体实例形式较为详细的分析了针对具体需求使用php进行方程求解的实现技巧,需要的朋友可以参考下
    2016-11-11
  • JS 网站性能优化笔记

    JS 网站性能优化笔记

    JS 网站性能优化笔记,使用下面的方法有利于提高代码的执行效率。
    2011-05-05
  • 详解php微信小程序消息推送配置

    详解php微信小程序消息推送配置

    这篇文章主要介绍了php微信小程序消息推送配置,对微信小程序推送感兴趣的同学,可以参考下
    2021-04-04
  • php在linux下检测mysql同步状态的方法

    php在linux下检测mysql同步状态的方法

    这篇文章主要介绍了php在linux下检测mysql同步状态的方法,是Linux下使用php检测mysql同步状态的实用技巧,具有一定参考借鉴价值,需要的朋友可以参考下
    2015-01-01
  • 解析crontab php自动运行的方法

    解析crontab php自动运行的方法

    本篇文章是对crontab php自动运行的方法进行了详细的分析介绍,需要的朋友参考下
    2013-06-06
  • PHP钩子实现方法解析

    PHP钩子实现方法解析

    这篇文章主要介绍了PHP钩子实现方法,结合实例形式分析了php钩子的原理与相关实现技巧,需要的朋友可以参考下
    2019-05-05
  • php strnatcmp()函数的用法总结

    php strnatcmp()函数的用法总结

    这篇文章主要是对php中strnatcmp()函数的用法进行了详细的总结介绍,需要的朋友可以过来参考下,希望对大家有所帮助
    2013-11-11

最新评论