LVS为MySQL读提供负载均衡配置笔记

数据库在整体平台设计中都有很重要的作用，由此也衍生出了很多骚操作。波波不去一一列举为解决业务场景所使用的各种骚操作，本篇笔记主要记录LVS为MySQL读提供负载均衡配置过程。不见得适合所有的人，大家看看就行。

mysql数据库的读写分离

一、YUM安装LVS和Keepalived

1、配置阿里云的YUM源

  1. #clean OS default repo
  2. mkdir /etc/yum.repos.d/old && mv /etc/yum.repos.d/C* /etc/yum.repos.d/old/
  3. #add local repo
  4. wget -O /etc/yum.repos.d/CentOS-Base.repo http://mirrors.aliyun.com/repo/Centos-7.repo
  5. wget -O /etc/yum.repos.d/epel.repo http://mirrors.aliyun.com/repo/epel-7.repo

2、安装

  1. yum install ipvsadm keepalived

二、配置Keepalived

备注：keepalived配置文件目录/etc/keepalived，从库状态检查脚本目录/etc/keepalived。

  1. ! Configuration File for keepalived
  3. global_defs {
  4.    router_id MHA-A
  5. }
  7. # db Read
  8. vrrp_instance VI_1 {
  9.     state MASTER
  10.     interface eth0
  11.     virtual_router_id 51
  12.     priority 150
  13.     advert_int 6
  14.     authentication {
  15.         auth_type PASS
  16.         auth_pass 123qwe
  17.     }
  18.     virtual_ipaddress {
  19.         192.168.0.21/24
  20.     }
  21. }
  24. # VIP 192.168.0.21
  25. virtual_server 192.168.0.21 3306 {
  26.     delay_loop 10
  27.     lb_algo rr
  28.     lb_kind DR
  29.     nat_mask 255.255.255.0
  30.     protocol TCP
  32.     #sorry_server 192.168.0.235 3306
  34.     real_server 192.168.0.235 3306 {
  35.         weight 1
  36.         TCP_CHECK {
  37.           connect_port 3306
  38.           connect_timeout 10
  39.           nb_get_retry 3
  40.           delay_before_retry 5
  41.         }
  42.         MISC_CHECK {
  43.           misc_path "/etc/keepalived/check_slave.pl 192.168.0.235 3306"
  44.           misc_dynamic
  45.         }
  46.     }
  48.         real_server 192.168.0.236 3306 {
  49.         weight 1
  50.         TCP_CHECK {
  51.           connect_port 3306
  52.           connect_timeout 10
  53.           nb_get_retry 3
  54.           delay_before_retry 5
  55.         }
  56.         MISC_CHECK {
  57.           misc_path "/etc/keepalived/check_slave.pl 192.168.0.236 3306"
  58.           misc_dynamic
  59.         }
  60.     }
  61. }

三、所有从库绑定读VIP

编写脚本/app/scripts/lvs-start-client-read.sh

  1. #!/bin/bash
  2. #real_server.sh
  3. vip=192.168.0.21
  4. open() {
  5.         sudo ifconfig lo:Rvip ${vip}/32 up
  6.         sudo sysctl -w net.ipv4.conf.lo.arp_announce=2
  7.         sudo sysctl -w net.ipv4.conf.lo.arp_ignore=1
  8.         sudo sysctl -w net.ipv4.conf.all.arp_announce=2
  9.         sudo sysctl -w net.ipv4.conf.all.arp_ignore=1
  10. }
  11. close() {
  12.         sudo ifconfig lo:Rvip down
  13.         sudo sysctl -w net.ipv4.conf.lo.arp_announce=0
  14.         sudo sysctl -w net.ipv4.conf.lo.arp_ignore=0
  15.         sudo sysctl -w net.ipv4.conf.all.arp_announce=0
  16.         sudo sysctl -w net.ipv4.conf.all.arp_ignore=0
  17. }
  18. case $1 in
  19. start)
  20.         open
  21. ;;
  22. stop)
  23.         close
  24. ;;
  25. *)
  26.         echo "Usage: $0 need argument  [start|stop]"
  27. ;;
  28. esac

启动Keepalived，观察连接情况。

四、查看LVS状态

  1. watch -n1 ipvsadmin -Ln

上传 /etc/keepalived/check_slave.pl 内容如下：

  1. #!/usr/bin/perl -w
  3. use DBI;
  4. use DBD::mysql;
  7. # CONFIG VARIABLES
  8. $SBM = 200;
  9. $db = "information_schema";
  10. $host = $ARGV[0];
  11. $port = $ARGV[1];
  12. $user = "repl";
  13. $pw = "replpassword";
  15. # SQL query
  16. $query = "show slave status";
  18. $dbh = DBI->connect("DBI:mysql:$db:$host:$port", $user, $pw, { RaiseError => 0,PrintError => 0 });
  20. #print "$db, $host , $port , $user, $pw";
  22. if (!defined($dbh)) {
  23.     #print "connect fail.";
  24.     exit 1;
  25. }
  27. $sqlQuery = $dbh->prepare($query);
  29. $sqlQuery->execute;
  32. $Slave_IO_Running =  "";
  33. $Slave_SQL_Running = "";
  34. $Seconds_Behind_Master = "";
  36. while (my $ref = $sqlQuery->fetchrow_hashref()) {
  38.     $Slave_IO_Running = $ref->{'Slave_IO_Running'};
  39.     $Slave_SQL_Running = $ref->{'Slave_SQL_Running'};
  40.     $Seconds_Behind_Master = $ref->{'Seconds_Behind_Master'};
  42. }
  44. #print "Slave_IO_Running = $Slave_IO_Running\n";
  45. #print "Slave_SQL_Running = $Slave_SQL_Running\n";
  46. #print "Seconds_Behind_Master = $Seconds_Behind_Master\n";
  48. $sqlQuery->finish;
  49. $dbh->disconnect();
  52. if ( $Slave_IO_Running eq "No" || $Slave_SQL_Running eq "No" || $Slave_IO_Running eq "" || $Slave_SQL_Running eq "" ||  $Seconds_Behind_Master eq "NULL" || $Seconds_Behind_Master eq "" ) {
  55. #print "Slave_IO_Running = $Slave_IO_Running\n";
  56. #print "Slave_SQL_Running = $Slave_SQL_Running\n";
  57. #print "Seconds_Behind_Master = $Seconds_Behind_Master\n";
  59.     exit 1;
  61. } else {
  63.     if ( $Seconds_Behind_Master > $SBM ) {
  64.         #print "Seconds_Behind_Master > SBM";
  65.     exit 1;
  66.     } else {
  67.         #print "Seconds_Behind_Master < SBM";
  68.         exit 0;
  69.     }
  71. }

 

你想把广告放到这里吗？

发表评论

您必须 登录 才能发表留言！