memcached 做mysql主從備份方法

 一般的大站通常做法是    拿著內存當數據庫教程來用(memcached).     和很好的讀  寫分離  備份機制 (mysql教程 的主從)

在這樣的環境下我們怎麼進行PHP開發呢.  本人不太會講話.所以還是帖代碼吧. 

剛在linux  的 VIM  裡寫的一個  demo    調試通過.  也同時希望大家拍磚 ,  使用PHP5  寫的. PHP4寫出來怕大家說我落後了

<?php教程
$memcached = array(  //用memcached 的 多 進程模擬 多台memcached 服務器     cn     en   為  內存服務器名
     'cn'=>array('192.168.254.144',11211),
     'en'=>array('192.168.254.144',11212)
     );
$mysql    = array( // mysql 的主從 我的環境是 ： xp 主    linux 從  mysql 5  php5
     'master'=>array('192.168.254.213','root','1','mydz'),
     'slave_1'=>array('192.168.254.144','root','1','mydz')  //可以靈活添加多台從服務器
     );
?>

服務器配置文件: 十分方便的 切換主從.  當主換了  從可以迅速切換為主.  支持 多從服務器   .

[php]
<?php
class Memcached
{
private $mem;
public $pflag=''; // memcached pconnect tag
private function memConnect($serkey){
  require 'config.php';
  $server = $memcached;
  $this->mem = new Memcache;
  $link = !$this->pflag ? 'connect' : 'pconnect' ;
  $this->mem->$link($server[$serkey][0],$server[$serkey][1]) or $this->errordie('memcached connect error');

}

public function set($ser_key,$values,$flag='',$expire=''){
  $this->memConnect($this->tag($ser_key));
  if($this->mem->set($ser_key,$values,$flag,$expire)) return true;
  else return false;
}

public function get($ser_key){
  $this->memConnect($this->tag($ser_key));
  if($var=$this->mem->get($ser_key)) return $var;
  else return false;
}
private function tag($ser_key){
  $tag=explode('_',$ser_key);
  return $tag[0];
}
private function errordie($errmsg){
  die($errmsg);
}
}
?>
[/php]

簡單的封裝了 memcached  的操作. 詳細的時間不多.我要離開公司了tukiz43  

在memcached 的多服務器上.  我的實現思路是這樣的:   在把信息添加到 內存服務器的時候.我選擇了手工設置添加到那個服務器.而不用傳統的根據ID自動分配.
這樣可以更靈活點. 

以內存服務器名 為表示   比如 存  $arr 這個信息到  en 這台 內存服務器 我就這樣寫   $mem->set('en_'.$arr);    明白了吧

[php]
<?php
class Mysql
{
private   $mysqlmaster;
private   $myssqlslave;
private static $auid=0;
public function __construct(){
  require 'config.php';
  $msg = $mysql;
 
  $this->mysqlmaster = new mysqli($msg['master'][0],$msg['master'][1],$msg['master'][2],$msg['master'][3]); //master mysql
   $this->mysqlslave  = $this->autotranscat($msg); // slave mysql

  if(mysqli_connect_errno()){
   printf("Connect failed: %sn",mysqli_connect_error());
   exit();
  }
  if(!$this->mysqlmaster->set_charset("latin1") && !$this->mysqlslave->set_charset("latin1")){
   exit("set charset error");
  }
}

private function autotranscat($mysql){
  session_start();
  $_SESSION['SID']!=0 || $_SESSION['SID']=0   ;
  if($_SESSION['SID'] >=count($mysql)-1) $_SESSION['SID'] = 1;
  else $_SESSION['SID']++;
  $key = 'slave_'.$_SESSION['SID'];
  echo($_SESSION['SID']);
  return new mysqli($mysql[$key][0],$mysql[$key][1],$mysql[$key][2],$mysql[$key][3]);
}

public function mquery($sql){ //insert  update
  if(!$this->mysqlmaster->query($sql)){
   return false;
  }
}

public function squery($sql){
  if($result=$this->mysqlslave->query($sql)){
   return $result;
  }else{
   return false;
  };
}
public function fetArray($sql){
  if($result=$this->squery($sql)){
   while($row=$result->fetch_array(MYSQLI_ASSOC)){
    $resultraa[] = $row;
   };
   return $resultraa;
  }
}
}
?>
[/php]

