• 技术文章 >后端开发 >php教程

    php实现mysql连接池的效果

    不言不言2018-06-07 15:15:12原创3085
    这篇文章主要介绍了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 的长连接。

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

    以上就是本篇文章的全部内容了,感谢大家的阅读,更多相关内容请关注PHP中文网!

    相关推荐:

    thinkphp3.2.3版本的数据库增删改查实现代码

    php入门到就业线上直播课:查看学习

    以上就是php实现mysql连接池的效果的详细内容,更多请关注php中文网其它相关文章!

    声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn核实处理。

    千万级数据并发解决方案(理论+实战):点击学习

    Mysql单表千万级数据量的查询优化与性能分析

    Mysql主从原理及其在高并发系统中的应用

    专题推荐:mysql 连接池
    上一篇:PHP如何获得微信公众平台关注用户的基本信息 下一篇:自己动手写 PHP MVC 框架(40节精讲/巨细/新人进阶必看)

    相关文章推荐

    • ❤️‍🔥共22门课程,总价3725元,会员免费学• ❤️‍🔥接口自动化测试不想写代码?• 你知道如何用PHP实现多进程吗• PHP与MySQL连接的方法总结• 工具包分享:PHP实现滑块验证图片• 针对初学PHP者的疑难问答_PHP• 求大神解答!ajax处理php返回的xml文档的问题
    1/1

    PHP中文网