MySQL 读写分离如何实现,常见问题及解决方案

一、环境介绍:

LNMP

vmware workstation pro配置了3个虚拟机,均安装了LNMP环境:

Pro  :192.168.0.105        Pro2:192.168.0.106

Pro3:192.168.0.107

  

二、Mysql主从复制同步的实现

mysql读写分离的前提是mysql主从复制,因此,想要实现读写分离,就必须先实现主从复制。

注:Mysql实现主从复制(一主双从)直通车

  

三、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程序实现读写分离

<?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 slaveSelect($sql)
    {
        //该处只是随机获取slave节点的ip,当然,还可以采用其他算法获取slave_ip
        $slave_server = $this->getSlaveIp();
        $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 masterExcute($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 getSlaveIp()
    {
        $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 getRes()
    {
        return $this->res;
    }
}

故障转移:

可以采用定时任务(linux-crontab 或swoole 毫秒定时器)来定时执行一个查询脚本,查询mysql主从状态,如果发现某一个挂掉,并实现脚本内自动切换

 

4、基于macat 实现读写分离和故障自动切换(推荐)

在众多mysql读写分离中间件中,mycat 社区最为活跃,而且版本经过多次迭代,已经非常稳定,因此采用插件形式做读写分离,macat作为首选。

使用mycat 做读写分离的好处在于,不用手动的去选择数据库实例,而是交由macat进行路由分配,而我们所需要做的只是做一些参数的配置。

注:swoole有一个SMProxy,属于mycat的优化版