ecshop改造讀寫分離

前兩天配置好了mysql主從方式，今天就拿ecshop練習讀寫分離。如下代碼僅供學習參考，不成熟的地方，還需完善。

config.php

<?php $db_name   = "ecshop"; $prefix    = "ecs_"; $timezone    = "Europe/Berlin"; $cookie_path    = "/"; $cookie_domain    = ""; $session = "1440"; $_config = array(); //數據庫主服務器設置, 支持多組服務器設置, 當設置多組服務器時, 則會隨機使用某個服務器
$_config['master'][1]['dbhost'] = "192.168.2.175:3306"; $_config['master'][1]['dbname'] = "ecshop"; $_config['master'][1]['dbuser'] = "dragon"; $_config['master'][1]['dbpw'] = "loong"; /* *$_config['master'][2]['dbhost'] = ""; *... */

//數據庫從服務器設置( slave, 只讀 ), 支持多組服務器設置, 當設置多組服務器時, 系統每次隨機使用
$_config['slave'][1]['dbhost'] = "192.168.2.176:3306"; $_config['slave'][1]['dbname'] = "ecshop"; $_config['slave'][1]['dbuser'] = "ivan"; $_config['slave'][1]['dbpw'] = "loong"; $_config['slave'][2]['dbhost'] = "192.168.2.177:3306"; $_config['slave'][2]['dbname'] = "ecshop"; $_config['slave'][2]['dbuser'] = "ivan"; $_config['slave'][2]['dbpw'] = "loong"; define('EC_CHARSET','utf-8'); define('ADMIN_PATH','admin'); define('AUTH_KEY', 'this is a key'); define('OLD_AUTH_KEY', ''); define('API_TIME', ''); ?>

初始化數據鏈接類

/* 初始化數據庫類 * 若是配置了從服務器，則初始化從庫類 */  
    if(count($_config['slave'])) { require(ROOT_PATH . 'includes/cls_mysql_slave.php'); $db = new cls_mysql_slave($_config); }else{ require(ROOT_PATH . 'includes/cls_mysql.php'); $db = new cls_mysql($_config); } 

增長cls_mysql_slave.php從庫類

<?php require(ROOT_PATH . 'includes/cls_mysql.php'); class cls_mysql_slave extends cls_mysql { var $slaveid = null; function set_config($config){ if(!empty($this->config['slave'])) { $this->slaveid = array_rand($this->config['slave']); } parent::set_config($config); } /* 隨機分配從庫鏈接 */
    function set_slave_config() { $this->settings = $this->config['slave'][$this->slaveid]; $this->settings['charset'] = $this->config['charset']; $this->settings['pconnect'] = $this->config['pconnect']; } function slave_connect() { $this->set_slave_config(); $dbhost = $this->settings['dbhost']; $dbuser = $this->settings['dbuser']; $dbpw = $this->settings['dbpw']; $dbname = $this->settings['dbname']; $this->connect($dbhost, $dbuser, $dbpw, $dbname); } function query($sql, $type = '') { // 若是執行查詢操做，則執行從庫鏈接
        if($this->slaveid && strtoupper(substr($sql, 0 , 6)) == 'SELECT') { $this->slave_connect(); }else{ parent::set_config($this->config); $dbhost = $this->settings['dbhost']; $dbuser = $this->settings['dbuser']; $dbpw = $this->settings['dbpw']; $dbname = $this->settings['dbname']; $this->connect($dbhost, $dbuser, $dbpw, $dbname); } return parent::query($sql, $type); } /* 刪除失敗鏈接*/
    function del_error_link(){ unset($this->config['slave'][$this->slaveid]); $this->set_config($this->config); $this->set_slave_config(); $dbhost = $this->settings['dbhost']; $dbuser = $this->settings['dbuser']; $dbpw = $this->settings['dbpw']; $dbname = $this->settings['dbname']; $this->connect($dbhost, $dbuser, $dbpw, $dbname); } }

cls_mysql.php文件類修改

