首页 / PHP / Thinkphp分布式数据库连接代码分析

Thinkphp分布式数据库连接代码分析

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Thinkphp分布式数据库连接代码分析，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含8221字，纯文字阅读大概需要12分钟。

内容图文

Thinkphp作为国内的一款流行框架，相信使用的人一定不在少数。本篇我们来分析一下Thinkphp中比较重要的一部分——分布式数据库的连接。

当然了，我们在这里不是去将如何使用模型去对数据库进行增删改查。我们是对其底层的连接代码做一个分析，可以帮助大家更好的理解thinkphp对数据库的操作。方便我们以后的使用。

一、单一数据库的连接

在使用的时候，单一数据库的连接配置非常简单。我们只需要在配置文件中配置一下的信息即可。

‘DB_TYPE‘ => ‘mysql‘,
‘DB_HOST‘ => ‘192.168.5.102‘,
‘DB_NAME‘ => ‘databasename‘,
‘DB_USER‘ => ‘user‘,
‘DB_PWD‘ => ‘password‘,
‘DB_PORT‘ => ‘3306‘,
‘DB_PREFIX‘ => ‘onmpw_‘,

设置完成以后就可以使用了。默认情况下就是单一的数据库连接。

二、分布式数据库的连接

单一数据库的连接很简单，我们着重分析一下分布式数据库的连接。

‘DB_TYPE‘ => ‘mysql‘,
‘DB_HOST‘ => ‘192.168.5.191,192.168.5.88,192.168.5.103‘,
‘DB_NAME‘ => ‘test,test,test‘,
‘DB_USER‘ => ‘masteruser,slaveuser,slaveuser‘,
‘DB_PWD‘ => ‘masterpass,slavepass,slavepass‘,
‘DB_PORT‘ => ‘3306‘,
‘DB_PREFIX‘ => ‘‘,
‘DB_DEPLOY_TYPE‘        => 1, // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
‘DB_RW_SEPARATE‘        => true,       // 数据库读写是否分离主从式有效
‘DB_MASTER_NUM‘         => 1, // 读写分离后主服务器数量
‘DB_SLAVE_NO‘           => ‘‘, // 指定从服务器序号

按照以上配置就可以连接分布式数据库了。

下面我们看下面几个选项

‘DB_HOST’

分布式数据库，有几台服务器就要填写几个服务器地址，每个地址之间用逗号隔开。如果是主从式分布的话，前面的地址要是主数据库的地址。

对于下面的用户名和密码还有监听端口之类的，当然是有几个就写几个。如果各个数据库的用户名和密码都一样的话，可以只写一个。

对于这些选项的解析的代码如下

$_config[‘username‘] =   explode(‘,‘,$this->config[‘username‘]);
$_config[‘password‘] =   explode(‘,‘,$this->config[‘password‘]);
$_config[‘hostname‘] =   explode(‘,‘,$this->config[‘hostname‘]);
$_config[‘hostport‘]   =   explode(‘,‘,$this->config[‘hostport‘]);
$_config[‘database‘] =   explode(‘,‘,$this->config[‘database‘]);
$_config[‘dsn‘]      =   explode(‘,‘,$this->config[‘dsn‘]);
$_config[‘charset‘]   =   explode(‘,‘,$this->config[‘charset‘]);

‘DB_DEPLOY_TYPE’=>1

1 表示是分布式， 0 表示的是集中式（也就是单一服务器）。

该选项的实现是在类 Think\Db\Dirver中

protected function initConnect($master=true) {
    if(!empty($this->config[‘deploy‘]))
       // 采用分布式数据库
       $this->_linkID = $this->multiConnect($master);
    else
       // 默认单数据库
      if ( !$this->_linkID ) $this->_linkID = $this->connect();
}

$this->config[‘deploy’]表示的就是’DB_DEPLOY_TYPE’这个配置选项，上面的配置在使用之前都已经经过解析了，配置项都在$this->config数组中。至于是如何解析配置文件的，这里我们不做介绍，感兴趣的可以参考Think\Db类。

$this->multiConnect()函数就是用来进行分布式连接的，如果’DB_DEPLOY_TYPE’选项设置为1，该函数就会执行。否则直接执行$this->connect()函数。

‘DB_RW_SEPARATE’=>true

true 表示读写分离；false表示读写不分离。

这里需要注意的是，读写分离是以主从式数据库系统为前提的。该选项设置为true的时候主数据库写，从数据库读。

if($this->config[‘rw_separate‘]){
      // 主从式采用读写分离
      if($master)
          // 主服务器写入
          $r =   $m;
      else{
          if(is_numeric($this->config[‘slave_no‘])) {// 指定服务器读
              $r = $this->config[‘slave_no‘];
          }else{
               // 读操作连接从服务器
              $r = floor(mt_rand($this->config[‘master_num‘],count($_config[‘hostname‘])-1));   // 每次随机连接的数据库
          }
            }
}else{
      // 读写操作不区分服务器
      $r = floor(mt_rand(0,count($_config[‘hostname‘])-1));   // 每次随机连接的数据库
}

$this->config[‘rw_separate’] 为true的时候采用读写分离，为false的时候读写不分离。读写分离为什么必须是主从式的呢？因为从服务器不能写只能读，如果向从服务器写入数据的话，数据是没法同步的。这样就会造成数据不一致的情况。所以说，如果我们的系统是主从式的话，我们必须采用读写分离。也就是说DB_RW_SEPARATE选项必须配置为true。

‘DB_MASTER_NUM‘=>1

该选项后面的数字表示读写分离后，主服务器的数量。因此该选项也是用于主从式数据库系统。

下面的代码是选择主服务器。

$m = floor(mt_rand(0,$this->config[‘master_num‘]-1));

主从式数据库读取的时候选择从服务器读的核心代码

$r = floor(mt_rand($this->config[‘master_num‘],count($_config[‘hostname‘])-1)); // 每次随机连接的数据库

其中$this->config[‘master_num’]表示主服务器的数量。

‘DB_SLAVE_NO‘=> ‘‘

指定从服务器的序号，用于读取数据。如果不设置，则根据主服务器的数量计算书从服务器的数量，然后从中随机选取一台进行读取。

if(is_numeric($this->config[‘slave_no‘])) {// 指定服务器读
   $r = $this->config[‘slave_no‘];
}else{
   // 读操作连接从服务器
   $r = floor(mt_rand($this->config[‘master_num‘],count($_config[‘hostname‘])-1));   // 每次随机连接的数据库
}

以上是对每个选项的作用的实现代码进行了一个简单的说明。

下面我们来看其连接的部分

if($m != $r ){
   $db_master = array(
      ‘username‘ => isset($_config[‘username‘][$m])?$_config[‘username‘][$m]:$_config[‘username‘][0],
      ‘password‘ => isset($_config[‘password‘][$m])?$_config[‘password‘][$m]:$_config[‘password‘][0],
    ‘hostname‘ => isset($_config[‘hostname‘][$m])?$_config[‘hostname‘][$m]:$_config[‘hostname‘][0],
      ‘hostport‘ => isset($_config[‘hostport‘][$m])?$_config[‘hostport‘][$m]:$_config[‘hostport‘][0],
      ‘database‘ => isset($_config[‘database‘][$m])?$_config[‘database‘][$m]:$_config[‘database‘][0],
      ‘dsn‘ => isset($_config[‘dsn‘][$m])?$_config[‘dsn‘][$m]:$_config[‘dsn‘][0],
      ‘charset‘ => isset($_config[‘charset‘][$m])?$_config[‘charset‘][$m]:$_config[‘charset‘][0],
    );
}
$db_config = array(
   ‘username‘ => isset($_config[‘username‘][$r])?$_config[‘username‘][$r]:$_config[‘username‘][0],
    ‘password‘ => isset($_config[‘password‘][$r])?$_config[‘password‘][$r]:$_config[‘password‘][0],
    ‘hostname‘ => isset($_config[‘hostname‘][$r])?$_config[‘hostname‘][$r]:$_config[‘hostname‘][0],
    ‘hostport‘ => isset($_config[‘hostport‘][$r])?$_config[‘hostport‘][$r]:$_config[‘hostport‘][0],
     ‘database‘ => isset($_config[‘database‘][$r])?$_config[‘database‘][$r]:$_config[‘database‘][0],
     ‘dsn‘ => isset($_config[‘dsn‘][$r])?$_config[‘dsn‘][$r]:$_config[‘dsn‘][0],
     ‘charset‘   => isset($_config[‘charset‘][$r])?$_config[‘charset‘][$r]:$_config[‘charset‘][0],
);
return $this->connect($db_config,$r,$r == $m ? false : $db_master);

