Keepalive之MySQL故障自动切换脚本


MySQL架构为master-slave(主从),master故障自动切换到slave上。当然也可以设置为双master,但这里有个弊端:就是当主的压力很大时,从上延时很大,比如落后2000秒,此时主挂了,从接管(VIP漂移到从),用户刚才发表的文章,此时因为同步延时大,还没复制过来,于是用户又发表了一篇文章,当原来的master修好后,因从的IO和SQL线程还在开启状态,还会继续同步刚才没有同步复制完的数据,这时有可能把用户新发表的文章更改掉,造成用户数据丢失。

考虑到这种情况,我这里还是用的master-slave(主从)架构。

keepalive安装很简单,这里不再啰嗦。主要看下配置文件和脚本:

  1. # more /etc/keepalived/keepalived.conf  
  2. global_defs { 
  3.    router_id KeepAlive_Mysql 
  4. }  
  5.  
  6. vrrp_script check_run { 
  7. script "/root/sh/mysql_check.sh" 
  8. interval 300
  9.  
  10. vrrp_sync_group VG1 { 
  11. group { 
  12. VI_1 
  13.  
  14. vrrp_instance VI_1 { 
  15.     state BACKUP 
  16.     interface eth0   
  17.     virtual_router_id 51 
  18.     priority 100   
  19.     advert_int 1 
  20.     nopreempt 
  21.     authentication { 
  22.         auth_type PASS 
  23.         auth_pass 1111 
  24.     } 
  25.     track_script { 
  26.     check_run 
  27.     } 
  28.  
  29.     notify_master /root/sh/master.sh 
  30.     notify_backup /root/sh/backup.sh 
  31.     notify_stop /root/sh/stop.sh 
  32.  
  33.     virtual_ipaddress { 
  34.         192.168.8.150 
  35.     } 
notify_master <STRING>|<QUOTED-STRING>    # 状态改变为MASTER后执行的脚本
notify_backup <STRING>|<QUOTED-STRING>    # 状态改变为BACKUP后执行的脚本
notify_fault <STRING>|<QUOTED-STRING>    # 状态改变为FAULT后执行的脚本
notify_stop <STRING>|<QUOTED-STRING>    # VRRP停止后后执行的脚本
notify <STRING>|<QUOTED-STRING>        # (1)任意状态改变后执行的脚本

下面解释下这4个脚本的用法:

mysql_check.sh(健康检查脚本,当发现mysql连接不上,会把keepalive进程关闭,并切换。)
  1. # more mysql_check.sh  
  2. #!/bin/bash 
  3.  
  4. . /root/.bash_profile 
  5.  
  6. count=1 
  7.  
  8. while true 
  9. do 
  10.  
  11. mysql -e "show status;" > /dev/null 2>&1 
  12. i=$? 
  13. ps aux | grep mysqld | grep -v grep > /dev/null 2>&1 
  14. j=$? 
  15. if [ $i = 0 ] && [ $j = 0 ] 
  16. then 
  17.    exit 0 
  18. else 
  19.    if [ $i = 1 ] && [ $j = 0 ] 
  20.    then 
  21.        exit 0 
  22.    else 
  23.         if [ $count -gt 5 ] 
  24.         then 
  25.               break 
  26.         fi 
  27.    let count++ 
  28.    continue 
  29.    fi 
  30. fi 
  31.  
  32. done 
  33.  
  34. /etc/init.d/keepalived stop 
 master.sh(状态改变为MASTER后执行的脚本)  (首先判断同步复制是否执行完毕,如果未执行完毕,等1分钟后,不论是否执行完毕,都跳过,并停止同步复制进程。) (其次,更改前端程序连接的业务账号admin的权限和密码,并记录当前切换以后的日志和POS点。)
  1. # more master.sh 
  2. #!/bin/bash 
  3.  
  4. . /root/.bash_profile 
  5.  
  6. Master_Log_File=$(mysql -e "show slave status\G" | grep -w Master_Log_File | awk -F": " '{print $2}') 
  7. Relay_Master_Log_File=$(mysql -e "show slave status\G" | grep -w Relay_Master_Log_File | awk -F": " '{print $2}') 
  8. Read_Master_Log_Pos=$(mysql -e "show slave status\G" | grep -w Read_Master_Log_Pos | awk -F": " '{print $2}') 
  9. Exec_Master_Log_Pos=$(mysql -e "show slave status\G" | grep -w Exec_Master_Log_Pos | awk -F": " '{print $2}') 
  10.  
  11. i=1 
  12.  
  13. while true 
  14. do 
  15.  
  16. if [ $Master_Log_File = $Relay_Master_Log_File ] && [ $Read_Master_Log_Pos -eq $Exec_Master_Log_Pos ] 
  17. then 
  18.    echo "ok" 
  19.    break 
  20. else 
  21.    sleep 1 
  22.  
  23.    if [ $i -gt 60 ] 
  24.    then 
  25.       break 
  26.    fi 
  27.    continue 
  28.    let i++ 
  29. fi 
  30. done 
  31.  
  32. mysql -e "stop slave;" 
  33. mysql -e "flush logs;GRANT ALL PRIVILEGES ON *.* TO 'admin'@'%' IDENTIFIED BY 'admin';flush privileges;" 
  34. mysql -e "show master status;" > /tmp/master_status_$(date "+%y%m%d-%H%M").txt 
backup.sh(状态改变为BACKUP后执行的脚本)
  1. # more backup.sh  
  2. #!/bin/bash 
  3.  
  4. . /root/.bash_profile 
  5.  
  6. mysql -e "GRANT ALL PRIVILEGES ON *.* TO 'admin'@'%' IDENTIFIED BY '1q2w3e4r';flush privileges;" 
 stop.sh(keepalived停止后后执行的脚本) (首先把admin密码更改掉) (其次,设置参数,保证不丢失数据) (最后,查看是否还有写操作,不论是否执行完毕,1分钟后都退出。)
  1. # more stop.sh  
  2. #!/bin/bash 
  3.  
  4. . /root/.bash_profile 
  5.  
  6. mysql -e "GRANT ALL PRIVILEGES ON *.* TO 'admin'@'%' IDENTIFIED BY '1q2w3e4r';flush privileges;" 
  7. mysql -e "set global innodb_support_xa=1;" 
  8. mysql -e "set global sync_binlog=1;" 
  9. mysql -e "set global innodb_flush_log_at_trx_commit=1;" 
  10.  
  11. M_File1=$(mysql -e "show master status\G" | awk -F': ' '/File/{print $2}') 
  12. M_Position1=$(mysql -e "show master status\G" | awk -F': ' '/Position/{print $2}') 
  13. sleep 1 
  14. M_File2=$(mysql -e "show master status\G" | awk -F': ' '/File/{print $2}') 
  15. M_Position2=$(mysql -e "show master status\G" | awk -F': ' '/Position/{print $2}') 
  16.  
  17. i=1 
  18.  
  19. while true 
  20. do 
  21.  
  22. if [ $M_File1 = $M_File2 ] && [ $M_Position1 -eq $M_Position2 ] 
  23. then 
  24.    echo "ok" 
  25.    break 
  26. else 
  27.    sleep 1 
  28.  
  29.    if [ $i -gt 60 ] 
  30.    then 
  31.       break 
  32.    fi 
  33.    continue 
  34.    let i++ 
  35. fi 
  36. done 

有兴趣的朋友可以测试下,有问题及时交流。

相关内容