mha 0.57 安装

古城微笑少年丶 2022-06-06 09:57 220阅读 0赞

官网下载。

安装依赖包:

yum install perl-DBD-MySQL perl-Config-Tiny perl-Log-Dispatch perl-Parallel-ForkManager perl-Time-HiRes -y

如果提示有的包没有找到。

需要运行

yum install epel-release -y

安装客户端：

rpm -ivh mha4mysql-node-0.57-0.el7.noarch.rpm

管理端（安管理端前需要先安客户端）

yum localinstall mha4mysql-manager-0.57-0.el7.noarch.rpm

如果管理端各种报错，可以试试源码安装。

tar -zxvf mha4mysql-manager-0.57.tar.gz

cd mha4mysql-manager-0.57

perl Makefile.PL

make

make install

所有节点需要ssh 无密登陆

mha 配制文件如下

\[server default\]  
manager\_workdir=/data0/mha/app1  
manager\_log=/data0/mha/app1/logs/manager.log  
master\_binlog\_dir=/data0/mha/app1/mysql  
\#master\_ip\_failover\_script= /usr/local/bin/master\_ip\_failover  
\#master\_ip\_online\_change\_script= /usr/local/bin/master\_ip\_online\_change  
password=123456  
user=lixiaomeng  
ping\_interval=2  
remote\_workdir=/tmp  
repl\_password=123456  
repl\_user=lixiaomeng  
\#report\_script=/usr/local/send\_report  
\#secondary\_check\_script= /usr/local/bin/masterha\_secondary\_check -s server03 -s server02              
shutdown\_script=""  
ssh\_user=root  
  
  
\[server1\]  
hostname=192.168.10.78  
port=6000  
  
  
\[server2\]  
hostname=192.168.10.77  
port=6000  
candidate\_master=1  
check\_repl\_delay=0  
  
  
\[server2\]  
hostname=192.168.10.79  
port=6000

master\_ip\_failover 脚本