看到这，我觉得大家应该对上面在介绍各个配置选项的代码的时候其中的$r和$m是什么作用了。

现在我们来看 $r == $m ? false : $db_master ，如果数据库读写不分离的情况下，读写是一台服务器的话传给connect函数的值为false。或者是如果是主从分离的写的情况下传给connect的值也为false。通过上面代码我们看到，如果$r和$m不相等的情况下，会设置$db_master。其实也就是相当于一台备用的，如果选择的$r服务器出现故障不能连接，将会去连接$db_master。

connect()函数的第三个参数其实是表示当$db_config这台服务器连接故障时是否选择备用的连接。false表示不重连，其它值即表示重新连接。

其核心代码如下

try{
   if(empty($config[‘dsn‘])) {
      $config[‘dsn‘] =   $this->parseDsn($config);
   }
   if(version_compare(PHP_VERSION,‘5.3.6‘,‘<=‘)){
       // 禁用模拟预处理语句
       $this->options[PDO::ATTR_EMULATE_PREPARES] =   false;
   }
   $this->linkID[$linkNum] = new PDO( $config[‘dsn‘], $config[‘username‘], $config[‘password‘],$this->options);
}catch (\PDOException $e) {
   if($autoConnection){ //$autoConnection不为false，而是默认的主服务器
        trace($e->getMessage(),‘‘,‘ERR‘);
            return $this->connect($autoConnection,$linkNum); //出现异常，使用递归函数重新连接
        }elseif($config[‘debug‘]){
            E($e->getMessage());
    }
}

这种方式，对于主从式来说，$r和$m肯定不会相同。因此如果说在读取数据的时候，选择的那台从服务器出现故障的话，那主服务器即是备用的，最后会去主服务器读取。能保证数据读取的时效性。

但是，总感觉现在还不太完善。如果说有多台从服务器，在读取的时候选择的那台从服务器和主服务器都出现了故障，那数据岂不是就读取失败了。这时候如果能再次读取其它的从服务器的话那应该是更有保障。当然了，目前的thinkphp的功能已经相当完善，足够我们使用了。但是还是希望thinkphp以后越来越完善。

Thinkphp分布式数据库连接代码分析

标签：

本文系统来源：http://www.cnblogs.com/chinalorin/p/5859841.html

内容总结

以上是互联网集市为您收集整理的Thinkphp分布式数据库连接代码分析全部内容，希望文章能够帮你解决Thinkphp分布式数据库连接代码分析所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/468837.html

来源：【匿名】

【上一篇】phpmyadmin中访问时出现2002 无法登录 MySQL 服务器【下一篇】PHP 5 数据对象 (PDO) 抽象层与 Oracle

更多 ►

【Thinkphp分布式数据库连接代码分析】教程文章相关的互联网学习教程文章

thinkphp实现数组分页示例

在thinkphp的框架下实现分页。公司的网站基于Thinkphp框架，一直久闻thinkphp的大名，终于有机会实战了。thinkphp是MVC架构的，MVC对于任何ITers来说都不陌生，模型(model)－视图(view)－控制器(controller)。他将逻辑和数据分开处理，少了很多繁琐的过程。其实在官方的资料中已经详细的介绍了怎么分页，传送门：http://document.thinkphp.cn/manual_3_2.html#data_page可是并不适用于数据已经从DB中取出，并且转换为数组的情况，我...

ThinkPHP3快速入门教程三：查询语言

一、查询语言简介： ThinkPHP内置了非常灵活的查询方法，可以快速的进行数据查询操作，查询条件可以用于读取、更新和删除等操作，主要涉及到where方法等连贯相关方法操作即可，此框架查询系统可以解决不同数据库的差异性，因些我们把框架的这一查询方式称之为查询语言。使其查询操作更加简单易懂。二、查询方式：ThinkPHP可以支持直接使用字符串作为查询条件，但是大多数情况推荐使用索引数组或者对象来作为查询条件，因为会更加安...

