首页 / PHP / CodeIgniter实现读写分离的方法

CodeIgniter实现读写分离的方法

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了CodeIgniter实现读写分离的方法，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含8119字，纯文字阅读大概需要12分钟。

内容图文

这篇文章主要介绍了CodeIgniter读写分离实现方法,结合实例形式较为详细的分析了CodeIgniter读写分离的相关配置与功能实现技巧,需要的朋友可以参考下

本文实例讲述了CodeIgniter读写分离实现方法。分享给大家供大家参考，具体如下：

当前服务器只做了主从，未配置读写分离，读写分离的功能就只有交给程序来实现，这里主要谈谈Codeigniter怎么实现读写分离，并且需要满足以下两点：

1、读写分离对开发应该透明。

网上有方案通过手动load多个DB来实现读写分离，这样的分离跟业务关联太紧，增加了开发难度也不利于维护，我们要做的是默认读重库，写则写主库，读写分离对开发者透明

2、配置简单。

保留现有的配置方式，通过增加一个数组来配置读写分离，不影响原有使用方式。

思路

1、要实现读写分离最简单的思路就是在最终执行查询的地方根据查询语句判断是插入主库还是读取从库，所以需要找到该函数。

2、应该只连接一次数据库，下次操作该链接应当可复用。也就是连一次重库后所有的读操作都可用，不需再次连接，主库同理。所以我们可以将链接放在CI超级对象中。

3、主从的判断是根据最终执行的SQL语句来判断的，所以数据库配置中的自动链接autoinit参数就不用设置为true了，如果默认连接了而又不需要操作该库就浪费资源了。

4、模型中可以使用$this->db来直接操作查询，不需要其他调整。

5、不直接修改system下的文件

实现读写分离

CI的DB类固定为读取system下的文件，我们可以通过适当的重写来实现。首先是Loader.php，其中的database方法用来加载数据库对象，固定引用了system/database/DB.php文件，我们判断下是否存在自定义DB.php文件，存在则引入。

重写Loader.php

public function database($params = '', $return = FALSE, $active_record = NULL)
{
  $CI =& get_instance();
  if (class_exists('CI_DB') AND $return == FALSE AND $active_record == NULL AND isset($CI->db) AND is_object($CI->db)) {
    return FALSE;
  }
  if(file_exists(APPPATH.'core/database/DB.php')) {
    require_once(APPPATH.'core/database/DB.php');
  } else {
    require_once(BASEPATH.'database/DB.php');
  }
  if ($return === TRUE) {
    return DB($params, $active_record);
  }
  $CI->db = '';
  $CI->db =& DB($params, $active_record);
}
/* End of file MY_Loader.php */
/* Location: ./application/core/MY_Loader.php */

接着我们在application/core下创建database/DB.php，该文件只有一个DB方法，用来读取配置文件并进行初始化工作。同样有两处地方需要重写下：

重写DB.php

//DB_driver.php为所有驱动方式的父类，最终执行查询的方法在该文件中
//第一处修改为判断自定义的DB_driver.php是否存在，存在则引入
if(file_exists(APPPATH.'core/database/DB_driver.php')) {
  require_once(APPPATH.'core/database/DB_driver.php');
} else {
  require_once(BASEPATH.'database/DB_driver.php');
}
//第二处 $params['dbdriver'].'_driver.php' 该文件可不调整，实际未修改该文件，为了方便调试也加了
//mysql驱动对应system/database/drivers/mysql/mysql_driver.php，mysql的最后执行方法在这里，
//包括数据库打开和关闭、查询等,可以该文件增加相应日志查看读写分离是否有效
if(file_exists(APPPATH.'core/database/drivers/'.$params['dbdriver'].'/'.$params['dbdriver'].'_driver.php')) {
  require_once(APPPATH.'core/database/drivers/'.$params['dbdriver'].'/'.$params['dbdriver'].'_driver.php');
} else {
  require_once(BASEPATH.'database/drivers/'.$params['dbdriver'].'/'.$params['dbdriver'].'_driver.php');
}
//将当前group name赋值给param，方便判断
$params['group_name'] = $active_group;
 
