MySQL MHA--故障切换模式(GTID模式和非GTID模式)

Posted 2022-03-21 gaogao67

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了MySQL MHA--故障切换模式(GTID模式和非GTID模式)相关的知识，希望对你有一定的参考价值。

GTID和非GTID故障切换模式选择

mysql 5.6版本引入GTID来解决主从切换时BINLOG位置点难定位的问题，MHA从0.56版本开始支持基于GTID的复制，在切换时可以采用GTID模式和非GTID模式两种模式进行切换，如何在发生故障切换时如何判断采用哪种切换方式呢？

在MHA/MasterFailover.pm的do_master_failover方法中定义了"主库宕机"情况下的故障切换流程，其中第一步就是检查配置文件和确定故障切换模式

相关代码：

    my ( $servers_config_ref, $binlog_server_ref ) = init_config();
    $log->info("Starting master failover.");
    $log->info();
    $log->info("* Phase 1: Configuration Check Phase..\\n");
    $log->info();
    MHA::ServerManager::init_binlog_server( $binlog_server_ref, $log );
    $dead_master = check_settings($servers_config_ref);
    if ( $_server_manager->is_gtid_auto_pos_enabled() ) 
      $log->info("Starting GTID based failover.");
    
    else 
      $_server_manager->force_disable_log_bin_if_auto_pos_disabled();
      $log->info("Starting Non-GTID based failover.");
    
    $log->info();

在MHA\\ServerManager.pm中判断是否采用GTID模式切换的方法：

sub is_gtid_auto_pos_enabled($) 
  my $self = shift;
  return 1 if ( $self->gtid_failover_mode == 1 );
  return 0;



sub force_disable_log_bin_if_auto_pos_disabled($) 
  my $self = shift;
  my $log  = $self->logger;
  if ( $self->gtid_failover_mode == 2 ) 
    my @slaves = $self->get_alive_slaves();
    $log->info("Forcing disable_log_bin since GTID auto pos is disabled");
    foreach my $slave (@slaves) 
      $slave->disable_log_bin = 1;
    
  


$self->gtid_failover_mode = $self->get_gtid_status();

在MHA/ServerManager.pm判断群集是否使用GTID复制：

sub get_gtid_status($) 
  my $self    = shift;
  my @servers = $self->get_alive_servers();
  my @slaves  = $self->get_alive_slaves();
  return 0 if ( $#servers < 0 );
  foreach (@servers) 
    return 0 unless ( $_->has_gtid );
  
  foreach (@slaves) 
    return 0 unless ( $_->Executed_Gtid_Set );
  
  foreach (@slaves) 
    return 1
      if ( defined( $_->Auto_Position )
      && $_->Auto_Position == 1 );
    return 1 if ( $_->use_gtid_auto_pos );
  
  return 2;

其中has_gtid的计算为：

use constant Has_Gtid_SQL             => "SELECT \\@\\@global.gtid_mode As Value";
sub has_gtid($) 
  my $self  = shift;
  my $value = $self->get_variable(Has_Gtid_SQL);
  if ( defined($value) && $value eq "ON" ) 
    $self->has_gtid = 1;
    return 1;
  
  return 0;

计算use_gtid_auto_pos的代码：

## MHA/Config.pm
my @PARAM_ARRAY =
  qw/ hostname ip port ssh_host ssh_ip ssh_port ssh_connection_timeout ssh_options node_label candidate_master \\
  no_master ignore_fail skip_init_ssh_check skip_reset_slave user password repl_user repl_password disable_log_bin \\
master_pid_file handle_raw_binlog ssh_user remote_workdir master_binlog_dir log_level manager_workdir manager_log \\
check_repl_delay check_repl_filter latest_priority multi_tier_slave ping_interval ping_type secondary_check_script \\
master_ip_failover_script master_ip_online_change_script shutdown_script report_script init_conf_load_script \\
client_bindir client_libdir use_gtid_auto_pos/;
my %PARAM;
for (@PARAM_ARRAY)  $PARAM$_ = 1; 

$valueuse_gtid_auto_pos = $param_arg->use_gtid_auto_pos;
if ( !defined( $valueuse_gtid_auto_pos ) ) 
  $valueuse_gtid_auto_pos = $default->use_gtid_auto_pos;
  $valueuse_gtid_auto_pos = 1 if ( !defined( $valueuse_gtid_auto_pos ) );