這個是 mysqli 的封裝.  也就是   讀  從  寫 主  的操作的封裝.

[php]
<?php
require 'init.php';
$mem = new Memcached;
/* $mem->set('en_xx','bucuo');
echo($mem->get('en_xx'));
$mem->set('cn_jjyy','wokao');
echo($mem->get('cn_jjyy'));
*/
$sq = new Mysql;
$sql = "insert into mybb(pid) values(200)";
$mdsql = md5($sql);
if(!$result=$mem->get('cn_'.$mdsql)){
  $sq->mquery("insert into mybb(pid) values(200)"); //插入到主mysql
  $result = $sq->fetArray("select * from mybb"); //查詢 是 從mysql
  foreach($result as $var){
   echo $var['pid'];
  }
  $mem->set('cn_'.$mdsql,$result); //添加到 名為 cn 的 memcached 服務器 
}else{
  foreach($result as $var){
   echo $var['pid'];
  }
}
?>

看個php備份類

<?php
/*******************************************************
**文 件 名:DBManagement.php
**Copyright (c)2007-2008 ** 網站開發部
**文件編號:wtcms-lcq-db-004
**創 建 人:林超旗
**日    期:2007-04-07
**修 改 人:
**日    期:
**描    述:實現數據的導入導出,數據表結構的導入導出
********************************************************/

        //
        //包含Mysql數據庫操作文件
        //
        require_once("MysqlDB.php");
       