/* End of file DB.php */
/* Location: ./application/core/database/DB.php */

整个DB.php调整的也基本上是文件的引入，group name的引入是为了方便后面的判断，不引入则可以通过主机、数据库名称这些来配置。如果想强制关闭autoint，可以在DB.php中删掉下面这段：

if ($DB->autoinit == TRUE)
{
  $DB->initialize();
}

接下来就是最核心的地方。根据查询语句实现读写分离。
DB_driver.php中的simple_query方法可以理解为最后执行SQL语句的方法，我们可以在这里进行数据库链接的判断。

重写DB_driver.php

//增加属性，表示当前组
var $active_group;
//增加属性，使用强制使用主库
var $db_force_master;
//该方法为执行查询的必经之地，我们可以在这里根据类型判断使用哪个链接。
function simple_query($sql)
{
  //load_db_proxy_setting方法这里写在helper中，也可以直接写在该类中，写在helper中则需要在自动加载中加载该helper
  //该方法的作用是根据当前链接group name 和sql读写类型，以及是否强制使用主库判断使用哪个链接。使用主库 OR 重库？
  //主重库的负载均衡，单点故障都可以在这里考虑。也就是根据3个参数返回一个可用的配置数组。
  $proxy_setting = load_db_proxy_setting($this->group_name, $this->is_write_type($sql), $this->db_force_master);
  if(is_array($proxy_setting) && ! empty($proxy_setting)) {
    $proxy_setting_key = key($proxy_setting);
    $this->group_name = $proxy_setting_key;
    //将当前配置重新赋值给类的属性，如果database.php配置的是DSN字符串，则需要在load_db_proxy_setting中做处理
    foreach($proxy_setting[$proxy_setting_key] as $key => $val) {
      $this->$key = $val;
    }
    //定义链接ID为conn_前缀
    $proxy_conn_id = 'conn_'.$proxy_setting_key;
    $CI = & get_instance();
    //赋值给CI超级对象或者直接从CI超级对象中读取
    if(isset($CI->$proxy_conn_id) && is_resource($CI->$proxy_conn_id)) {
      $this->conn_id = $CI->$proxy_conn_id;
    } else {
      $this->conn_id = false;
      $this->initialize();
      $CI->$proxy_conn_id = $this->conn_id;
    }
    //强制只一次有效，下次查询失效，防止一直强制主库
    $this->reset_force_master();
  }
  if ( ! $this->conn_id)
  {
    $this->initialize();
  }
  return $this->_execute($sql);
}
//某些情况会强制使用主库，先执行该方法即可
public function force_master()
{
  $this->db_force_master = TRUE;
}
public function reset_force_master()
{
  $this->db_force_master = FALSE;
}
/* End of file DB_driver.php */
/* Location: ./application/core/database/DB_driver.php */

到这里读写分离即基本实现了，但做事情得善始善终，链接的数据库对象需要关闭，可以在公用控制器中执行完毕后关掉连接。

DB_driver.php中也有close方法，可以考虑下是否可以在该方法中关闭？这里认为是不行的。

关闭数据库链接

class MY_Controller extends CI_Controller 
{
  public function __construct() 
  {
    parent::__construct();
    $this->load->service('common/helper_service', NULL, 'helper');
    //下面这段为关闭CI超级对象中的数据库对象和数据库链接，db的对象Codeigniter.php中会关闭
    register_shutdown_function(function(){
      foreach(get_object_vars($this) as $key => $val) {
        if(substr($key, 0, 3) == 'db_' && is_object($this->{$key}) && method_exists($this->{$key}, 'close')) {
          $this->{$key}->close();
        }
        if(substr($key, 0, 5) == 'conn_' && is_resource($this->{$key})) {
          $this->db->_close($val);
          unset($this->{$key});
        }
      }
    });
  }
}
/* End of file MY_Controller.php */
/* Location: ./application/core/MY_Controller.php */