项目中引用ThinkPHP框架【图】

ThinkPHP是一个宽度、兼容且简单的国产的轻量级框架，具有优良的性能，并且非常注重易用性。　　那么，我们该如何将ThinkPHP引入自己的项目中，使得自己的项目可以使用这款优良的框架呢？　　首先介绍下ThinkPHP框架的目录结构：　　Common：框架的核心函数库　　Conf：框架的核心配置文件目录　　Lang：语言包　　Library：框架的核心资源库目录　　ThinkPHP.php：核心入口文件所以，如果我们想要引用ThinkPHP的框架，非常简单，首...

ThinkPHP无限级分类原理实现留言与回复功能实例

本文所述留言板程序使用了无限级分类的原理，可以实现无限级留言与回复。留言列表gclist保留了留言层次空格，使留言--回复层次分明。分享给大家供大家参考。具体分析如下：功能上，本程序可以实现无限级留言与回复，即对留言回复，对回复的留言回复。当然你也可以作有限制的控制，使其只对留言回复，关键是在模板代码中去掉回复的留言中的“回复该留言”即可。欢迎去拍砖！程序效果如下图所示：完整源码点击此处本站下载。数据表：...

ThinkPhp02【代码】【图】

一、什么是MVC M -Model 编写model类对数据进行操作 V -View 编写html文件，页面呈现 C -Controller 编写类文件（UserAction.class.php）二、ThinkPHP的MVC特点三、ThinkPHP的MVC对应的目录 M 项目目录/应用目录/Lib/Model V 项目目录/应用目录/Tpl C 项目目录/应用目录/Lib/Action四、url访问C 五、url的4种访问方式 1.PATHINFO 模式 -- 重点！！！！！！ http://域名/...

ThinkPHP学习（三）配置PHP5支持MySQL，连接MySQL数据库【图】

配置PHP5支持MySQL打开PHP配置文件“F:\PHP\php5328Win32\php.ini”，查找“extension=php_mysql.dll”，把前面的分号去掉，保存文件，启动服务；却提示“PHP startup: Unable to load dynamic library :F:\PHP\php_mysql.dll”错误，解决办法，打开PHP配置文件“F:\PHP\php5328Win32\php.ini”，查找“extension_dir = "ext"”，把前面的分号去掉，保存文件，启动服务，问题解决；准备测试数据如果你还没有安装MySQL，请先安装MyS...

使用xdebug分析thinkphp框架函数调用图【图】

开发中需要性能调优，使用xdebug分析thinkphp框架函数调用图。关于xdebug的安装参考这2篇NetBeans配置Xdebug 远程调试PHPphp扩展xdebug安装以及用kcachegrind系统分析 1.安装xdebug需要先去http://www.xdebug.org看看一些文档，xdebug作为php扩展安装# http://www.xdebug.org/files/xdebug-2.3.3.tgz# tar -xzf xdebug-2.3.3.tgz# cd xdebug-2.3.3# /usr/local/php/bin/phpize# ./configure --enable-xdebug --with-php-config=/u...

thinkphp自动创建数据对象解析【代码】

