MySQL 主从同步02-percona-toolkit工具(数

作者: 轻飘飘D | 来源:发表于2021-02-24 22:14 被阅读0次

MySQL 主从同步02-percona-toolkit工具(数
MySQL主从同步
主从：MySQL设置主从同步基础设置
MySQL主从介绍、配置主、配置从、测试主从同步
php mysql 读写分离
MySQL主从库
9 MySQL 主从同步
mysql 主从基础知识笔记
高级程序员必知必会，一文详解MySQL主从同步原理
MySQL主从介绍、准备工作、配置主、配置从、测试主从同步

1.下载 percona-toolkit工具 & 安装(xag201,xag202)

[root@xag201 src]# 
wget https://downloads.percona.com/downloads/percona-toolkit/3.3.0/binary/redhat/7/x86_64/percona-toolkit-3.3.0-1.el7.x86_64.rpm

安装该工具依赖的软件包
yum install perl-IO-Socket-SSL perl-DBD-MySQL perl-Time-HiRes perl perl-DBI -y
yum install perl-TermReadKey -y

安装后，percona-toolkit工具的各个组件命令就有有了（输入ht-，按TAB键就会显示）
rpm -ivh percona-toolkit-3.3.0-1.el7.x86_64.rpm

[root@xag201 src]# pt-
pt-align                  pt-duplicate-key-checker  pt-heartbeat              
pt-mext                   pt-pg-summary             pt-sift                   
pt-summary                pt-variable-advisor
pt-archiver               pt-fifo-split             pt-index-usage            
pt-mongodb-query-digest   pt-pmp                    pt-slave-delay            
pt-table-checksum         pt-visual-explain
pt-config-diff            pt-find                   pt-ioprofile              
pt-mongodb-summary        pt-query-digest           pt-slave-find             
pt-table-sync             
pt-deadlock-logger        pt-fingerprint            pt-k8s-debug-collector    
pt-mysql-summary          pt-secure-collect         pt-slave-restart          
pt-table-usage            
pt-diskstats              pt-fk-error-logger        pt-kill                   
pt-online-schema-change   pt-show-grants            pt-stalk                  
pt-upgrade

2.pt-table-checksum使用梳理(用于检测MySQL主、从库的数据是否一致)

在主库执行授权（一定要对主库ip授权(主备都对'root'@'xag201' 授权，授权的用户名和密码可以自行定义，不过要保证这个权限能同时登陆主库和从库）
mysql> 
GRANT SELECT, PROCESS, SUPER, REPLICATION SLAVE,CREATE,DELETE,INSERT,UPDATE ON *.* TO 'root'@'xag201' identified by '123456';

mysql> flush privileges;

在从库上执行授权
mysql> 
GRANT SELECT, PROCESS, SUPER, REPLICATION SLAVE ON *.* TO 'root'@'xag201' IDENTIFIED BY '123456';

mysql> flush privileges;

如下，在主库上执行的一个检查主从数据一致性的命令
(别忘了第一次运行的时候需要添加--create-replicate-table参数，后续再运行时就不需要加了)：
下面命令中的xag201是主库ip
检查的是testdb库下的t1表的数据（当然，命令中也可以不跟表，直接检查某整个库的数据；
如下去掉--tables=t1表，直接检查testdb库的数据）

常用参数解释：
--nocheck-replication-filters ：不检查复制过滤器，建议启用。后面可以用--databases来指定需要检查的数据库。
--no-check-binlog-format : 不检查复制的binlog模式，要是binlog模式是ROW，则会报错。
--replicate-check-only :只显示不同步的信息。
--replicate= ：把checksum的信息写入到指定表中，建议直接写到被检查的数据库当中。
--databases= ：指定需要被检查的数据库，多个则用逗号隔开。
--tables= ：指定需要被检查的表，多个用逗号隔开
h= ：Master的地址
u= ：用户名
p=：密码
P= ：端口

#首次
[root@xag201 src]# pt-table-checksum --nocheck-replication-filters --no-check-binlog-format --replicate=testdb.checksums --create-replicate-table --databases=testdb --tables=t1 h=xag201,u=root,p=123456,P=3306
Checking if all tables can be checksummed ...
Starting checksum ...
*******************************************************************
 Using the default of SSL_verify_mode of SSL_VERIFY_NONE for client
 is deprecated! Please set SSL_verify_mode to SSL_VERIFY_PEER
 possibly with SSL_ca_file|SSL_ca_path for verification.
 If you really don't want to verify the certificate and keep the
 connection open to Man-In-The-Middle attacks please set
 SSL_verify_mode explicitly to SSL_VERIFY_NONE in your application.
*******************************************************************
  at /usr/bin/pt-table-checksum line 332.
*******************************************************************
 Using the default of SSL_verify_mode of SSL_VERIFY_NONE for client
 is deprecated! Please set SSL_verify_mode to SSL_VERIFY_PEER
 possibly with SSL_ca_file|SSL_ca_path for verification.
 If you really don't want to verify the certificate and keep the
 connection open to Man-In-The-Middle attacks please set
 SSL_verify_mode explicitly to SSL_VERIFY_NONE in your application.
*******************************************************************
  at /usr/bin/pt-table-checksum line 332.

# A software update is available:
            TS ERRORS  DIFFS     ROWS  DIFF_ROWS  CHUNKS SKIPPED    TIME TABLE
02-16T20:23:07      0      0        5          0       1       0   0.030 testdb.t1

##非首次
[root@xag201 src]# pt-table-checksum --nocheck-replication-filters --no-check-binlog-format --replicate=testdb.checksums --databases=testdb --tables=t1 h=xag201,u=root,p=123456,P=3306
Checking if all tables can be checksummed ...
Starting checksum ...
            TS ERRORS  DIFFS     ROWS  DIFF_ROWS  CHUNKS SKIPPED    TIME TABLE
02-16T20:23:45      0      0        5          0       1       0   0.019 testdb.t1

解释：
TS ：完成检查的时间。
ERRORS ：检查时候发生错误和警告的数量。
DIFFS ：0表示一致，1表示不一致。当指定--no-replicate-check时，会一直为0，当指定--replicate-check-only会显示不同的信息。
ROWS ：表的行数。
CHUNKS ：被划分到表中的块的数目。
SKIPPED ：由于错误或警告或过大，则跳过块的数目。
TIME ：执行的时间。
TABLE ：被检查的表名。

3.创建 test_scheduler 表

create table test_scheduler
(
  sch_seq int auto_increment not null,
  hostname varchar(50),
  server_id varchar(50),
  sch_createtime datetime,
  primary key(sch_seq)
);

insert into test_scheduler(hostname,server_id,sch_createtime) values(@@hostname,@@server_id,now());


#存储过程
DROP PROCEDURE IF EXISTS  proc_test_scheduler;

DELIMITER $$

create procedure proc_test_scheduler()
LANGUAGE SQL
DETERMINISTIC
MODIFIES SQL DATA
SQL SECURITY DEFINER
begin
delete from test_scheduler where server_id=cast(@@server_id as char(50)) and 
sch_createtime<date_sub(now(),interval 5 minute);
insert into test_scheduler(hostname,server_id,sch_createtime) values(@@hostname,@@server_id,now());
end$$

DELIMITER ;

call proc_test_scheduler();

#每60秒调用一次 proc_test_scheduler()
DROP EVENT IF EXISTS even_test_scheduler;
CREATE EVENT IF NOT EXISTS even_test_scheduler
ON SCHEDULE EVERY 60 SECOND
DO call proc_test_scheduler();

4.查看事件

root@xag201:testdb [:33: ] 41 SQL->
SELECT EVENT_SCHEMA,EVENT_NAME,EVENT_DEFINITION,INTERVAL_FIELD,STATUS,LAST_EXECUTED FROM information_schema.EVENTS\G
*************************** 1. row ***************************
    EVENT_SCHEMA: testdb
      EVENT_NAME: even_test_scheduler
EVENT_DEFINITION: call proc_test_scheduler()
  INTERVAL_FIELD: SECOND
          STATUS: ENABLED
   LAST_EXECUTED: 2021-02-17 00:32:42

root@xag202:testdb [:33: ] 16 SQL->
SELECT EVENT_SCHEMA,EVENT_NAME,EVENT_DEFINITION,INTERVAL_FIELD,STATUS,LAST_EXECUTED FROM information_schema.EVENTS\G
*************************** 1. row ***************************
    EVENT_SCHEMA: testdb
      EVENT_NAME: even_test_scheduler
EVENT_DEFINITION: call proc_test_scheduler()
  INTERVAL_FIELD: SECOND
          STATUS: SLAVESIDE_DISABLED
   LAST_EXECUTED: NULL

5.人为搞出不一致情况

#备库
root@xag202:testdb [:45: ] 7 SQL->stop slave;  

root@xag202:testdb [:45: ] 8 SQL-> reset slave;

root@xag202:testdb [:45: ] 9 SQL->show slave status\G;
*************************** 1. row ***************************
。。。
             Slave_IO_Running: No
            Slave_SQL_Running: No


root@xag201:testdb [:48: ] 49 SQL->show master status;
+---------------+----------+--------------+------------------+-------------------+
| File          | Position | Binlog_Do_DB | Binlog_Ignore_DB | Executed_Gtid_Set |
+---------------+----------+--------------+------------------+-------------------+
| binlog.000023 |    12081 |              |                  |                   |
+---------------+----------+--------------+------------------+-------------------+

root@xag202:testdb [:16: ] 6 SQL->
change master to master_host='xag201', master_port=3306, master_user='repl', master_password='rep123',master_log_file='binlog.000023',master_log_pos=12081;

root@xag202:testdb [:53: ] 13 SQL->start slave;

root@xag202:testdb [:53: ] 14 SQL->show slave status\G;
*************************** 1. row ***************************
。。。
             Slave_IO_Running: Yes
            Slave_SQL_Running: Yes

6.检查不一致 & pt-table-sync用法梳理(高效的同步MySQL表之间的数据)

[root@xag201 ~]# 
pt-table-checksum --nocheck-replication-filters --no-check-binlog-format --replicate=testdb.checksums --databases=testdb --tables=test_scheduler h=xag201,u=root,p=123456,P=3306
---------------------------------------------------------------------------------------------
Checking if all tables can be checksummed ...
Starting checksum ...
            TS ERRORS  DIFFS     ROWS  DIFF_ROWS  CHUNKS SKIPPED    TIME TABLE
02-17T00:57:08      0      1        8          4       1       0   0.015 testdb.test_scheduler
------------------------------------------------------------------------------------------------

参数解释：
--replicate= ：指定通过pt-table-checksum得到的表，这2个工具差不多都会一直用。
--databases= : 指定执行同步的数据库。
--tables= ：指定执行同步的表，多个用逗号隔开。
--sync-to-master ：指定一个DSN，即从的IP，他会通过show processlist或show slave status 去自动的找主。
h= ：服务器地址，命令里有2个ip，第一次出现的是Master的地址，第2次是Slave的地址。
u= ：帐号。
p= ：密码。
--print ：打印，但不执行命令。
--execute ：执行命令。

[root@xag201 ~]# pt-table-sync --replicate=testdb.checksums h=xag201,u=root,p=123456 h=xag202,u=root,p=123456 --print
DELETE FROM `testdb`.`test_scheduler` WHERE `sch_seq`='23' LIMIT 1 /*percona-toolkit src_db:testdb src_tbl:test_scheduler src_dsn:h=xag201,p=...,u=root dst_db:testdb dst_tbl:test_scheduler dst_dsn:h=xag212,p=...,u=root lock:1 transaction:1 changing_src:testdb.checksums replicate:testdb.checksums bidirectional:0 pid:2531 user:root host:xag201*/;
DELETE FROM `testdb`.`test_scheduler` WHERE `sch_seq`='25' LIMIT 1 /*percona-toolkit src_db:testdb src_tbl:test_scheduler src_dsn:h=xag201,p=...,u=root dst_db:testdb dst_tbl:test_scheduler dst_dsn:h=xag212,p=...,u=root lock:1 transaction:1 changing_src:testdb.checksums replicate:testdb.checksums bidirectional:0 pid:2531 user:root host:xag201*/;
DELETE FROM `testdb`.`test_scheduler` WHERE `sch_seq`='27' LIMIT 1 /*percona-toolkit src_db:testdb src_tbl:test_scheduler src_dsn:h=xag201,p=...,u=root dst_db:testdb dst_tbl:test_scheduler dst_dsn:h=xag212,p=...,u=root lock:1 transaction:1 changing_src:testdb.checksums replicate:testdb.checksums bidirectional:0 pid:2531 user:root host:xag201*/;
DELETE FROM `testdb`.`test_scheduler` WHERE `sch_seq`='29' LIMIT 1 /*percona-toolkit src_db:testdb src_tbl:test_scheduler src_dsn:h=xag201,p=...,u=root dst_db:testdb dst_tbl:test_scheduler dst_dsn:h=xag212,p=...,u=root lock:1 transaction:1 changing_src:testdb.checksums replicate:testdb.checksums bidirectional:0 pid:2531 user:root host:xag201*/;

上面命令介绍完了，接下来开始执行修复：
通过（--print）打印出来了修复数据的sql语句，可以手动的在slave从库上执行，
让他们数据保持一致性，这样比较麻烦！
可以直接在master主库上执行修复操作，通过--execute参数，如下：
[root@xag201 ~]# pt-table-sync --replicate=testdb.checksums h=xag201,u=root,p=123456 h=xag202,u=root,p=123456 --execute

如上修复后，再次检查，发现主从库数据已经一致了！
[root@xag201 ~]# pt-table-checksum --nocheck-replication-filters --no-check-binlog-format --replicate=testdb.checksums --databases=testdb --tables=test_scheduler h=xag201,u=root,p=123456,P=3306
-----------------------------------------------------------------------------------------
Checking if all tables can be checksummed ...
Starting checksum ...
            TS ERRORS  DIFFS     ROWS  DIFF_ROWS  CHUNKS SKIPPED    TIME TABLE
02-17T01:03:23      0      0        8          0       1       0   0.014 testdb.test_scheduler
-----------------------------------------------------------------------------------------

7.编写监控脚本，定时检查。当检查到主从数据不一致时，强制修复数据（可选）

[root@xag201 ~]# /usr/bin/pt-table-checksum --nocheck-replication-filters --no-check-binlog-format --replicate=testdb.checksums --databases=testdb  h=xag201,u=root,p=123456,P=3306
---------------------------------------------------------------------------------
Checking if all tables can be checksummed ...
Starting checksum ...
            TS ERRORS  DIFFS     ROWS  DIFF_ROWS  CHUNKS SKIPPED    TIME TABLE
02-17T11:14:07      0      0        5          0       1       0   0.016 testdb.t1
02-17T11:14:07      0      0        8          0       1       0   0.017 testdb.test_scheduler
--------------------------------------------------------------------------------------

[root@xag201 ~]# /usr/bin/pt-table-checksum --nocheck-replication-filters --no-check-binlog-format --replicate=testdb.checksums --databases=testdb  h=xag201,u=root,p=123456,P=3306|awk -F" " '{print $3}'|sed -n '4p'
----------------------------------------
0
----------------------------------------
[root@xag201 ~]# vim pt_testdb.sh
[root@xag201 ~]# chmod +x pt_testdb.sh 

[root@xag201 ~]# ./pt_testdb.sh
data is ok

[root@xag201 ~]# cat /root/pt_testdb.sh
--------------------------------------------------------------------------------------------------------
#!/bin/bash
NUM=$(/usr/bin/pt-table-checksum --nocheck-replication-filters --no-check-binlog-format --replicate=testdb.checksums --databases=testdb  h=xag201,u=root,p=123456,P=3306|awk -F" " '{print $3}'|sed -n '4p')
if [ $NUM -eq 1 ];then
  /usr/bin/pt-table-sync --replicate=testdb.checksums h=xag201,u=root,p=123456 h=xag202,u=root,p=123456 --print
  /usr/bin/pt-table-sync --replicate=testdb.checksums h=xag201,u=root,p=123456 h=xag202,u=root,p=123456 --execute
else
  echo "data is ok"
fi
------------------------------------------------------------------------------------------------------------

检查主从testdb库数据一致性(每隔10秒检查一次）

[root@xag201 ~]# crontab -l
* * * * * /bin/bash -x /root/pt_testdb.sh > /dev/null 2>&1
* * * * * sleep 10;/bin/bash -x /root/pt_testdb.sh > /dev/null 2>&1
* * * * * sleep 20;/bin/bash -x /root/pt_testdb.sh > /dev/null 2>&1
* * * * * sleep 30;/bin/bash -x /root/pt_testdb.sh > /dev/null 2>&1
* * * * * sleep 40;/bin/bash -x /root/pt_testdb.sh > /dev/null 2>&1
* * * * * sleep 50;/bin/bash -x /root/pt_testdb.sh > /dev/null 2>&1

pt-heartbeat监控mysql主从复制延迟梳理

#主库
[root@xag201 ~]# pt-heartbeat --user=root --ask-pass --host=xag201 --create-table -D testdb --interval=3 --update --replace --daemonize

[root@xag201 ~]# ps -ef|grep pt-heartbeat
root       2573      1  0 11:40 ?        00:00:00 perl /usr/bin/pt-heartbeat --user=root --ask-pass --host=xag201 --create-table -D testdb --interval=3 --update --replace --daemonize

root@xag201:testdb [:41: ] 21 SQL->show create table heartbeat \G;
*************************** 1. row ***************************
       Table: heartbeat
Create Table: CREATE TABLE `heartbeat` (
  `ts` varchar(26) NOT NULL,
  `server_id` int(10) unsigned NOT NULL,
  `file` varchar(255) DEFAULT NULL,
  `position` bigint(20) unsigned DEFAULT NULL,
  `relay_master_log_file` varchar(255) DEFAULT NULL,
  `exec_master_log_pos` bigint(20) unsigned DEFAULT NULL,
  PRIMARY KEY (`server_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4
1 row in set (0.00 sec)

说明： heratbeat   表一直在更改ts和position,而ts是我们检查复制延迟的关键。

root@xag201:testdb [:41: ] 22 SQL->select * from heartbeat;
+----------------------------+-----------+---------------+----------+-----------------------+---------------------+
| ts                         | server_id | file          | position | relay_master_log_file | exec_master_log_pos |
+----------------------------+-----------+---------------+----------+-----------------------+---------------------+
| 2021-02-17T11:42:03.008650 |       201 | binlog.000024 |    67548 | binlog.000026         |                 154 |
+----------------------------+-----------+---------------+----------+-----------------------+---------------------+

[root@xag201 ~]# pt-heartbeat -D testdb --table=heartbeat --monitor --host=xag202 --user=root --password=123456
1.01s [  0.02s,  0.00s,  0.00s ]
2.01s [  0.05s,  0.01s,  0.00s ]
0.00s [  0.05s,  0.01s,  0.00s ]
1.00s [  0.07s,  0.01s,  0.00s ]
1.99s [  0.10s,  0.02s,  0.01s ]
0.00s [  0.10s,  0.02s,  0.01s ]
1.00s [  0.12s,  0.02s,  0.01s ]

解释：0表示从没有延迟。 [ 0.00s, 0.00s, 0.00s ] 表示1m,5m,15m的平均值。可以通过--frames去设置

#备库
[root@xag202 ~]# pt-heartbeat -D testdb --table=heartbeat --monitor --host=xag202 --user=root --password=123456
0.00s [  0.00s,  0.00s,  0.00s ]
1.00s [  0.02s,  0.00s,  0.00s ]
0.00s [  0.02s,  0.00s,  0.00s ]
0.00s [  0.02s,  0.00s,  0.00s ]
1.00s [  0.03s,  0.01s,  0.00s ]

pt-heartbeat命令格式
pt-heartbeat [OPTIONS] [DSN] --update|--monitor|--check|--stop

注意：需要指定的参数至少有 --stop，--update，--monitor，--check。
其中--update，--monitor和--check是互斥的，--daemonize和--check也是互斥。
--ask-pass     隐式输入MySQL密码
--charset     字符集设置
--check      检查从的延迟，检查一次就退出，除非指定了--recurse会递归的检查所有的从服务器。
--check-read-only    如果从服务器开启了只读模式，该工具会跳过任何插入。
--create-table    在主上创建心跳监控的表，如果该表不存在，可以自己手动建立，
                  建议存储引擎改成memory。通过更新该表知道主从延迟的差距。
--daemonize   执行时，放入到后台执行
--user=-u，   连接数据库的帐号
--database=-D，    连接数据库的名称
--host=-h，     连接的数据库地址
--password=-p，     连接数据库的密码
--port=-P，     连接数据库的端口
--socket=-S，    连接数据库的套接字文件
--file 【--file=output.txt】   打印--monitor最新的记录到指定的文件，很好的防止满屏幕都是数据的烦恼。
--frames 【--frames=1m,2m,3m】  在--monitor里输出的[]里的记录段，默认是1m,5m,15m。可以指定1个，如：--frames=1s，多个用逗号隔开。可用单位有秒（s）、分钟（m）、小时（h）、天（d）。
--interval   检查、更新的间隔时间。默认是见是1s。最小的单位是0.01s，最大精度为小数点后两位，因此0.015将调整至0.02。
--log    开启daemonized模式的所有日志将会被打印到制定的文件中。
--monitor    持续监控从的延迟情况。通过--interval指定的间隔时间，打印出从的延迟信息，通过--file则可以把这些信息打印到指定的文件。
--master-server-id    指定主的server_id，若没有指定则该工具会连到主上查找其server_id。
--print-master-server-id    在--monitor和--check 模式下，指定该参数则打印出主的server_id。
--recurse    多级复制的检查深度。模式M-S-S...不是最后的一个从都需要开启log_slave_updates，这样才能检查到。
--recursion-method     指定复制检查的方式,默认为processlist,hosts。
--update    更新主上的心跳表。
--replace     使用--replace代替--update模式更新心跳表里的时间字段，这样的好处是不用管表里是否有行。
--stop    停止运行该工具（--daemonize），在/tmp/目录下创建一个“pt-heartbeat-sentinel” 文件。后面想重新开启则需要把该临时文件删除，才能开启（--daemonize）。
--table   指定心跳表名，默认heartbeat。

11.在主库运行监测同步延迟

[root@xag201 ~]# pt-heartbeat -D testdb --table=heartbeat --monitor --host=xag202 --user=root --password=123456
2.00s [  0.03s,  0.01s,  0.00s ]
0.00s [  0.03s,  0.01s,  0.00s ]
0.99s [  0.05s,  0.01s,  0.00s ]
2.00s [  0.08s,  0.02s,  0.01s ]
解释：0表示从没有延迟。 [ 0.00s, 0.00s, 0.00s ] 表示1m,5m,15m的平均值。可以通过--frames去设置。

加上--master-server-id参数（主库my.cnf里配置的server-id值）
[root@xag201 ~]# pt-heartbeat -D testdb --table=heartbeat --monitor --host=xag202 --user=root --password=123456 --master-server-id=201
1.01s [  0.02s,  0.00s,  0.00s ]
2.00s [  0.05s,  0.01s,  0.00s ]
0.00s [  0.05s,  0.01s,  0.00s ]
0.99s [  0.07s,  0.01s,  0.00s ]
1.99s [  0.10s,  0.02s,  0.01s ]

将主库的server-id打印出来（--print-master-server-id）
[root@xag201 ~]# pt-heartbeat -D testdb --table=heartbeat --monitor --host=xag202 --user=root --password=123456 --print-master-server-id
1.00s [  0.02s,  0.00s,  0.00s ] 201
2.00s [  0.05s,  0.01s,  0.00s ] 201
0.00s [  0.05s,  0.01s,  0.00s ] 201
0.99s [  0.07s,  0.01s,  0.00s ] 201

可以使用--check监测一次就退出
注意：使用了--check，就不能使用--monitor
--update，--monitor和--check是互斥的，--daemonize和--check也是互斥

[root@xag201 ~]# pt-heartbeat -D testdb --table=heartbeat --check --host=xag202 --user=root --password=123456 --print-master-server-id
2.00 201

[root@xag201 ~]# pt-heartbeat -D testdb --table=heartbeat --check --host=xag202 --user=root --password=123456
0.00


注意：
如果想把这个输出结果加入自动化监控，那么可以使用如下命令使监控输出写到文件，
然后使用脚本定期过滤文件中的最大值作为预警即可：
注意--log选项必须在有--daemonize参数的时候才会打印到文件中，
且这个文件的路径最好在/tmp下，否则可能因为权限问题无法创建

[root@xag201 ~]# pt-heartbeat -D testdb --table=heartbeat --monitor --host=xag202 --user=root --password=123456 --log=/root/master-slave.txt --daemonize

[root@xag201 ~]# tail -f master-slave.txt 
2.00s [  0.15s,  0.03s,  0.01s ]
0.00s [  0.15s,  0.03s,  0.01s ]
1.00s [  0.17s,  0.03s,  0.01s ]

12.在从库上运行监测同步延迟
(也可以在命令后加上--master-server-id=201或--print-master-server-id，同上操作)

[root@xag202 ~]# pt-heartbeat -D testdb --table=heartbeat --monitor --user=root --password=123456
0.00s [  0.00s,  0.00s,  0.00s ]
0.00s [  0.00s,  0.00s,  0.00s ]
1.00s [  0.02s,  0.00s,  0.00s ]

[root@xag202 ~]# pt-heartbeat -D testdb --table=heartbeat --user=root --password=123456 --check
0.00
[root@xag202 ~]# pt-heartbeat -D testdb --table=heartbeat --monitor --user=root --password=123456 --log=/root/master-slave.txt --daemonize

[root@xag202 ~]# tail -f /root/master-slave.txt
0.99s [  0.02s,  0.00s,  0.00s ]
0.00s [  0.02s,  0.00s,  0.00s ]
0.00s [  0.02s,  0.00s,  0.00s ]

关闭上面执行的heartbeat更新进程

方法一：可以用参数--stop去关闭
[root@xag201 ~]# ps -ef|grep heartbeat
root       2573      1  0 11:40 ?        00:00:01 perl /usr/bin/pt-heartbeat --user=root --ask-pass --host=xag201 --create-table -D testdb --interval=3 --update --replace --daemonize
root       2637      1  0 12:07 ?        00:00:00 perl /usr/bin/pt-heartbeat -D testdb --table=heartbeat --monitor --host=xag202 --user=root --password=123456 --log=/root/master-slave.txt --daemonize

[root@xag201 ~]# pt-heartbeat --stop
Successfully created file /tmp/pt-heartbeat-sentinel

后续要继续开启后台进行的话，记住一定要先把/tmp/pt-heartbeat-sentinel 文件删除，否则启动不了

[root@xag201 ~]# ps -ef|grep heartbeat

方法二：直接kill掉进程pid（推荐这种方法）
[root@xag202 ~]# ps -ef|grep heartbeat
root       4545      1  0 12:18 ?        00:00:00 perl /usr/bin/pt-heartbeat -D testdb --table=heartbeat --monitor --user=root --password=123456 --log=/root/master-slave.txt --daemonize

[root@xag202 ~]# kill -9 4545

[root@xag202 ~]# ps -ef|grep heartbeat

监控脚本

[root@xag201 ~]# cat check-slave-monit.sh
------------------------------------------------------------------------
#!/bin/bash
cat /root/master-slave.txt > /root/master_slave.txt
echo > /root/master-slave.txt
max_time=`cat /root/master_slave.txt |grep -v '^$' |awk '{print $1}' |sort -k1nr |head -1`
NUM=$(echo "$max_time"|cut -d"s" -f1)
if [ $NUM == "0.00" ];then
   echo "Mysql主从数据一致"
else
   echo "Mysql主从同步延迟"
fi

--------------------------------------------------------------------------

[root@xag201 ~]# chmod +x check-slave-monit.sh 

[root@xag201 ~]# ./check-slave-monit.sh 
Mysql主从同步延迟

MySQL 主从同步02-percona-toolkit工具(数
1.下载 percona-toolkit工具 & 安装(xag201,xag202) 2.pt-table-che...
MySQL主从同步
MySQL主从同步（一）——原理详解一、MySQL主从同步简介 MySQL主从同步，即MySQL Replica...
主从：MySQL设置主从同步基础设置
MySQL主从同步机制 MySQL主从同步是在MySQL主从复制(Master-Slave Replication...
MySQL主从介绍、配置主、配置从、测试主从同步
MySQL主从介绍MySQL主从介绍配置主配置主配置从配置从测试主从同步测试主从同步
php mysql 读写分离
Mysql主从同步的原理 Mysql主从同步实战 PHP+MYSQL 读写分离简单实战
MySQL主从库
一、MySQL主从库MySQL的主从复制方案，是数据的传输。只不过MySQL无需借助第三方工具，而是其自身同步复制...
9 MySQL 主从同步
MySQL 主从同步概述 [TOC] MySQL 主从同步介绍主库: 被客户端存储数据访问的库从库: 同步主库...
mysql 主从基础知识笔记
mysql 主从同步 mysql 主从，其实也就是mysql 复制了， mysql 主从复制的原理就是从服务器复制...
高级程序员必知必会，一文详解MySQL主从同步原理
一、MySQL主从同步实现方式 MySQL主从同步是基于Bin Log实现的，而Bin Log记录的是原始SQL语...
MySQL主从介绍、准备工作、配置主、配置从、测试主从同步
目录一、MySQL主从介绍二、准备工作三、配置主四、配置从五、测试主从同步一、MySQL主从介绍 MySQL主...