mysql實現讀寫分離

一、環境介紹：
LNMP

vmware workstation pro配置了3個虛擬機，均安裝了LNMP環境：

Pro  ：192.168.0.105        Pro2：192.168.0.106

Pro3：192.168.0.107      

 

 

二、Mysql主從復制同步的實現
https://blog.csdn.net/m_nanle_xiaobudiu/article/details/81086243

 

三、Mysql讀寫分離
1、原理

（1）讓master數據庫處理增刪改操作（create、insert、delete，update）。

（2）讓slave數據庫處理讀操作（select）。

注：mysql讀寫分離的前提是mysql主從復制，這樣可以保證在master上修改數據，slave同步后，web應用可以讀取到slave端的數據。

2、實現方式

Mysql讀寫分離可以基於第三方插件，也可以通過后端修改代碼實現，具體實現讀寫分離的常見方式有四種

注：由於插件方式性能較低，且每種插件都有其一定缺點，所以建議在后端做讀寫分離

（1）Mysql-Proxy 讀寫分離

（2）Amoeba 讀寫分離

（3）Mycat 讀寫分離

（4）基於程序讀寫分離（推薦）

3、讀寫分離的實現

  

<?php
class Db
{
    private $res;
    function __construct($sql)
    {
        $queryStr = strtolower(trim(substr($sql,0,6)));
        if ($queryStr == 'select') {
            //如果是查詢操作（select），則連接從數據庫（slave）
            $res = $this->slave_select($sql);
            $this->res = $res;
        } else {
            //如果是增刪改操作（create、insert、delete，update），則連接主數據庫（master）
            $res=$this->master_excute($sql);
            $this->res = $res;
        }
 
    }
 
    /**
     * slave從庫返回sql查詢結果
     * @param $sql
     * @return array
     */
    private function slave_select($sql)
    {
        //該處只是隨機獲取slave節點的ip，當然，還可以采用其他算法獲取slave_ip
        $slave_server = $this->get_slave_ip();
        $dsn = "mysql:host=$slave_server;dbname=test";
        $user = 'root';
        $pass = '123456';
        $pdo = new PDO($dsn, $user, $pass);
        return $pdo->query($sql)->fetchAll(PDO::FETCH_ASSOC);
    }
 
    /**
     * master主庫返回sql執行結果
     * @param $sql
     * @return int
     */
    private function master_excute($sql)
    {
        $master_server = '192.168.0.102';
        $dsn = "mysql:host=$master_server;dbname=test";
        $user = 'root';
        $pass = '123456';
        $pdo = new PDO($dsn, $user, $pass);
        return $pdo->exec($sql);
    }
 
    /**
     * 隨機獲取slave-ip
     * @return mixed
     */
    private function get_slave_ip()
    {
        $slave_ips = ['192.168.0.104','192.168.0.105','192.168.0.106','192.168.0.107','192.168.0.108'];
        $count = count($slave_ips)-1;
        $random_key = mt_rand(0,$count);
        return $slave_ips[$random_key];
    }
 
    /**
     * 獲取結果
     * @return int
     */
    public function get_res()
    {
        return $this->res;
    }
 
 
}