\#!/usr/bin/env perl  
use strict;  
use warnings FATAL => 'all';  
use Getopt::Long;  
my (  
$command, $ssh\_user, $orig\_master\_host, $orig\_master\_ip,  
$orig\_master\_port, $new\_master\_host, $new\_master\_ip, $new\_master\_port  
);  
my $vip = '10.10.1.20';\#Virtual IP  
my $gateway = '10.10.1.1';\#Gateway IP  
my $interface = 'eth0';  
my $key = "1";  
my $ssh\_start\_vip = "/sbin/ifconfig $interface:$key $vip;/sbin/arping -I $interface -c 3 -s $vip $gateway >/dev/null 2>&1";  
my $ssh\_stop\_vip = "/sbin/ifconfig $interface:$key down";  
GetOptions(  
'command=s' => \\$command,  
'ssh\_user=s' => \\$ssh\_user,  
'orig\_master\_host=s' => \\$orig\_master\_host,  
'orig\_master\_ip=s' => \\$orig\_master\_ip,  
'orig\_master\_port=i' => \\$orig\_master\_port,  
'new\_master\_host=s' => \\$new\_master\_host,  
'new\_master\_ip=s' => \\$new\_master\_ip,  
'new\_master\_port=i' => \\$new\_master\_port,  
);  
exit &main();  
sub main \{  
print "\\n\\nIN SCRIPT TEST====$ssh\_stop\_vip==$ssh\_start\_vip===\\n\\n";  
if ( $command eq "stop" || $command eq "stopssh" ) \{  
\# $orig\_master\_host, $orig\_master\_ip, $orig\_master\_port are passed.  
\# If you manage master ip address at global catalog database,  
\# invalidate orig\_master\_ip here.  
my $exit\_code = 1;  
eval \{  
print "Disabling the VIP on old master: $orig\_master\_host \\n";  
&stop\_vip();  
$exit\_code = 0;  
\};  
if ($@) \{  
warn "Got Error: $@\\n";  
exit $exit\_code;  
\}  
exit $exit\_code;  
\}  
elsif ( $command eq "start" ) \{  
\# all arguments are passed.  
\# If you manage master ip address at global catalog database,  
\# activate new\_master\_ip here.  
\# You can also grant write access (create user, set read\_only=0, etc) here.  
my $exit\_code = 10;  
eval \{  
print "Enabling the VIP - $vip on the new master - $new\_master\_host \\n";  
&start\_vip();  
$exit\_code = 0;  
\};  
if ($@) \{  
warn $@;  
exit $exit\_code;  
\}  
exit $exit\_code;  
\}  
elsif ( $command eq "status" ) \{  
print "Checking the Status of the script.. OK \\n";  
\`ssh $ssh\_user\\@$orig\_master\_host \\" $ssh\_start\_vip \\"\`;  
exit 0;  
\}  
else \{  
&usage();  
exit 1;  
\}  
\}  
\# A simple system call that enable the VIP on the new master  
sub start\_vip() \{  
\`ssh $ssh\_user\\@$new\_master\_host \\" $ssh\_start\_vip \\"\`;  
\}  
\# A simple system call that disable the VIP on the old\_master  
sub stop\_vip() \{  
\`ssh $ssh\_user\\@$orig\_master\_host \\" $ssh\_stop\_vip \\"\`;  
\}  
sub usage \{  
print  
"Usage: master\_ip\_failover --command=start|stop|stopssh|status --orig\_master\_host=host --orig\_master\_ip=ip --  
  
  
  
  
orig\_master\_port=port --new\_master\_host=host --new\_master\_ip=ip --new\_master\_port=port\\n";  
\}

——————————————————————————

master\_ip\_online\_change 脚本

\#!/usr/bin/env perl  
  
  
\#  Copyright (C) 2011 DeNA Co.,Ltd.  
\#  
\#  This program is free software; you can redistribute it and/or modify  
\#  it under the terms of the GNU General Public License as published by  
\#  the Free Software Foundation; either version 2 of the License, or  
\#  (at your option) any later version.  
\#  
\#  This program is distributed in the hope that it will be useful,  
\#  but WITHOUT ANY WARRANTY; without even the implied warranty of  
\#  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the  
\#  GNU General Public License for more details.  
\#  
\#  You should have received a copy of the GNU General Public License  
\#   along with this program; if not, write to the Free Software  
\#  Foundation, Inc.,  
\#  51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA  
  
  
\#\# Note: This is a sample script and is not complete. Modify the script based on your environment.  
  
  
use strict;  
use warnings FATAL => 'all';  
  
  
use Getopt::Long;  
use MHA::DBHelper;  
use MHA::NodeUtil;  
use Time::HiRes qw( sleep gettimeofday tv\_interval );  
use Data::Dumper;  
  
  
my $\_tstart;  
my $\_running\_interval = 0.1;  
  
  
my $vip = '10.10.1.20';  
my $key = "1";  
my $ssh\_start\_vip = "/sbin/ifconfig eth0:$key $vip/24";  
my $ssh\_stop\_vip = "/sbin/ifconfig eth0:$key down";  
my $ssh\_send\_garp = "/sbin/arping -U $vip -I eth0 -c 1";  
  
  
my (  
  $command,              $orig\_master\_is\_new\_slave, $orig\_master\_host,  
  $orig\_master\_ip,       $orig\_master\_port,         $orig\_master\_user,  
  $orig\_master\_password, $orig\_master\_ssh\_user,     $new\_master\_host,  
  $new\_master\_ip,        $new\_master\_port,          $new\_master\_user,  
  $new\_master\_password,  $new\_master\_ssh\_user,  
);  
GetOptions(  
  'command=s'                => \\$command,  
  'orig\_master\_is\_new\_slave' => \\$orig\_master\_is\_new\_slave,  
  'orig\_master\_host=s'       => \\$orig\_master\_host,  
  'orig\_master\_ip=s'         => \\$orig\_master\_ip,  
  'orig\_master\_port=i'       => \\$orig\_master\_port,  
  'orig\_master\_user=s'       => \\$orig\_master\_user,  
  'orig\_master\_password=s'   => \\$orig\_master\_password,  
  'orig\_master\_ssh\_user=s'   => \\$orig\_master\_ssh\_user,  
  'new\_master\_host=s'        => \\$new\_master\_host,  
  'new\_master\_ip=s'          => \\$new\_master\_ip,  
  'new\_master\_port=i'        => \\$new\_master\_port,  
  'new\_master\_user=s'        => \\$new\_master\_user,  
  'new\_master\_password=s'    => \\$new\_master\_password,  
  'new\_master\_ssh\_user=s'    => \\$new\_master\_ssh\_user,  
);  
  
  
exit &main();  
  
  
sub start\_vip()\{  
    \`ssh $new\_master\_ssh\_user\\@$new\_master\_host \\" $ssh\_start\_vip \\"\`;  
    \`ssh $new\_master\_ssh\_user\\@$new\_master\_host \\" $ssh\_send\_garp \\"\`;  
\}  
  
  
sub stop\_vip()\{  
    \`ssh $orig\_master\_ssh\_user\\@$orig\_master\_host \\" $ssh\_stop\_vip \\"\`;  
\}  
  
  
  
  
sub current\_time\_us \{  
  my ( $sec, $microsec ) = gettimeofday();  
  my $curdate = localtime($sec);  
  return $curdate . " " . sprintf( "%06d", $microsec );  
\}  
  
  
sub sleep\_until \{  
  my $elapsed = tv\_interval($\_tstart);  
  if ( $\_running\_interval > $elapsed ) \{  
    sleep( $\_running\_interval - $elapsed );  
  \}  
\}  
  
  
sub get\_threads\_util \{  
  my $dbh                    = shift;  
  my $my\_connection\_id       = shift;  
  my $running\_time\_threshold = shift;  
  my $type                   = shift;  
  $running\_time\_threshold = 0 unless ($running\_time\_threshold);  
  $type                   = 0 unless ($type);  
  my @threads;  
  
  
  my $sth = $dbh->prepare("SHOW PROCESSLIST");  
  $sth->execute();  
  
  
  while ( my $ref = $sth->fetchrow\_hashref() ) \{  
    my $id         = $ref->\{Id\};  
    my $user       = $ref->\{User\};  
    my $host       = $ref->\{Host\};  
    my $command    = $ref->\{Command\};  
    my $state      = $ref->\{State\};  
    my $query\_time = $ref->\{Time\};  
    my $info       = $ref->\{Info\};  
    $info =~ s/^\\s\*(.\*?)\\s\*$/$1/ if defined($info);  
    next if ( $my\_connection\_id == $id );  
    next if ( defined($query\_time) && $query\_time < $running\_time\_threshold );  
    next if ( defined($command)    && $command eq "Binlog Dump" );  
    next if ( defined($user)       && $user eq "system user" );  
    next  
      if ( defined($command)  
      && $command eq "Sleep"  
      && defined($query\_time)  
      && $query\_time >= 1 );  
  
  
    if ( $type >= 1 ) \{  
      next if ( defined($command) && $command eq "Sleep" );  
      next if ( defined($command) && $command eq "Connect" );  
    \}  
  
  
    if ( $type >= 2 ) \{  
      next if ( defined($info) && $info =~ m/^select/i );  
      next if ( defined($info) && $info =~ m/^show/i );  
    \}  
  
  
    push @threads, $ref;  
  \}  
  return @threads;  
\}  
  
  
sub main \{  
  if ( $command eq "stop" ) \{  
    \#\# Gracefully killing connections on the current master  
    \# 1. Set read\_only= 1 on the new master  
    \# 2. DROP USER so that no app user can establish new connections  
    \# 3. Set read\_only= 1 on the current master  
    \# 4. Kill current queries  
    \# \* Any database access failure will result in script die.  
    my $exit\_code = 1;  
    eval \{  
      \#\# Setting read\_only=1 on the new master (to avoid accident)  
      my $new\_master\_handler = new MHA::DBHelper();  
  
  
      \# args: hostname, port, user, password, raise\_error(die\_on\_error)\_or\_not  
      $new\_master\_handler->connect( $new\_master\_ip, $new\_master\_port,  
        $new\_master\_user, $new\_master\_password, 1 );  
      print current\_time\_us() . " Set read\_only on the new master.. ";  
      $new\_master\_handler->enable\_read\_only();  
      if ( $new\_master\_handler->is\_read\_only() ) \{  
        print "ok.\\n";  
      \}  
      else \{  
        die "Failed!\\n";  
      \}  
      $new\_master\_handler->disconnect();  
  
  
      \# Connecting to the orig master, die if any database error happens  
      my $orig\_master\_handler = new MHA::DBHelper();  
      $orig\_master\_handler->connect( $orig\_master\_ip, $orig\_master\_port,  
        $orig\_master\_user, $orig\_master\_password, 1 );  
  
  
      \#\# Drop application user so that nobody can connect. Disabling per-session binlog beforehand  
      $orig\_master\_handler->disable\_log\_bin\_local();  
      \# print current\_time\_us() . " Drpping app user on the orig master..\\n";  
      \#drop\_app\_user($orig\_master\_handler);  
  
  
      \#\# Waiting for N \* 100 milliseconds so that current connections can exit  
      my $time\_until\_read\_only = 15;  
      $\_tstart = \[gettimeofday\];  
      my @threads = get\_threads\_util( $orig\_master\_handler->\{dbh\},  
        $orig\_master\_handler->\{connection\_id\} );  
      while ( $time\_until\_read\_only > 0 && $\#threads >= 0 ) \{  
        if ( $time\_until\_read\_only % 5 == 0 ) \{  
          printf  
"%s Waiting all running %d threads are disconnected.. (max %d milliseconds)\\n",  
            current\_time\_us(), $\#threads + 1, $time\_until\_read\_only \* 100;  
          if ( $\#threads < 5 ) \{  
            print Data::Dumper->new( \[$\_\] )->Indent(0)->Terse(1)->Dump . "\\n"  
              foreach (@threads);  
          \}  
        \}  
        sleep\_until();  
        $\_tstart = \[gettimeofday\];  
        $time\_until\_read\_only--;  
        @threads = get\_threads\_util( $orig\_master\_handler->\{dbh\},  
          $orig\_master\_handler->\{connection\_id\} );  
      \}  
  
  
      \#\# Setting read\_only=1 on the current master so that nobody(except SUPER) can write  
      print current\_time\_us() . " Set read\_only=1 on the orig master.. ";  
      $orig\_master\_handler->enable\_read\_only();  
      if ( $orig\_master\_handler->is\_read\_only() ) \{  
        print "ok.\\n";  
      \}  
      else \{  
        die "Failed!\\n";  
      \}  
  
  
      \#\# Waiting for M \* 100 milliseconds so that current update queries can complete  
      my $time\_until\_kill\_threads = 5;  
      @threads = get\_threads\_util( $orig\_master\_handler->\{dbh\},  
        $orig\_master\_handler->\{connection\_id\} );  
      while ( $time\_until\_kill\_threads > 0 && $\#threads >= 0 ) \{  
        if ( $time\_until\_kill\_threads % 5 == 0 ) \{  
          printf  
"%s Waiting all running %d queries are disconnected.. (max %d milliseconds)\\n",  
            current\_time\_us(), $\#threads + 1, $time\_until\_kill\_threads \* 100;  
          if ( $\#threads < 5 ) \{  
            print Data::Dumper->new( \[$\_\] )->Indent(0)->Terse(1)->Dump . "\\n"  
              foreach (@threads);  
          \}  
        \}  
        sleep\_until();  
        $\_tstart = \[gettimeofday\];  
        $time\_until\_kill\_threads--;  
        @threads = get\_threads\_util( $orig\_master\_handler->\{dbh\},  
          $orig\_master\_handler->\{connection\_id\} );  
      \}  
  
  
      \#\# Terminating all threads  
      print current\_time\_us() . " Killing all application threads..\\n";  
      $orig\_master\_handler->kill\_threads(@threads) if ( $\#threads >= 0 );  
      print current\_time\_us() . " done.\\n";  
      $orig\_master\_handler->enable\_log\_bin\_local();  
      $orig\_master\_handler->disconnect();  
  
  
      \#\# Droping the VIP       
      print "Disabling the VIP an old master: $orig\_master\_host \\n";  
      &stop\_vip();  
  
  
      \#\# After finishing the script, MHA executes FLUSH TABLES WITH READ LOCK  
      $exit\_code = 0;  
    \};  
    if ($@) \{  
      warn "Got Error: $@\\n";  
      exit $exit\_code;  
    \}  
    exit $exit\_code;  
  \}  
  elsif ( $command eq "start" ) \{  
    \#\# Activating master ip on the new master  
    \# 1. Create app user with write privileges  
    \# 2. Moving backup script if needed  
    \# 3. Register new master's ip to the catalog database  
  
  
\# We don't return error even though activating updatable accounts/ip failed so that we don't interrupt slaves' recovery.  
\# If exit code is 0 or 10, MHA does not abort  
    my $exit\_code = 10;  
    eval \{  
      my $new\_master\_handler = new MHA::DBHelper();  
  
  
      \# args: hostname, port, user, password, raise\_error\_or\_not  
      $new\_master\_handler->connect( $new\_master\_ip, $new\_master\_port,  
        $new\_master\_user, $new\_master\_password, 1 );  
  
  
      \#\# Set read\_only=0 on the new master  
      $new\_master\_handler->disable\_log\_bin\_local();  
      print current\_time\_us() . " Set read\_only=0 on the new master.\\n";  
      $new\_master\_handler->disable\_read\_only();  
  
  
      \#\# Creating an app user on the new master  
      \#print current\_time\_us() . " Creating app user on the new master..\\n";  
      \# create\_app\_user($new\_master\_handler);  
      print "Enabling the VIP $vip on the new master: $new\_master\_host \\n";  
      &start\_vip();  
      $new\_master\_handler->enable\_log\_bin\_local();  
      $new\_master\_handler->disconnect();  
  
  
      \#\# Update master ip on the catalog database, etc  
      $exit\_code = 0;  
    \};  
    if ($@) \{  
      warn "Got Error: $@\\n";  
      exit $exit\_code;  
    \}  
    exit $exit\_code;  
  \}  
  elsif ( $command eq "status" ) \{  
  
  
    \# do nothing  
    exit 0;  
  \}  
  else \{  
    &usage();  
    exit 1;  
  \}  
\}  
  
  
sub usage \{  
  print  
"Usage: master\_ip\_online\_change --command=start|stop|status --orig\_master\_host=host --orig\_master\_ip=ip --orig\_master\_port=port --new\_master\_host=host --new\_master\_ip=ip --new\_master\_port=port\\n";  
  die;  
\}

启动mha

masterha\_manager --conf=/data0/mha/app1/app1.cnf

Mon Nov  6 15:25:17 2017 - \[warning\] Global configuration file /etc/masterha\_default.cnf not found. Skipping.  
Mon Nov  6 15:25:17 2017 - \[info\] Reading application default configuration from /data0/mha/app1/app1.cnf..  
Mon Nov  6 15:25:17 2017 - \[info\] Reading server configuration from /data0/mha/app1/app1.cnf..  
\[root@DBA app1\]$ masterha\_manager --conf=/data0/mha/app1/app1.cnf   
Mon Nov  6 15:26:33 2017 - \[warning\] Global configuration file /etc/masterha\_default.cnf not found. Skipping.  
Mon Nov  6 15:26:33 2017 - \[info\] Reading application default configuration from /data0/mha/app1/app1.cnf..  
Mon Nov  6 15:26:33 2017 - \[info\] Reading server configuration from /data0/mha/app1/app1.cnf..

\--手动切换 测试 （需要关闭mha管理进程）

masterha\_master\_switch --master\_state=alive --conf=/data0/mha/app1/app1.cnf --new\_master\_host=db1 --new\_master\_port=6000 --orig\_master\_is\_new\_slave