前言
新建两个数据库, 分别为 192.168.220.132:3001, 192.168.220.132:3002
设置 192.168.220.132:3001 为 master, 192.168.220.132:3002 为 slave
配置文件如下
然后使用 mysqld --initialize 来初始化 data 目录, 以及相关基础数据库
这里会为 root 账户创建一个随机的密码, 用于后面的登录
然后是修改 root 的密码信息, 可访问客户端的信息
master 和 slave 启动好了之后, 在 slave 上面执行如下命令, 配置 master 的相关信息
change master to master_host='192.168.220.132', master_port=3301, master_user='root', master_password='root', master_log_file='mysql-master.000006', master_log_pos=154;
start slave;
show slave status;
假设我们这里测试数据表如下
CREATE TABLE `tz_test_02` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT,
`field1` varchar(128) DEFAULT NULL,
`field2` varchar(128) DEFAULT NULL,
PRIMARY KEY (`id`) USING BTREE,
KEY `field_1` (`field1`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=12 DEFAULT CHARSET=utf8
基础数据如下
master 这边 binlog 的处理
我们这里测试执行 sql 如下, 我们这里 着重关注第二条 insert 语句的相关处理
delete from tz_test_02 where id = 11;
INSERT INTO `tz_test_02`(`id`, `field1`, `field2`) VALUES (11, 'field11', '11');
在提交事务的时候, 会唤醒 BinlogSender 这边的相关逻辑处理
然后 Binlog_sener 这边被唤醒, 开始处理发送 binlog 的相关处理
然后这里会遍历新增的 event, 将需要传递的 event 传输到 slave
这里会依次遍历几个 event, 类型分别为 Anonymous_Gtid, Query, Table_map, Write_rows, Xid
这里的 WRITE_ROWS_EVENT 对应的 position 为 8889
然后 master 的 binlog 中信息如下, 可以看到 8889 对应的 event 为 WRITE_ROWS_EVENT
slave 这边 binlog 的处理
然后 slave 这边会收到相关的几个 event, Anonymous_Gtid, Query, Table_map, Write_rows, Xid 这里我们主要关心 WRITE_ROWS_EVENT
这里将接收过来的 WRITE_ROWS_EVENT 添加到 Relay_log_info 中, 其是对应于一段带缓冲的文件映射
slave 这边的 relay_log 的 apply 的处理如下, 相当于拿到对应的 binlog 之后, 处理相关的业务处理, 对于我们这里的 WRITE_ROWS_EVENT 就是根据目标语句, 或者Write_rows 新增业务记录
slave 这边 handleSlaveSql 的线程
slave reapply relay_log 的线程如下, 只负责处理该部分的业务
该线程是在 “start slave” 命令的处理中执行的, 新建了 handleSlaveSql 的线程
另外可以看出 这个 replication 过程时候近乎实时的
中间空隙是 master 这边遍历发送 binlog, slave 这边接受 binlog, 并执行
完
