【正文】 讀寫分離的三種方法 PHP 實(shí)現(xiàn)的 Mysql 讀寫分離 MySQL Proxy 安裝與讀寫分離體驗(yàn) mysql 讀寫分離 使用 MySQL Proxy 解決 MySQL 主從同步延遲 MySQL MasterMaster Replication Manager(MMM) mysql+mmm+proxy 實(shí)現(xiàn) mysql 讀寫分離及 HA 讀寫分離的三種方法 1. PHP 代碼法 ,mysql master(write)salver(read)。 2. MySQL Proxy+LUA 腳本法 。 3. 更 HA 方式 :MySQL Proxy+MMM。 PHP 實(shí)現(xiàn)的 Mysql 讀寫分離 本代碼是從 uchome 的代碼修改的，是因?yàn)橐鉀Q uchome 的效率而處理的。 這個(gè)思維其實(shí)很久就有了，只是一直沒有去做，相信也有人有同樣的想法，如 果有類似的，那真的希望提出相關(guān)的建議。 封裝的方式比較簡(jiǎn)單，增加了只讀數(shù)據(jù)庫(kù)連接的接口擴(kuò)展，不使用只讀數(shù)據(jù)庫(kù)也不影響原代碼使用。 有待以后不斷完善。 為了方便，試試建立了 google 的一個(gè)項(xiàng)目： 希望給有需要的朋友帶來(lái)幫助。 PHP 實(shí)現(xiàn)的 Mysql 讀寫分離 主要特性： 簡(jiǎn)單的讀寫分離 一個(gè)主數(shù)據(jù)庫(kù)，可以添加更多的只讀數(shù)據(jù)庫(kù) 讀寫分離但不用擔(dān)心某些特性不支持 缺點(diǎn)：同時(shí)連接兩個(gè)數(shù)據(jù)庫(kù) 英文比較爛，也寫幾個(gè)字吧 php code for mysql read/write split feature: simply rw split one master,can add more slaves support all mysql feature link to the master and slave at the same time PHP 代碼： ?php /**************************************** *** mysqlrwphp version @ 2020416 *** code by hqlulu *** *** *** code modify from (uchome) ****************************************/ class mysql_rw_php { //查詢個(gè)數(shù) var $querynum = 0。 //當(dāng)前操作的數(shù)據(jù)庫(kù)連接 var $link = null。 //字符集 var $charset。 //當(dāng)前數(shù)據(jù)庫(kù) var $cur_db = 39。39。 //是否存在有效的只讀數(shù)據(jù)庫(kù)連接 var $ro_exist = false。 //只讀數(shù)據(jù)庫(kù)連接 var $link_ro = null。 //讀寫數(shù)據(jù)庫(kù)連接 var $link_rw = null。 function mysql_rw_php(){ } function connect($dbhost, $dbuser, $dbpw, $dbname = 39。39。, $pconnect = 0, $halt = TRUE) { if($pconnect) { if(!$thislink = @mysql_pconnect($dbhost, $dbuser, $dbpw)) { $halt amp。amp。 $thishalt(39。Can not connect to MySQL server39。)。 } } else { if(!$thislink = @mysql_connect($dbhost, $dbuser, $dbpw)) { $halt amp。amp。 $thishalt(39。Can not connect to MySQL server39。)。 } } //只讀連接失敗 if(!$thislink amp。amp。 !$halt) return false。 //未初始化 rw 時(shí)，第一個(gè)連接作為 rw if($thislink_rw == null) $thislink_rw = $thislink。 if($thisversion() 39。39。) { if($thischarset) { @mysql_query(SET character_set_connection=$thischarset, character_set_results=$thischarset, character_set_client=binary, $thislink)。 } if($thisversion() 39。39。) { @mysql_query(SET sql_mode=39。39。, $thislink)。 } } if($dbname) { $thisselect_db($dbname)。 } } //連接一個(gè)只讀的 mysql 數(shù)據(jù)庫(kù) function connect_ro($dbhost, $dbuser, $dbpw, $dbname = 39。39。, $pconnect = 0){ if($thislink_rw == null) $thislink_rw = $thislink。 $this link = null。 //不產(chǎn)生 halt 錯(cuò)誤 $this connect($dbhost, $dbuser, $dbpw, $dbname, $pconnect, false)。 if($thislink){ //連接成功 //echo link ro sussess!br。 $thisro_exist = true。 $thislink_ro = $thislink。 if($thiscur_db){ //如果已經(jīng)選擇過數(shù)據(jù)庫(kù)則需要操作一次 @mysql_select_db($thiscur_db, $thislink_ro)。 } }else{ //連接失敗 //echo link ro failed!br。 $thislink = amp。$thislink_rw。 } } //設(shè)置一系列只讀數(shù)據(jù)庫(kù) 并且連接其中一個(gè) function set_ro_list($ro_list){ if(is_array($ro_list)){ //隨機(jī)選擇其中一個(gè) $link_ro = $ro_list[array_rand($ro_list)]。 $thisconnect_ro($link_ro[39。dbhost39。], $link_ro[39。dbuser39。], $link_ro[39。dbpw39。])。 } } function select_db($dbname) { //同時(shí)操作兩個(gè)數(shù)據(jù)庫(kù)連接 $this cur_db = $dbname。 if($thisro_exist){ @mysql_select_db($dbname, $thislink_ro)。 } return @mysql_select_db($dbname, $thislink_rw)。 } function fetch_array($query, $result_type = MYSQL_ASSOC) { return mysql_fetch_array($query, $result_type)。 } function fetch_one_array($sql, $type = 39。39。) { $qr = $this query($sql, $type)。 return $thisfetch_array($qr)。 } function query($sql, $type = 39。39。) { $this link = amp。$thislink_rw。 //判斷是否 select 語(yǔ)句 if($thisro_exist amp。amp。 preg_match (/^(\s*)select/i, $sql)){ $thislink = amp。$thislink_ro。 } $func = $type == 39。UNBUFFERED39。 amp。amp。 @function_exists(39。mysql_unbuffered_query39。) ? 39。mysql_unbuffered_query39。 : 39。mysql_query39。 if(!($query = $func($sql, $thislink)) amp。amp。 $type != 39。SILENT39。) { $thishalt(39。MySQL Query Error39。, $sql)。 } $this querynum++。 return $query。 } function affected_rows() { return mysql_affected_rows($thislink)。 } function error() { return (($thislink) ? mysql_error($thislink) : mysql_error())。 } function errno() { return intval(($thislink) ? mysql_errno($thislink) : mysql_errno())。 } function result($query, $row) { $query = @mysql_result($query, $row)。 return $query。 } function num_rows($query) { $query = mysql_num_rows($query)。 return $query。 } function num_fields($query) { return mysql_num_fields($query)。 } function free_result($query) { return mysql_free_result($query)。 } function insert_id() { return ($id = mysql_insert_id($thislink)) = 0 ? $id : $thisresult($thisquery(SELECT last_insert_id()), 0)。 } function fetch_row($query) { $query = mysql_fetch_row($query)。 return $query。 } function fetch_fields($query) { return mysql_fetch_field($query)。