程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 數據庫知識 >> MYSQL數據庫 >> 關於MYSQL數據庫 >> memcached和mysql主從環境下PHP開發

memcached和mysql主從環境下PHP開發

編輯:關於MYSQL數據庫
提示:多memcached和MySQL主從環境下PHP開發.


一般的大站通常做法是:拿著內存當數據庫來用(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'];
}
}
?>


這個是使用程序,大站就差不多是這樣實現的了。

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved