自己的双站点镜像解决方案，和大家分享一下。跟之前发布在Bo-Blog 安装使用里的有改进。Hack的原理是，修改DB.php中的db_query()函数，检测那些修改数据库内容的sql语句，将该sql保存在temp文件下，并调用镜像站点的相应同步函数，将该sql语句在镜像站点的mysql中运行，然后再在本地数据库中运行。关于文件同步方面，只是局限于bo-blog相关的文件，如data/plugin/temp下的文件，我们也可以称其为bo-blog系统文件。原理是修改global.php中的writetofile()函数，工作机制类似于数据库同步，将要写的文件内容，先写入temp下的某个文件中，并调用镜像站点同步函数，将文件内容写入相应的文件中，然后在写入本地文件。打破同步的方法也很简单，只要将同步函数的文件名改掉就可以了，比如将mirror.php改成mirror.php.bak，相应的同步链就会被打破。同步函数文件mirror.php存放的位置应为blog的安装目录。$config['mirror']的值是镜像站点blog的安装目录。
改进历程：
1、增加系统文件同步
2、在传递同步函数时增加安全性，并加入$config['mirror']的系统参数
3、增加失败重试，防止频繁出现同步出错信息。[最新改进]
下面是hack部分代码。建议不是很熟悉php的，或没有UE或其他专业文本修改工具的人不要尝试！
db.php中db_query()的修改
function db_query($sql, $silence = 0) {   global $querynum, $allqueries, $ignore_db_errors; //#--Mirror Function Begin--#   global $config;   $pack_sql=$sql;   $command=explode(" ",trim($pack_sql));   if (strpos("INSERT UPDATE DELETE CREATE ALTER ",strtoupper($command[0]))!==false)   {        $db_sess="temp/sql_".md5($pack_sql).".txt";     $handler=@fopen($db_sess,"w");     fputs($handler,$pack_sql);     fclose($handler);     chmod($db_sess,0644);          $pack_db_sess=rawurlencode("/".$db_sess);     $mirror_host=$config['mirror'];     $err_count=0;     while ($err_count<10)     {       $url_handler=@fopen($mirror_host."/mirror.php?db=".$pack_db_sess,"r");       $buffer="";       if (is_resource($url_handler))       {         while (!feof($url_handler))         {           $buffer .= fgets($url_handler, 4096);         }         fclose($url_handler);         if (trim($buffer)=="OK")         {           $err_count=10;         }         if(trim($buffer)!="OK" && !$silence && !$ignore_db_errors && $err_count==9)         {           db_halt("Mirror MySQL Query Error[$buffer]"."{".$mirror_host."/mirror.php?db=".$pack_db_sess."}", $sql);           $querynum++;           return $query;         }       }       else       {         break;       }       $err_count++;     }     unlink($db_sess);   } //#--Mirror Function End--#   $query = mysql_query($sql);   if(!$query && !$silence && !$ignore_db_errors) {     db_halt('MySQL Query Error', $sql);   }   $querynum++;   //$allqueries[]=$sql; //For Debug Use Only   return $query; }

global.php中writetofile()的修改
function writetofile ($filename, $data) { //File Writing //#--Mirror Function Begin--#   global $config;   $pack_file=$filename;   $mirrorfile=explode("/",trim($pack_file));   if (strpos('data plugin bak temp',$mirrorfile[0])!==false)   {        $file_sess="temp/file_".md5($data).".txt";     $handler=@fopen($file_sess,"w");     fputs($handler,$data);     fclose($handler);     chmod($file_sess,0644);          $pack_file_sess=rawurlencode("/".$file_sess);     $pack_filename=rawurlencode($filename);     $mirror_host=$config['mirror'];     $err_count=0;     while ($err_count<10)     {       $url_handler=@fopen($mirror_host."/mirror.php?filedata=".$pack_file_sess."&filename=".$pack_filename,"r");       $buffer="";       if (is_resource($url_handler))       {         while (!feof($url_handler))         {           $buffer .= fgets($url_handler, 4096);         }         fclose($url_handler);       }       else       {         break;       }              if (trim($buffer)=="OK")       {         $err_count=10;       }       if ((trim($buffer)!="OK") and ($err_count==9))       {         die("Mirror File Error[$filename]:".$buffer);       }       $err_count++;     }     unlink($file_sess);   } //#--Mirror Function End--#   $filenum=@fopen($filename,"w");   if (!$filenum) {     return false;   }   flock($filenum,LOCK_EX);   $file_data=fwrite($filenum,$data);   fclose($filenum);   return true; }

同步函数mirror.php源码
<?php require_once ("data/config.php"); $sql=""; $file_name=""; $file_data=""; $data=""; if (isset($_GET["db"])) {   $db_sess=$_GET["db"];   $url_handler=@fopen($config['mirror'].$db_sess,"r");   if (is_resource($url_handler))   {     while (!feof($url_handler))     {       $sql .= fgets($url_handler, 4096);     }     fclose($url_handler);   }   else die("ERROR DATA OPEN[$sql]");   db_connect($db_server, $db_username, $db_password, $db_name);   $sql = mysql_query($sql);   if(!$sql) {     die("ERROR SQL[$sql]");   } } if (isset($_GET["filedata"])) {   $file_data=$_GET["filedata"];   $file_name=$_GET["filename"];   $url_handler=@fopen($config['mirror'].$file_data,"r");   if (is_resource($url_handler))   {     while (!feof($url_handler))     {       $data .= fgets($url_handler, 4096);     }     fclose($url_handler);   }   else die("ERROR DATA OPEN[$file_data:$file_name]");   $config_data=$data;   if ($file_name!="data/config.php")   {     $handler=@fopen($file_name,"w");     if (is_resource($handler))     {       flock($handler,LOCK_EX);       fwrite($handler,$config_data);     }     else die("ERROR DATA COPY[$file_data:$file_name]");     fclose($handler);   }         } echo "OK"; function db_connect($dbhost, $dbuser, $dbpw, $dbname=') {   if(!@mysql_connect($dbhost, $dbuser, $dbpw))   {     die("ERROR CONNECT DB!");   }   if (!empty($dbname)) {     $a_result=mysql_select_db($dbname);     if ($a_result) {       if (mysql_get_server_info()>='4.1.0') mysql_query("SET NAMES 'utf8'");     }     return $a_result;   } } ?>
最后编辑： Robin Hoo 编辑于2008/05/29 09:18