MySQL主从复制

    科技2026-02-16  10

      原理: 主数据库进行增删改操作后,相应操作记录的语句会记录到binlog日志文件中从数据库会请求主数据库的binlog日志文件,获取到新的操作语句,然后在自己的从数据库上自动执行相同的操作语句,进而实现主从的同步。

    主从复制过程: (1)Master开启bin-log功能,binlog日志文件用于记录数据库的增删改操作 (2)需要开启三个线程,Master:I/O线程;Slave:I/O线程,SQL线程 (3)Slave start;通过I/O线程连接Master,并且请求某个bin-log,position之后的内容 (4)Master服务器收到Slave I/O线程发过来的日志请求信息,然后Master I/O线程将bin-log内容、position返回给Slave IO线程 (5)Slave服务器收到bin-log日志内容,将bin-log日志内容写入到relay-log中继日志,创建一个master.info文件,该文件记录master IP、用户名、密码、master bin-log名称、bin-log position (6)Slave已经开启了sql线程,由sql线程实时监测relay-log日志内容是否有更新,如果有更新,则解析文件中的sql语句,并在Slave数据库中执行相同的操作语句 注:可以通过show slave status \G 来查看具体的中继日志路径以及连接的master的其他信息。

    主从复制的实现 1、master机器上的配置 (1)vim /etc/my.cnf #修改mysql的配置文件 (2)配置bind-address (配置成master-ip)和 server-id (改成ip后三位即可,也可以改为其他,比如5)以及开启bin-log(默认是已经开启),如下:

    bind-address = 0.0.0.0 server-id = 105

    (3)创建用于slave机器获取master机器上binlog文件的账号(从机器复制用户)

    grant replication slave on *.* to 'mysql'@'%' identified by 'root';

    (4)flush privileges; #刷新数据库 (5)show master status; #查看master状态,并记录下binlog日志文件名以及position

    2、slave机器上的配置 (1)在两台从机器上分别配置MySQL配置文件中的bind-address和server-id

    192.168.0.106机器上: bind-address = 0.0.0.0 server-id = 106 192.168.0.107机器上: bind-address = 0.0.0.0 server-id = 107

    (2)分别在两台从库上操作

    change master to master_host='192.168.0.105', master_port=3306, master_user='root', master_password='12345', master_log_file='mysql-bin.000045', master_log_pos=402;

    (3)分别开启两台从库 (4)验证从库状态 当从库的 IO线程和SQL线程的状态都是yes时,说明主从模式配置成功

    实现MySQL读写分离 原理: (1)让master数据库处理增删改操作(create、insert、delete,update) (2)让slave数据库处理读操作(select)

    注:MySQL读写分离的前提是MySQL主从复制,这样可以保证在master上修改数据,slave同步后,web应用可以读取到slave端的数据。

    实现方式: MySQL读写分离可可以基于第三方插件,也可以通过后端修改代码实现,具体实现读写分离的常见方式有四种: (1)Mysql-Proxy 读写分离 (2)Amoeba 读写分离 (3)Mycat 读写分离 (4)基于程序读写分离(推荐)

    注:由于插件方式性能较低,且每种插件都有其一定缺点,所以建议在后端做读写分离

    读写分离的实现:

    <?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; } }
    Processed: 0.009, SQL: 9