模型中的使用，为了使每个model中都可使用$this->db，以及不多次连接数据库，这里也是将链接放在CI超级对象中。这里就算不读写分离也可以这么处理，可以很方便的连接多个DB，具体的model要使用其他库只需要在构造函数中传入group name即可。

模型调整

public function __construct($group_name = '')
{
  parent::__construct();
  $this->initDb($group_name);
}
private function initDb($group_name = '')
{
  $db_conn_name = $this->getDbName($group_name);
  $CI = & get_instance();
  if(isset($CI->{$db_conn_name}) && is_object($CI->{$db_conn_name})) {
    $this->db = $CI->{$db_conn_name};
  } else {
    $CI->{$db_conn_name} = $this->db = $this->load->database($group_name, TRUE);
  }
}
private function getDbName($group_name = '')
{
  if($group_name == '') {
    $db_conn_name = 'db';
  } else {
    $db_conn_name = 'db_'.$group_name;
  }
  return $db_conn_name;
}
/* End of file MY_Model.php */
/* Location: ./application/core/MY_Model.php */

最后的数据库配置方式，只需要在原有的基础上配置一个数组即可。是使用双主还是一主多从就看这里的配置方式。最开始想到直接在原配置上加键名来处理，但主与从的对应关系还是没有这样子明了，这里的定义方式决定了load_db_proxy_setting的实现方式。

database.php配置

$_master_slave_relation = array(
  'default_master' => array('default_slave1', 'default_slave2', 'default_slave3'),
);
/* End of file database.php */
/* Location: ./application/config/database.php */

最开始的数据库链接并未放到CI超级对象中，发现load多个模型时每次都会打开链接，所以完成读写分离之后一定要测试，可以在数据库链接打开和关闭的地方查看是否按预期执行(方法对应application/core/database/drivers/mysql/mysql_driver.php中的db_connect和_close)。整个调整过程最重要的两点就是simple_query方法以及构造函数中关闭数据库链接。模型中的调整是为了更方便的链接多个库，未实现读写分离时也是这么调整的，常用的方法独立成一个文件，MY_Model去继承。

实现MYSQL读写分离的中间件挺多，在没有用到这些时可以通过程序上的控制来实现读写分离。当然这里只是实现了读写分离，可以强制使用主库。如果想要更好的分配方式，可以好好想想load_db_proxy_setting中的分配方式。

以上就是本文的全部内容，希望对大家的学习有所帮助，更多相关内容请关注PHP中文网！

内容总结

以上是互联网集市为您收集整理的CodeIgniter实现读写分离的方法全部内容，希望文章能够帮你解决CodeIgniter实现读写分离的方法所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

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

内容手机端

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

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

来源：【匿名】

【上一篇】关于PHP求多项式导数的函数代码【下一篇】PHP 5 数据对象 (PDO) 抽象层与 Oracle

更多 ►

【CodeIgniter实现读写分离的方法】教程文章相关的互联网学习教程文章

php codeigniter (CI) oracle 数据库配置-宋正河整理

