一、环境介绍:
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读写分离的实现
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的优化版