memcached 和 mysql 主從環境下php開發程式碼詳解

一般的大站通常做法是 拿著內存當資料庫來用(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 的操作. 詳細的時間不多.我要離開公司了 

在memcached 的多伺服器上. 我的實現思路是這樣的: 在把信息是這樣的: 在把信息新增到記憶伺服器的時候.我選擇了手動設定新增到那個伺服器.而不用傳統的根據ID自動分配. 
這樣可以更靈活點. 
以記憶伺服器名為表示例如存$arr 這個資訊到en 這台記憶體伺服器我就這樣寫$mem->set('en_'.$arr); 明白了

複製碼=0; 

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(); 

} "latin1") && !$this->mysqlslave->set_charset("latin1")){ 

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中文網（www.php.cn）！