<?php if (!defined('IN_ECS')) { die('Hacking attempt'); } class cls_mysql { var $link_id    = NULL; var $settings   = array(); var $queryCount = 0; var $linkCount = 0; var $queryTime  = ''; var $queryLog   = array(); var $max_cache_time = 300; // 最大的緩存時間，以秒爲單位

    var $cache_data_dir = 'temp/query_caches/'; var $root_path      = ''; var $error_message  = array(); var $platform       = ''; var $version        = ''; var $dbhash         = ''; var $starttime      = 0; var $timeline       = 0; var $timezone       = 0; var $mysql_config_cache_file_time = 0; var $mysql_disable_cache_tables = array(); // 不容許被緩存的表，遇到將不會進行緩存
    var $config = array(); function __construct($config, $charset = 'utf8', $pconnect = 0, $quiet = 0) { $this->cls_mysql($config, $charset, $pconnect, $quiet); } function cls_mysql($config, $charset = 'utf8', $pconnect = 0, $quiet = 0) { if(!empty($config)) { $config['charset'] = $charset; $config['pconnect'] = $pconnect; $this->config = $config; } if (defined('EC_CHARSET')) { $charset = strtolower(str_replace('-', '', EC_CHARSET)); } if (defined('ROOT_PATH') && !$this->root_path) { $this->root_path = ROOT_PATH; } $this->set_config($this->config); if ($quiet) { $dbhost = $this->settings['dbhost']; $dbuser = $this->settings['dbuser']; $dbpw = $this->settings['dbpw']; $dbname = $this->settings['dbname']; $this->connect($dbhost, $dbuser, $dbpw, $dbname, $charset, $pconnect, $quiet); } } //隨機分配數據庫鏈接
    function set_config($config) { $sid = array_rand($config['master']); $settings = $config['master'][$sid]; $settings['sid'] = $sid; $settings['charset'] = $this->config['charset']; $settings['pconnect'] = $this->config['pconnect']; $this->settings = $settings; } function connect($dbhost, $dbuser, $dbpw, $dbname = '', $charset = 'utf8', $pconnect = 0, $quiet = 0) { if ($pconnect) { if (!($this->link_id = @mysql_pconnect($dbhost, $dbuser, $dbpw))) { if (!$quiet) { $this->ErrorMsg("Can't pConnect MySQL Server!"); } return false; } } else { if (PHP_VERSION >= '4.2') { $this->link_id = @mysql_connect($dbhost, $dbuser, $dbpw, true); } else { $this->link_id = @mysql_connect($dbhost, $dbuser, $dbpw); mt_srand((double)microtime() * 1000000); // 對 PHP 4.2 如下的版本進行隨機數函數的初始化工做
 } if (!$this->link_id) { if (!$quiet) { //鏈接超過10次，中斷鏈接，拋出錯誤 
                    if($this->linkCount>9){ $this->ErrorMsg("Can't Connect MySQL Server!"); } $this->linkCount++; $this->del_error_link(); } return false; } } $this->dbhash  = md5($this->root_path . $dbhost . $dbuser . $dbpw . $dbname); $this->version = mysql_get_server_info($this->link_id); /* 若是mysql 版本是 4.1+ 以上，須要對字符集進行初始化 */
        if ($this->version > '4.1') { if ($charset != 'latin1') { mysql_query("SET character_set_connection=$charset, character_set_results=$charset, character_set_client=binary", $this->link_id); } if ($this->version > '5.0.1') { mysql_query("SET sql_mode=''", $this->link_id); } } $sqlcache_config_file = $this->root_path . $this->cache_data_dir . 'sqlcache_config_file_' . $this->dbhash . '.php'; @include($sqlcache_config_file); $this->starttime = time(); if ($this->max_cache_time && $this->starttime > $this->mysql_config_cache_file_time + $this->max_cache_time) { if ($dbhost != '.') { $result = mysql_query("SHOW VARIABLES LIKE 'basedir'", $this->link_id); $row    = mysql_fetch_assoc($result); if (!empty($row['Value']{1}) && $row['Value']{1} == ':' && !empty($row['Value']{2}) && $row['Value']{2} == "\\") { $this->platform = 'WINDOWS'; } else { $this->platform = 'OTHER'; } } else { $this->platform = 'WINDOWS'; } if ($this->platform == 'OTHER' && ($dbhost != '.' && strtolower($dbhost) != 'localhost:3306' && $dbhost != '127.0.0.1:3306') || (PHP_VERSION >= '5.1' && date_default_timezone_get() == 'UTC')) { $result = mysql_query("SELECT UNIX_TIMESTAMP() AS timeline, UNIX_TIMESTAMP('" . date('Y-m-d H:i:s', $this->starttime) . "') AS timezone", $this->link_id); $row    = mysql_fetch_assoc($result); if ($dbhost != '.' && strtolower($dbhost) != 'localhost:3306' && $dbhost != '127.0.0.1:3306') { $this->timeline = $this->starttime - $row['timeline']; } if (PHP_VERSION >= '5.1' && date_default_timezone_get() == 'UTC') { $this->timezone = $this->starttime - $row['timezone']; } } $content = '<' . "?php\r\n" .
                       '$this->mysql_config_cache_file_time = ' . $this->starttime . ";\r\n" .
                       '$this->timeline = ' . $this->timeline . ";\r\n" .
                       '$this->timezone = ' . $this->timezone . ";\r\n" .
                       '$this->platform = ' . "'" . $this->platform . "';\r\n?" . '>'; @file_put_contents($sqlcache_config_file, $content); } /* 選擇數據庫 */
        if ($dbname) { if (mysql_select_db($dbname, $this->link_id) === false ) { if (!$quiet) { $this->ErrorMsg("Can't select MySQL database!"); } return false; } else { return true; } } else { return true; } } ......

    /* 刪除失敗鏈接*/
    function del_error_link(){ unset($this->config['master'][$this->settings['sid']]); $this->set_config($this->config); $dbhost = $this->settings['dbhost']; $dbuser = $this->settings['dbuser']; $dbpw = $this->settings['dbpw']; $dbname = $this->settings['dbname']; $this->connect($dbhost, $dbuser, $dbpw, $dbname); } }

轉載：http://blog.csdn.net/very_loong/article/details/7999895