知数堂第5期MySQL实战班学员，第10期MySQL优化班学员，现任职助教。

MHA在选择新的主库之前，会先把活着的slave分为几个数组，分别为latest(最靠前的slave数组)，pref（优先被选择为master的数组），bad（不会被选择成为master的slave），slaves（所有活着的slave数组）。然后进行5次选择，从上面的这些组当中挑选出新的master。

选择latest数组

foreach (@slaves) {
my $a = $latest[0]{Master_Log_File};
my $b = $latest[0]{Read_Master_Log_Pos};
if (
!$find_oldest
&& (
( !$a && !defined($b) )
|| ( $_->{Master_Log_File} gt $latest[0]{Master_Log_File} )
|| ( ( $_->{Master_Log_File} ge $latest[0]{Master_Log_File} )
&& $_->{Read_Master_Log_Pos} > $latest[0]www.wanmeiyuele.cn{Read_Master_Log_Pos} )
)
)
{
@latest = ();
push( @latest, $_ );
}
elsif (
$find_oldest
&& (
( !$a && !defined($b) )
|| ( $_->{Master_Log_File} lt $latest[0]{Master_Log_File} )
|| ( ( $_->{Master_Log_File} le $latest[0]{Master_Log_File} )
&& $_->{Read_Master_Log_Pos} < $latest[0]{Read_Master_Log_Pos} )
)
)
{
@latest = ();
push( @latest, $_ );
}
elsif ( ( $_->{Master_Log_File} eq $latest[0]{Master_Log_File} )
&& ( $_->{Read_Master_Log_Pos} == $latest[0]{Read_Master_Log_Pos} ) )
{
push( @latest, $_ );
}
}

上面代码主要的结构就是一个foreach循环，一个if判断。foreach循环处理所有的活着的slave。if判断这里有三个判断条件，主要根据Master_Log_File和Read_Master_Log_Pos的大小来判断。第一个和第二个分别为了找出最靠前和最靠后的slave的。如果满足条件，那么就清空latest数组，把符合条件的放入latest数组里面。第三个条件用于找出和latest数组里面Master_Log_File和Read_Master_Log_Pos一样的slave，并放入latest数组。这样所有的 最靠前的就都放入latest数组里面了。

选择pref数组

foreach (@servers) {next if ( $_->{dead} eq '1' );if ( $_->{candidate_master} >= 1 ) {push( @ret_servers, $_ );}}

循环处理所有的配置server，已经死了的slave跳过，有参数candidate_master=1的slave放入pref数组，会被优先推举为新的master。

选择bad数组

 foreach (@servers) {if ($_->{no_master} >= 1|| $_->{log_bin}www.365soke.cn  eq '0'|| $_->{oldest_major_version} eq '0'|| ($latest_slave&& ( $check_replication_delay&& $self->check_slave_delay( $_, $latest_slave ) >= 1 ))){push( @ret_servers, $_ );}}

也是循环处理所有的配置的server，满足下面三个条件之一就会被选择放入bad数组，也就说这些slave不会被推选为新的master。

1. 添加了参数no_master=1

2. 没有开启binlog

3. 如果延迟太大，如何才算是复制延迟太大呢？

 ( $latest->{Master_Log_File} gt $target->{Relay_Master_Log_File} )
|| ( $latest->{Read_Master_Log_Pos} >
$target->{Exec_Master_Log_Pos} + 100000000 )

这里的latest就是上面选择出来最靠前的第一个latest slave，不过所有的latest都是一样的，所以选择哪一个用于比较都是没关系的。要么latest的master_log_file > 对比者的Relay_Master_Log_File。或者是两者相同，但是latest的Read_Master_Log_Pos > 对比者的Exec_Master_Log_Pos+1亿。如果设置了参数check_repl_delay=0，那就不会会检查复制延迟。

选择slaves数组

只要是活着的slave都会被放进slaves数组当中。

这里需要说明的是，一个slave可以放进多个数组当中。不是一个slave只能存放到一个数组当中。

第一次选择:

return $latest[0] if ( $#pref <www.feihuanyule.com  0 && $#bad < 0 && $latest[0]->{latest_priority} );

如果pref和bad数组当中slave的个数为0，则选择latest数组当中的第一个slave为master。

第二次选择：

$log->info(
" Searching from candidate_master slaves which have received the latest relay log events.."
) if ( $#pref >= 0 );
foreach my $h (@latest) {
foreach my $p (@pref) {
if ( $h->{id} eq $p->{id} ) {
return $h
if ( !$self->get\_server\_from\_by\_id( \@bad, $p->{id} ) );
}
}
}
$log->info(" Not found.") if ( $#pref >= 0 );

循环对比latest数组和perf数组的slave，如果存在相同的slave，并且这个slave不在bad数组当中，该slave会被推选为新的master。

第三次选择:

foreach my $s (@slaves) {
foreach my $p (@pref)www.hbs90.cn/ {
if ( $s->{id} eq $p->{id} ) {
my $a = $self->get_server_from_by_id( \@bad, $p->{id} );
return $s unless ($a);
}
}
}

循环对比slaves数组pref数组当中的slave，如果有一个slave相同并且不在bad数组当中，该就会成为新的master。

第四次选择:

foreach my $h (@latest) {
my $a = $self->get_server_from_by_id( @bad, $h->{id} );
return $h unless ($a);
}

循环latest数组，如果有循环到的slave不在bad数组当中，这个slave就会成为master。也就是说就算添加了candidate_master=1，该slave也不一定会成为主库。

第五次选择:

foreach my $s (@slaves)www.yibaoyule1.com/ {
my $a = $self->get_server_from_by_id( @bad, $s->{id} );
return $s unless (www.huayi1.cn/ $a);
}

从活着的slave当中进行循环，如果循环到的slave不在bad数组当中，那么这个slave就会成为主库。 如果进行了5次选择都找不到主库，那么主库选择失败，failover失败。