一般的大站通常做法是：拿著內存當數據庫來用(memcached)，以及很好的讀、寫分離，備份機制 (MySQL的主從)。
在這樣的環境下我們怎麼進行PHP開發呢？
剛在Linux的VIM裡使用PHP5寫的一個demo調試通過。
<?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
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);
}
}
?>
簡單的封裝了 memcached 的操作。
在memcached 的多服務器上我的實現思路是這樣的:在把信息添加到 內存服務器的時候.我選擇了手工設置添加到那個服務器.而不用傳統的根據ID自動分配。這樣可以更靈活點。
以內存服務器名 為表示 比如 存 $arr 這個信息到 en 這台 內存服務器 我就這樣寫 $mem->set('en_'.$arr); 明白了吧。
<?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: %s\n",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;
}
}
}
?>
這個是 MySQLi 的封裝. 也就是 讀 從 寫 主 的操作的封裝。
<?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'];
}
}
?>
這個是使用程序，大站就差不多是這樣實現的了。
