导航：首页 > 数据库 >

MySQL半同步复制的示例分析

发表于：2025-01-21 作者：千家信息网编辑

千家信息网最后更新 2025年01月21日，这篇文章主要介绍MySQL半同步复制的示例分析，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！代码分析int repl_semi_report_commit(Trans_para

千家信息网最后更新 2025年01月21日MySQL半同步复制的示例分析

这篇文章主要介绍MySQL半同步复制的示例分析，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！

代码分析

int repl_semi_report_commit(Trans_param *param)//gdb下param？
{
bool is_real_trans= param->flags & TRANS_IS_REAL_TRANS;
if (is_real_trans && param->log_pos)
{
const char *binlog_name= param->log_file;
return repl_semisync.commitTrx(binlog_name, param->log_pos);
}
return 0;
}

int ReplSemiSyncMaster::commitTrx(const char* trx_wait_binlog_name,
my_off_t trx_wait_binlog_pos)
{
//自旋锁，下面的代码是线性执行。
mysql_mutex_lock(&LOCK_binlog_);
if (active_tranxs_ != NULL && trx_wait_binlog_name){
entry=active_tranxs_->find_active_tranx_node(trx_wait_binlog_name,
trx_wait_binlog_pos);
if (entry)
thd_cond= &entry->cond;
}
//进入信号了，为后面发起信号量的等待动作做准备，每个正在进行提交的事务都对应一个初始化的信号量thd_cond
THD_ENTER_COND(NULL, thd_cond, &LOCK_binlog_,
& stage_waiting_for_semi_sync_ack_from_slave,
& old_stage);
if (getMasterEnabled() && trx_wait_binlog_name){
set_timespec(start_ts, 0);//
if (!getMasterEnabled() || !is_on())
goto l_end;
//计算等待ACK的截止时间。按照当前时间加上半同步等待的超时时间，这个时间回在发起信号量等待的时候用的
//rpl_semi_sync_master_timeout
abstime.tv_sec = start_ts.tv_sec + wait_timeout_ / TIME_THOUSAND;
abstime.tv_nsec = start_ts.tv_nsec +(wait_timeout_ % TIME_THOUSAND) * TIME_MILLION;
if (abstime.tv_nsec >= TIME_BILLION){
abstime.tv_sec++;
abstime.tv_nsec -= TIME_BILLION;
}
//state_是TRUE表示当前半同步状态为on，否则直接进入l_end。Rpl_semi_sync_master_status
//reply_file_name_值的变化，在其他函数中？
while (is_on()){
if (reply_file_name_inited_){
//比较事务所涉及的binlog位置跟reply的位置，如果cmp>0，说明此事务的binlog已经同步
//到slave，跳出该循环，进入最后阶段l_end
int cmp = ActiveTranx::compare(reply_file_name_, reply_file_pos_,
trx_wait_binlog_name, trx_wait_binlog_pos);
if (cmp >= 0){
break;
}
}
if (wait_file_name_inited_){
//比较事务所涉及的binlog位置和当前最小需要等待的binlog位置。如果cmp<0，表示调整当前最小需要等待
//binlog的位置。rpl_semi_sync_master_wait_pos_backtraverse++,即等待位置需要调整的次数，一般不会
//调整
int cmp = ActiveTranx::compare(trx_wait_binlog_name, trx_wait_binlog_pos,
wait_file_name_, wait_file_pos_);
if (cmp <= 0){
strncpy(wait_file_name_, trx_wait_binlog_name, sizeof(wait_file_name_) - 1);
wait_file_name_[sizeof(wait_file_name_) - 1]= '\0';
wait_file_pos_ = trx_wait_binlog_pos;
rpl_semi_sync_master_wait_pos_backtraverse++;
}
}else{
//保存第一次最小需要响应的事务位置
strncpy(wait_file_name_, trx_wait_binlog_name, sizeof(wait_file_name_) - 1);
wait_file_name_[sizeof(wait_file_name_) - 1]= '\0';
wait_file_pos_ = trx_wait_binlog_pos;
wait_file_name_inited_ = true;
}
//如果salve个数是0了，则将半同步关闭，退出循环
if (abort_loop && rpl_semi_sync_master_clients == 0 && is_on()){
switch_off();
break;
}
//正式进入等待binlog同步的步骤，将rpl_semi_sync_master_wait_sessions+1，表明
//有多少要提交的事务线程在等待（这个值是否能够代表实际等待事务的线程数量，值得怀疑，因为该函数
//开始位置有lock，没有unlock前，其他线程也进不到这一步，没办法执行++）
//然后发起等待信号，进入信号等待后，只有2种情况可以退出等待。1是被其他线程唤醒（binlog dump）
//2是等待超时时间。如果是被唤醒则返回值是0，否则是其他值
rpl_semi_sync_master_wait_sessions++;
entry->n_waiters++;
//发起信号等待，然后根据返回结果做相应计数：上面是循环体里面的所有内容，接下来我们看退出循环后的操作。特别提一下，唤醒该线程的dump线程，当dump线程收到相应binlog位置的ack之后，会将其唤醒。
wait_result= mysql_cond_timedwait(&entry->cond, &LOCK_binlog_, &abstime);
entry->n_waiters--;
rpl_semi_sync_master_wait_sessions--;
if (wait_result != 0){
//等待超时，关闭半同步
rpl_semi_sync_master_wait_timeouts++;
switch_off();
}else{
wait_time = getWaitTime(start_ts);
if (wait_time < 0){
//表明时钟错误，可能是做了时间调整
rpl_semi_sync_master_timefunc_fails++;
}else{
//将等待事件与该等待计入总数
rpl_semi_sync_master_trx_wait_num++;
rpl_semi_sync_master_trx_wait_time += wait_time;
}
}
}//end while
l_end:
/* Update the status counter. */
if (is_on())
rpl_semi_sync_master_yes_transactions++;
else
rpl_semi_sync_master_no_transactions++;
}
/* Last waiter removes the TranxNode */
if (trx_wait_binlog_name && active_tranxs_
&& entry && entry->n_waiters == 0)
active_tranxs_->clear_active_tranx_nodes(trx_wait_binlog_name,
trx_wait_binlog_pos);
THD_EXIT_COND(NULL, & old_stage);
}