一般的大站通常做法是 拿著內存當資料庫來用(memcached). 和很好的讀 寫分離 備份機制 (mysql 的主從) 在這樣的環境下我們怎麼進行PHP開發呢。
$memcached = array( //用memcached 的多進程模擬多台memcached 伺服器cn en 為記憶伺服器名稱
'cn'=>array('192.168.254.144',11211155%' =>array('192.168.254.144',11212)
);
$mysql = array( // mysql 的主從我的環境是: xp 主linux 從mysql 5 php5
'master'19.16868. 254.213','root','1','mydz'),
'slave_1'=>array('192.168.254.144','root','1','mydz') //可以靈活增加多個從伺服器
);
?>
複製程式碼如下:
複製程式碼如下:
{
private $mem;
public $pflag=''; // memcached pconnect tag
private function memConnect($serkey){
require 'config.php'; = new Memcache;
$link = !$this->pflag ? 'connect' : 'pconnect' ;
$this->mem->$link($server[$serkey][0],$server[$serkey] [1]) 或 $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];
} errmsg);
}
}
?>
在memcached 的多伺服器上. 我的實現思路是這樣的: 在把信息是這樣的: 在把信息新增到記憶伺服器的時候.我選擇了手動設定新增到那個伺服器.而不用傳統的根據ID自動分配.
這樣可以更靈活點.
以記憶伺服器名為表示例如存$arr 這個資訊到en 這台記憶體伺服器我就這樣寫$mem->set('en_'.$arr); 明白了
public function __construct(){
require 'config.php';
$msg = $mysql;
$this->mysqlmaster = new mysqli($msg['master'][0],$msg[0],$msg[0],$msg[0],$msg[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();
exit("set charset error");
}
}
private function autotranscat($my)( $_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){
}
public function squery($g){
} >query($sql)){
return $result;
}else{
return false;
};
}
public function fetArray($sql){$
}
public function fetArray($sql){$
}
public function fetArray($sql){$
if($result ){
while($row=$result->fetch_array(MYSQLI_ASSOC)){
$resultraa[] = $row;
};
return $resultraa
}封裝. 也就是讀從寫主的操作的封裝.
require 'init.php';
$mem = new Memcached;
/* $mem->set('en_xx','bucuo');
echo($mem->get('en_xx'));
echo($mem->get('en_xx')); $ mem->set('cn_jjyy','wokao');
echo($mem->get('cn_jjyy'));
*/
$sq = new Mysql;
$ = "insert 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中文網(m.sbmmt.com)!