首页 > 数据库技术 > 详细

MySQL5.6 基于db的并行复制

时间:2014-05-08 19:27:16      阅读:509      评论:0      收藏:0      [点我收藏+]
slave的几个类结构:
bubuko.com,布布扣
bubuko.com,布布扣
 
     Master_info:用于IO线程的参数,包括连接master实例的信息。
     Relay_log_info:用于sql线程,表示relay log相关的信息。
     Slave_worker:继承Relay_log_info,包括一个job队列,用于并行的worker线程。
 
binlog event的类结构:
     bubuko.com,布布扣bubuko.com,布布扣
 
slave启动的函数栈:
     dispatch_command
          start_slave
               start_slave_threads
                    start_slave_thread
 
     start_slave:初始化master_info和relay_log_info两个对象
     start_slave_threads:启动两个线程,分别是handle_slave_io io线程,handle_slave_sql sql线程。
 
handle_slave_io: 启动io线程,根据master_info对象的连接信息,连接master主库。
  while(!io_slave_killed(thd,mi))
     request_dump:循环发送dump协议指令到master,接受event写入relay_log.
 
handle_slave_sql:启动sql线程,
     1. 当没有使用并行复制的时候。
          while (!sql_slave_killed(thd,rli))
               exec_relay_log_event(thd,rli): 循环从relay_log中读取event,并执行apply。
     
          exec_relay_log_event的调用栈:
               apply_event_and_update_pos 
                    Log_event::apply_event
                         Query_log_event::do_apply_event
                              Query_log_event::do_apply_event     
 
     2. 当设置了opt_slave_parallel_workers时,启用了并行复制
          slave_start_workers:初始化relay_log_info中关于mts的变量。
               slave_start_single_worker:启动多个并发线程。
                    handle_slave_worker:
                         while (!error)
                               error= slave_worker_exec_job(w, rli):根据jobs_queue中的值,pop出event进行apply。
                              在Log_event::apply_event的过程中:
                                   1,如果开启了并行:那么会把event分配给worker线程,然后结束
                                   2,如果没有开启并行:则直接执行do_apply_event
                                   3,如果不能并行的,需要wait_for_workers_to_finish所有worker结束后,本线程自己独立执行。

MySQL5.6 基于db的并行复制,布布扣,bubuko.com

MySQL5.6 基于db的并行复制

原文:http://www.cnblogs.com/xpchild/p/3713621.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!