database.php123456789101112131415161718$active_group= ‘default‘;$active_record= TRUE; $db[‘default‘][‘hostname‘] = ‘localhost/xe‘;$db[‘default‘][‘username‘] = ‘root‘;$db[‘default‘][‘password‘] = ‘root‘;$db[‘default‘][‘database‘] = ‘‘;$db[‘default‘][‘dbdriver‘] = ‘oci8‘;$db[‘default‘][‘dbprefix‘] = ‘SZH_‘;$db[‘default‘][‘pconnect‘] = false;$db[‘default‘][...

【转载】CodeIgniter与PHP5.6的兼容问题

错误提示：A PHP Error was encounteredSeverity: NoticeMessage: Only variable references should be returned by referenceFilename: core/Common.phpLine Number: 257 原代码：return $_config[0] =& $config;修改后:$_config[0] =& $config;return $_config[0]; 以上内容转载自丸迷人的博客 http://blog.sina.com.cn/s/blog_6718a8f40102vz05.html原文：http://www.cnblogs.com/corvoh/p/4649357.html

***php（codeigniter）中如何重定向

Q:在保存完数据之后需要重定向，防止数据重复提交。我使用$this->方法名();跳转，发现不能达到重定向的效果（地址栏没变）请教高手重定向怎么用A:$this->load->helper(‘url‘);redirect(‘/login/form/‘, ‘refresh‘);通过发送HTTP头，命令客户端转向到您指定的URL。您既可以指定一个完整的URL，也可以对于站内内容，指定基于网站根目录的相对URL。本函数会自动根据您的配置文件，构造出完整的URL。你可以设定第二个参数为 loc...

CodeIgniter框架中关于URL（index.php）的那些事【代码】

最近，在做自己的个人网站时，采用了轻量级的php框架CodeIgniter。乍一看上去，代码清晰简洁，MVC模型非常容易维护。开发时我采用的工具是Netbeans IDE 8.0，当然，本文的内容和开发工具是没有关系的，和我们最后网站采用的服务器有很大的关系。目前最为常用的两款免费web服务器是Apache和Nginx（这两款服务器的比较，可以参考一篇网上的经典文章：http://zyan.cc/nginx_php_v6/）。在我网站开发与上线的过程中，刚好两个服务器都用...

codeigniter启用缓存与清除缓存方法分享

本文介绍了codeigniter启用缓存与清除缓存的方法，依靠网页缓存，网页可以达到近乎静态网页的加载速度，因为将程序输出的结果保存到硬盘上了。 codeigniter启用缓存与清除缓存人方法 codeigniter 支持缓存技术，以达到最快的速度。尽管ci已经相当高效了，但是网页中的动态内容、主机的内存cpu 和数据库读取速度等因素直接影响了网页的加载速度。依靠网页缓存，网页可以达到近乎静态网页的加载速度，因为将程序输出的结果保存到硬...

codeigniter数据库缓存自动过期处理方法

本文介绍了codeigniter数据库缓存自动过期的处理办法，修改了一下db类，在开启缓存时设置一个过期时间，到期自动缓存自动失效。 codeigniter数据库缓存自动过期 codeigniter框架是一个非常小巧的php框架，最近几个项目中一直用。 ci自带数据库文件缓存，但按官方的说法，缓存设置后永不过期，出发你调用方法主动删除。 cache files do not expire. any queries that have been cached will remain cached until you delete them. 修...

CodeIgniter启用缓存和清除缓存的方法_PHP

CI框架 Codeigniter支持缓存技术，以达到最快的速度。尽管CI已经相当高效了，但是网页中的动态内容、主机的内存CPU和数据库读取速度等因素直接影响了网页的加载速度。依靠网页缓存，你的网页可以达到近乎静态网页的加载速度，因为他们将程序输出的结果保存到硬盘上了。缓存是怎么工作的？CI支持每个页面单独缓存，而且可以设置缓存更新时间。当一个网页第一次被加载的时候，缓存文件将被保存到application/cache文件夹。下次访问的...

CodeIgniter的缓存机制与使用方法_PHP教程

数据库缓存数据库缓存类允许你把数据库查询结果保存在文本文件中以减少数据库访问。激活缓存需要三步：在服务器上创建一个可写的目录以便保存缓存文件。在文件 application/config/database.php 中设置其目录。激活缓存特性，可以在文件 application/config/database.php 中设置全局选项，也可以用以本页下面的方法手动设置。一旦被激活，每一次含有数据库查询的页面被加载时缓存就会自动发生。当页面被浏览时CodeIgniter的查询缓存...

让CodeIgniter数据库缓存自动过期的处理的方法_PHP教程

CodeIgniter框架是一个非常小巧的PHP框架。CI自带数据库文件缓存，但按官方的说法，缓存设置后永不过期，除非你调用方法主动删除。Cache files DO NOT expire. Any queries that have been cached will remain cached until you delete them.感觉太弱智了，非常不方便。修改一下db类，在开启缓存时设置一个过期时间，到期自动缓存自动失效。1：CI database/DB_dirver.php 中 1021行 cache_on 函数替换为代码如下:function cache_...

PHP - 技术教程分类

PHP 教程 PHP 简介 PHP 安装 PHP 语法 PHP 变量 PHP echo/print PHP EOF(heredoc) PHP 数据类型 PHP 类型比较 PHP 常量 PHP 字符串 PHP 运算符 PHP If...Else PHP Switch PHP 数组 PHP 数组排序 PHP 超级全局变量 PHP While 循环 PHP For 循环 PHP 函数 PHP 魔术常量 PHP 命名空间 PHP 面向对象 PHP 测验 PHP 表单 PHP 表单验证 PHP 表单 - 必需字段 PHP 完整表单实例 PHP $_GET 变量 PHP $_POST 变量 PHP 多维数组 PHP 日期 PHP 包含 PHP 文件 PHP 文件上传 PHP Cookie PHP Session PHP E-mail PHP Error PHP Exception PHP 过滤器 PHP 7 新特性 PHP MySQL 简介 PHP MySQL 连接 PHP MySQL 创建数据库 PHP MySQL 创建数据表 PHP MySQL 插入数据 PHP MySQL 插入多条数据 PHP MySQL 预处理语句 PHP MySQL 读取数据 PHP MySQL Where PHP MySQL Order By PHP MySQL Update PHP MySQL Delete PHP ODBC AJAX 简介 AJAX PHP AJAX 数据库 AJAX 实时搜索 AJAX 投票 PHP Array PHP Calendar PHP cURL PHP Date PHP Directory PHP Error PHP Filesystem PHP Filter PHP FTP PHP HTTP PHP Mail PHP Math PHP Misc PHP MySQLi PHP PDO PHP String PHP Zip PHP Timezones PHP 图像处理 PHP RESTful PHP PCRE PHP 可用的函数 PHP Composer php 全部

PHP - 最热教程

php如何取出数组的前几个元素 PHP变量什么时候释放 PHP如何实现在数据库随机获取几条记录如何解决php base64解码乱码 php主要用于哪些领域 Laravel 批量插入(insert)数据六款国内优秀免费wordpress主题推荐 React如何从后端获取数据并渲染到前端？纯PHP实现定时器任务（Timer），php实现...php该如何安装pdo_mysql扩展

首页 / PHP / CodeIgniter实现读写分离的方法

CodeIgniter实现读写分离的方法

内容导读

内容图文

内容总结

内容备注

内容手机端

【CodeIgniter实现读写分离的方法】教程文章相关的互联网学习教程文章

php codeigniter (CI) oracle 数据库配置-宋正河整理

【转载】CodeIgniter与PHP5.6的兼容问题

***php（codeigniter）中如何重定向

CodeIgniter框架中关于URL（index.php）的那些事【代码】

codeigniter启用缓存与清除缓存方法分享

codeigniter数据库缓存自动过期处理方法

CodeIgniter启用缓存和清除缓存的方法_PHP

CodeIgniter的缓存机制与使用方法_PHP教程

让CodeIgniter数据库缓存自动过期的处理的方法_PHP教程

CodeIgniter启用缓存和清除缓存的方法_PHP教程

CodeIgniter启用缓存和清除缓存的方法

让CodeIgniter数据库缓存自动过期的处理的方法

让CodeIgniter数据库缓存自动过期的处理的方法_php实例

CodeIgniter启用缓存和清除缓存的方法_php实例

[codeigniter五]、查询缓存

PHP - 技术教程分类

PHP - 最新教程

PHP - 最热教程