/*******************************************************
**類    名:MysqlDB
**類 編 號:lcq-DB-003
**作    用:數據庫鏈接的建立,數據操作,獲取字段個數,記錄條數等
**作    者:林超旗
**編寫日期:(2007-04-07)
********************************************************/
class DBManagement implements IDBManagement
{       
        //
        //當前數據庫中所有的數據表的名字
        //
        private $TablesName;
        //
        //默認路徑
        //
        private $DefaultPath;
        //
        //當前要操作的數據庫名
        //
        private $DatabaseName;
        //
        //操作數據庫的對象
        //
        private $db;
       
/*******************************************************
**方 法 名:__construct
**功能描述:創建一個DBManagement的對象
**輸入參數:$_DatabaseName-string<要操作的數據庫名,如果為空則從配置文件中讀取>
**        $_DefaultPath-string<存儲數據的默認路徑,如果為空則從配置文件中讀取>
**輸出參數:無
**返 回 值:無
**作    者:林超旗
**日    期:2007-04-09
**修 改 人:
**日    期:
********************************************************/       
        function __construct($_DatabaseName="",$_DefaultPath="")//
        {
                require("config.inc.php");
                if(!$_DatabaseName)        {$this->DatabaseName=$dbName;}
                else {$this->DatabaseName=$_DatabaseName;}
               
                if(!$_DefaultPath) {$this->DefaultPath=$defaultPath;}
                else {$this->DefaultPath=$_DefaultPath;}
                $path=realpath($this->DefaultPath);
                $this->DefaultPath=str_replace("","/",$path);
                //$this->db=new DBFactory();
                $this->db=new MysqlDB();
        }
       
/*******************************************************
**方 法 名:GetTablesName
**功能描述:獲取$this->Database的所有數據表的名字
**輸入參數:無        
**輸出參數:無
**返 回 值:-array <$this->TablesName:$this->Database的所有數據表的名字>
**作    者:林超旗
**日    期:2007-04-09
**修 改 人:
**日    期:
********************************************************/       
        protected function GetTablesName()
        {
                $result=$this->db->Query("show table status");
                while($Row=$this->db->NextRecord($result))
                {
                        $this->TablesName[]=$Row["Name"];
                }
                return $this->TablesName;
        }
       
/*******************************************************
**方 法 名:GetDataFileName
**功能描述:獲取與$this->Database的所有數據表對應的數據文件的物理文件名
**輸入參數:無        
**輸出參數:無
**返 回 值:-array <$DataFilesName:$與$this->Database的所有數據表對應的數據文件的物理文件名>
**作    者:林超旗
**日    期:2007-04-09
**修 改 人:
**日    期:
********************************************************/       
        protected function GetDataFileName()
        {
                $this->GetTablesName();
                $count=count($this->GetTablesName());
                for ($i=0;$i<$count;$i++)
                {
                        $DataFilesName[]=$this->DefaultPath."/".$this->TablesName[$i].".txt";
                        //echo $DataFilesName[$i];
                }
                return $DataFilesName;
        }
       
/*******************************************************
**方 法 名:SaveTableStructure
**功能描述:保存數據表的結構到install.sql文件中,目標路徑為$DefaultPath
**輸入參數:無        
**輸出參數:無
**返 回 值:- bool<返回為true表示保存成功;
**                為false表示保存失敗>
**作    者:林超旗
**日    期:2007-04-09
**修 改 人:
**日    期:
********************************************************/       
        protected function SaveTableStructure($text)
        {
                $fileName=$this->DefaultPath."/Install.sql";
                //if(file_exists($fileName))
                //{
                //        unlink($fileName);
                //}
                //echo $text;
                $fp=fopen($fileName,"w+");
                fwrite($fp,$text);
        }
       
/*******************************************************
**方 法 名:RestoreTableStructure
**功能描述:備份$this->Database中所有數據表的結構
**輸入參數:無        
**輸出參數:無
**返 回 值:- bool<返回為true表示所有數據表的結構備份成功;
**                為false表示全部或部分數據表的結構備份失敗>
**作    者:林超旗
**日    期:2007-04-09
**修 改 人:
**日    期:
********************************************************/       
        protected function BackupTableStructure()
        {
                $i=0;
                $sqlText="";
               
                $this->GetTablesName();
                $count=count($this->TablesName);
                //
                //取出所有數據表的結構
                //
                while($i<$count)
                {
                        $tableName=$this->TablesName[$i];       
                        $result=$this->db->Query("show create table $tableName");
                        $this->db->NextRecord($result);
                        //
                        //取出成生表的SQL語句
                        //
                        $sqlText.="DROP TABLE IF EXISTS `".$tableName."`; ";//`
                        $sqlText.=$this->db->GetField(1)."; ";
                        $i++;
                }
                $sqlText=str_replace("r","",$sqlText);
                $sqlText=str_replace("n","",$sqlText);
                //$sqlText=str_replace("'","`",$sqlText);
                $this->SaveTableStructure($sqlText);
        }

/*******************************************************
**方 法 名:RestoreTableStructure
**功能描述:還原$this->Database中所有數據表的結構
**輸入參數:無        
**輸出參數:無
**返 回 值:- bool<返回為true表示所有數據表的結構還原成功;
**                為false表示全部或部分數據表的結構還原失敗>
**作    者:林超旗
**日    期:2007-04-09
**修 改 人:
**日    期:
********************************************************/       
        protected function RestoreTableStructure()
        {
                $fileName=$this->DefaultPath."/Install.sql";
                if(!file_exists($fileName)){echo "找不到表結構文件,請確認你以前做過備份!";exit;}
                $fp=fopen($fileName,"r");
               
                $sqlText=fread($fp,filesize($fileName));
                //$sqlText=str_replace("r","",$sqlText);
                //$sqlText=str_replace("n","",$sqlText);               
                $sqlArray=explode("; ",$sqlText);
                try
                {
                        $count=count($sqlArray);
                        //
                        //數組的最後一個為";",是一個無用的語句,
                        //
                        for($i=1;$i<$count;$i++)
                        {
                                $sql=$sqlArray[$i-1].";";
                                $result=$this->db->ExecuteSQL($sql);
                                if(!mysql_errno())
                                {
                                        if($i%2==0){echo "數據表".($i/2)."的結構恢復成功!n";}
                                }
                                else
                                {
                                        if($i%2==0)
                                        {
                                                echo "數據表".($i/2)."的結構恢復失敗!n";
                                                exit();
                                        }
                                }
                        }
                }
                catch(Exception $e)
                {
                        $this->db->ShowError($e->getMessage());
                        $this->db->Close();
                        return false;
                }
        }
       
/*******************************************************
**方 法 名:ImportData
**功能描述:導入$this->Database中所有數據表的數據從與其同名的.txt文件中,源路徑為$DefaultPath
**輸入參數:無        
**輸出參數:無
**返 回 值:- bool<返回為true表示所有數據表的數據導入成功;
**                為false表示全部或部分數據表的數據導入失敗>
**作    者:林超旗
**日    期:2007-04-09
**修 改 人:
**日    期:
********************************************************/
        function ImportData()
        {
                $DataFilesName=$this->GetDataFileName();
                $count=count($this->TablesName);
                //$this->db->ExecuteSQL("set character set gbk");
                for ($i=0;$i<$count;$i++)
                {
                        //$DataFilesName[$i]=str_replace("","/",$DataFilesName[$i])
                        //echo $DataFilesName[$i];
                        $sqlLoadData="load data infile '".$DataFilesName[$i]."'  into table ".$this->TablesName[$i];
                        $sqlCleanData="delete from ".$this->TablesName[$i];
                        //echo $sql."n";
                        try
                        {
                                //$this->db->ExecuteSQL("set character set utf8");
                                //$this->db->ExecuteSQL("SET NAMES 'utf8'");
                                $this->db->ExecuteSQL($sqlCleanData);
                                $this->db->ExecuteSQL($sqlLoadData);
                                return true;
                                //echo "數據導入成功!";
                        }
                        catch (Exception $e)
                        {
                                $this->db->ShowError($e->getMessage());
                                return false;
                                exit();
                        }
                }       
        }
       
/*******************************************************
**方 法 名:ExportData
**功能描述:導出$this->Database中所有數據表的數據到與其同名的.txt文件中,目標路徑為$DefaultPath
**輸入參數:無        
**輸出參數:無
**返 回 值:- bool<返回為true表示所有數據表的數據導出成功;
**                為false表示全部或部分數據表的數據導出失敗>
**作    者:林超旗
**日    期:2007-04-09
**修 改 人:
**日    期:
********************************************************/
        function ExportData()
        {
                $DataFilesName=$this->GetDataFileName();
                $count=count($this->TablesName);
                try
                {
                        for ($i=0;$i<$count;$i++)
                        {
                                $sql="select * from ".$this->TablesName[$i]."  into outfile '".$DataFilesName[$i]."'";
                                if(file_exists($DataFilesName[$i]))
                                {
                                        unlink($DataFilesName[$i]);
                                }
                                //$this->db->ExecuteSQL("SET NAMES 'utf8'");
                                $this->db->ExecuteSQL($sql);
                        }
                        return true;
                        //echo "數據導出成功!";
                }
                catch (Exception $e)
                {
                        $this->db->ShowError($e->getMessage());
                        return false;
                        exit();
                }
        }
       
/*******************************************************
**方 法 名:BackupDatabase
**功能描述:備份$this->Database中所有數據表的結構和數據
**輸入參數:無        
**輸出參數:無
**返 回 值:- bool<返回為true表示所有數據表的數據庫備份成功;
**                為false表示全部或部分數據表的數據庫備份失敗>
**作    者:林超旗
**日    期:2007-04-10
**修 改 人:
**日    期:
********************************************************/       
        function BackupDatabase()
        {
                try
                {
                        $this->BackupTableStructure();
                        $this->ExportData();
                        return true;
                }
                catch (Exception $e)
                {
                        $this->db->ShowError($e->getMessage());
                        return false;
                        exit();
                }
        }
       
/*******************************************************
**方 法 名:RestoreDatabase
**功能描述:還原$this->Database中所有數據表的結構和數據
**輸入參數:無        
**輸出參數:無
**返 回 值:- bool<返回為true表示所有數據表的數據庫還原成功;
**                為false表示全部或部分數據表的數據庫還原失敗>
**作    者:林超旗
**日    期:2007-04-10
**修 改 人:
**日    期:
********************************************************/       
        function RestoreDatabase()
        {
                try
                {
                        $this->RestoreTableStructure();
                        $this->ImportData();
                        return true;
                }
                catch (Exception $e)
                {
                        $this->db->ShowError($e->getMessage());
                        return false;
                        exit();
                }               
        }
}
?>[/