thinkphp有一个自动创建数据对象的create方法，核心代码如下 public function create($data=‘‘,$type=‘‘) {// 如果没有传值默认取POST数据if(empty($data)) {$data = I(‘post.‘);}elseif(is_object($data)){$data = get_object_vars($data);}// 判断是否有主键，有代表修改，没有代表插入$type = $type?:(!empty($data[$this->getPk()])?self::MODEL_UPDATE:self::MODEL_INSERT);// 生成数据对象，先获取该模型所有...

thinkphp中在编辑一条数据时不用JS实现自动选中下拉框

<select name="auth_pid" id="auth_pid"> <option value="0" >--请选择--</option> <volist name="auth_list" id="item"> <eq name="item.auth_id" value="$auth_info.auth_pid"> <option value="<{$item.auth_id}>" selected ><{$item.auth_name}></option> <else /> <option value="<{$item.auth_id}>" ><{$item.auth_name}></option> </eq> </volist><...

基于 ThinkPHP 3.2.3 的页面静态化功能的实现【代码】

PHP 的页面静态化有多种实现方式，比如使用输出缓冲（output buffering），该种方式是把数据缓存在 PHP 的缓冲区（内存）中，下一次取数据时直接从缓冲区中读取数据，从而避免了脚本的编译和访问数据库等过程；另一种方式是直接生成静态的 HTML 文件，使用文件读写函数来实现，一些内容不经常改动的页面可以使用静态页面，访客访问到的页面就是真实的 HTML 页面，一些常见的 CMS 会使用该种方法。以第二种方法为例，参考 DedeCMS ...

ThinkPhp 生成静态页面【代码】

//开启静态缓存‘HTML_CACHE_ON‘ => true, //开启缓存‘HTML_CACHE_TIME‘ =>60, //开启缓存时间‘HTML_FILE_SUFFIX‘ => ‘.shtml‘, //生成缓存文件的后缀名‘HTML_PATH‘ => ‘Html‘, //生成缓存文件保存目录‘HTML_CACHE_RULES‘=>array( ‘Index:index‘ => ‘{:controller}/{:action}‘, ‘Seller:index‘ => ‘{:controller}/{:action}‘, ‘Course:index‘ => ‘{:controller}/{:actio...

thinkphp的select和find的区别(转)

做普通PHP项目转thinkphp时，字段自动完整匹配，ajax时前台数据一直取不到，后发现是select和find返回数据集有差异，参考下面方法修改。$this->ajaxReturn($msg[0]); select返回的是二维数组，find返回一维数组。 thinkphp是比较好的php开发框架，能比较快速的开发MVC架构的管理系统，我们需要用到 select()和find()方法，两个方法都能返回数据集数组，但有什么不同呢？先看一下我的代码对比：[php] view plaincopyprint?$tech=M(‘...

thinkphp 支付宝错误 Class 'Think' not found

Class ‘Think‘ not found D:\www\DonatePlatform\ThinkPHP\Extend\Vendor\alipay\lib\alipay_submit.class.php 第 29 行.经过仔细排查发现alipay_submit.class.php中这个方法 function AlipaySubmit($alipay_config) { $this->__construct($alipay_config); }方法名称与类名称相同，其实下面的办法是为了兼容php版本，我的是php5.2.6所以我把AlipaySubmit方法注释掉了，结果没有错误了，可以正常使用，或者你可以改这个方法名...

【ThinkPHP框架学习】(2) --- 后台管理系统如何用iframe点击左边右边局部刷新【图】

如题：在写后台管理系统时，需要实现后台界面的局部动态刷新。左边的导航栏使用a标签进行设置，通过href和target属性的配合，就可以将iframe中的子页实现动态刷新。原理：设这你的 iframe 的名字比如iframe name="main"你左边的页面中 <a href="Article_Manage.asp" target="main">文章管理</a>解读源码：1.在右边嵌套框中写入嵌套代码 iframe 设置为name = iframe 2.然后在左边导航链接中加入...

ThinkPHP分类查询(获取当前分类的子分类，获取父分类，下一级分类)【代码】

获取指定分类的所有子分类ID号//获取指定分类的所有子分类ID号function getAllChildcateIds($categoryID){//初始化ID数组$array[] = $categoryID;do {$ids = ‘‘;$where[‘pid‘] = array(‘in‘,$categoryID);$cate = M(‘cate‘)->where($where)->select();foreach ($cateas$k=>$v){$array[] = $v[‘id‘];$ids .= ‘,‘ . $v[‘id‘];}$ids = substr($ids, 1, strlen($ids));$categoryID = $ids;}while (!empty($cate));$ids =...

首页 / PHP / Thinkphp分布式数据库连接代码分析

Thinkphp分布式数据库连接代码分析

内容导读

内容图文

内容总结

内容备注

内容手机端

【Thinkphp分布式数据库连接代码分析】教程文章相关的互联网学习教程文章

THINKPHP - 相关标签

分布式数据库 - 相关标签

数据库连接 - 相关标签

PHP - 技术教程分类

PHP - 最新教程

PHP - 最热教程