【MySQL】MHA源代碼之主庫選?。ǘ?/h1>

一 、MHA 選舉主庫所維護(hù)的數(shù)組

在講MHA選擇 master的代碼中，我們必須把維護(hù)的四個(gè)數(shù)組的來龍去脈講清楚

成都創(chuàng)新互聯(lián)公司始終堅(jiān)持【策劃先行，效果至上】的經(jīng)營理念，通過多達(dá)十余年累計(jì)超上千家客戶的網(wǎng)站建設(shè)總結(jié)了一套系統(tǒng)有效的推廣解決方案，現(xiàn)已廣泛運(yùn)用于各行各業(yè)的客戶，其中包括：成都玻璃鋼坐凳等企業(yè)，備受客戶贊許。

(1) Alive_slaves 數(shù)組 :

server不是 master,且從庫正常， latest數(shù)組中的 server有足夠的中繼日志恢復(fù)這個(gè)落后的從庫 (追上主庫 )，則放入這個(gè) Alive_slaves的數(shù)組中 (此段代碼在 ServerManager.pm： init_servers函數(shù) )

    if ( $server->{dead} ) {
      $self->add_dead_server($server);
    }
    elsif ( $server->{unmanaged} ) {
      $self->add_unmanaged_slave($server);
    }
    #不是dead或者unmanaged就加入alive_server數(shù)組，如果show slave status 不是返回0E0,且這個(gè)server不是原來的主庫，并且sql線程無誤且可以用中繼日志來恢復(fù)，就加入alive_slave數(shù)據(jù)，否則加入failed——slave數(shù)組
    else {
      $self->add_alive_server($server);
      if ( $server->{not_slave} eq '0' && !$server->{orig_master} ) {
        if ( !$server->is_sql_thread_error() && !$server->{lack_relay_log} ) {
          $self->add_alive_slave($server);
        }
        else {
          $self->add_failed_slave($server);
        }
      }
}

(2)Latest 數(shù)組

在 alive_slaves數(shù)組中選取 relaylog最新的 server，這個(gè)數(shù)組如果有多個(gè) server,則 server的 Read_master_log_pos,master_log_file一定相等（此段代碼在 ServerManager.pm： identify_latest_slaves函數(shù)）

 

 my @slaves = $self->get_alive_slaves();
  my @latest = ();
  foreach (@slaves) {
    my $a = $latest[0]{Master_Log_File};
    my $b = $latest[0]{Read_Master_Log_Pos};
    if (
      #find_oldest=0，即我們?nèi)〉淖钊玶elaylog的slave，至于這里為什么是數(shù)組，是因?yàn)橛凶钚碌膔elaylog的不只有一個(gè)，可能有多個(gè)((即數(shù)組里邊邊的slave，具有一樣的Read_Master_Log_     Pos位置))
      !$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]{Read_Master_Log_Pos} )
      )
      )
    {
      @latest = ();
      push( @latest, $_ );
}

(3)Perf 數(shù)組

這個(gè)無需多解釋，就是MHA配置文件中配置了 candidate_master的值，這個(gè)可以大于 1哦

(4)Bad 數(shù)組： ( 代碼見： ServerManager.pm:get_bad_candidate_masters)

1) 檢測(cè)有故障的server

2) MHA 配置文件設(shè)置了 no_master 的 server

3)log_bin 沒有打開的server

4) 版本不兼容的server （高版本復(fù)制到低版本是沒問題的，但是如果低版本的選為為主庫，嘿嘿）

5) 復(fù)制落后太多的server

二 、MHA 主庫的選舉

(1) 指定主庫切換的，優(yōu)先級(jí)最高（通常這是在手動(dòng)切換）

(2) 如果server 在 latest 數(shù)組中，且在 perf 數(shù)組中，則優(yōu)先返回

(3) 如果server 在 alive_servers 數(shù)組中，且在 perf 數(shù)組中，則優(yōu)先返回

(4) 如果server 在 lastest 中，則優(yōu)先返回

(5) 如果server 在 alive_servers 中，則返回

(6) 否則選舉失敗

這里優(yōu)先級(jí)為1->6，具體實(shí)現(xiàn)在 (ServerManager.pm: select_new_master)

sub select_new_master {
  my $self                    = shift;
  my $prio_new_master_host    = shift;
  my $prio_new_master_port    = shift;
  my $check_replication_delay = shift;
  $check_replication_delay = 1 if ( !defined($check_replication_delay) );
 
  my $log    = $self->{logger};
  my @latest = $self->get_latest_slaves();
  my @slaves = $self->get_alive_slaves();
 
  my @pref = $self->get_candidate_masters();
  my @bad =
    $self->get_bad_candidate_masters( $latest[0], $check_replication_delay );
  #切換指定了master，即優(yōu)先級(jí)最高的
  if ( $prio_new_master_host && $prio_new_master_port ) {
    my $new_master =
      $self->get_alive_server_by_hostport( $prio_new_master_host,
      $prio_new_master_port );
    if ($new_master) {
      my $a = $self->get_server_from_by_id( \@bad, $new_master->{id} );
      unless ($a) {
        $log->info("$prio_new_master_host can be new master.");
        return $new_master;
      }
      else {
        $log->error("$prio_new_master_host is bad as a new master!");
        return;
      }
    }
    else {
      $log->error("$prio_new_master_host is not alive!");
      return;
    }
  }
 
  $log->info("Searching new master from slaves..");
  $log->info(" Candidate masters from the configuration file:");
  $self->print_servers( \@pref );
  $log->info(" Non-candidate masters:");
  $self->print_servers( \@bad );
  #如果perf(candidate_master沒設(shè)置)以及沒有不符合(主從延遲，版本等)的slave，并且lastest[0]設(shè)置有優(yōu)先級(jí)的話，就返回
  return $latest[0]
    if ( $#pref < 0 && $#bad < 0 && $latest[0]->{latest_priority} );
  #如果設(shè)置了優(yōu)先級(jí),則從lastest數(shù)組中選擇是canidate_master的，有就返回（隱含lastest[0]優(yōu)先，如果lastest[0]同時(shí)是canidate_master,那肯定是優(yōu)先返回的）
  #latest_priority默認(rèn)設(shè)置為1
  if ( $latest[0]->{latest_priority} ) {
    $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 );
  }
 
  #new master is not latest
  #這里選擇的是candidate_master，單不是latest數(shù)組中的master
  $log->info(" Searching from all candidate_master slaves..")
    if ( $#pref >= 0 );
  foreach my $s (@slaves) {
    foreach my $p (@pref) {
      if ( $s->{id} eq $p->{id} ) {
        my $a = $self->get_server_from_by_id( \@bad, $p->{id} );
        return $s unless ($a);
      }
    }
  }
  $log->info("  Not found.") if ( $#pref >= 0 );
  #其次是優(yōu)先在lastest數(shù)組中，但不在candidate_master中的
  if ( $latest[0]->{latest_priority} ) {
    $log->info(
" Searching from all slaves which have received the latest relay log events.."
    );
    foreach my $h (@latest) {
      my $a = $self->get_server_from_by_id( \@bad, $h->{id} );
      return $h unless ($a);
    }
    $log->info("  Not found.");
  }
 
  # none of latest servers can not be a master
  $log->info(" Searching from all slaves..");
  foreach my $s (@slaves) {
    my $a = $self->get_server_from_by_id( \@bad, $s->{id} );
    return $s unless ($a);
  }
  $log->info("  Not found.");
 
  return;
}

分享名稱：【MySQL】MHA源代碼之主庫選?。ǘ?
文章起源：http://weahome.cn/article/ipiigh.html