前言

年后在進(jìn)行騰訊二面的時(shí)候，寫(xiě)完算法的后問(wèn)的第一個(gè)問(wèn)題就是，MySQL的半同步是什么？我當(dāng)時(shí)直接懵了，我以為是問(wèn)的MySQL的兩階段提交的問(wèn)題呢？結(jié)果確認(rèn)了一下后不是兩階段提交，然后面試官看我連問(wèn)的是啥都不知道，就直接跳過(guò)這個(gè)問(wèn)題，直接聊下一個(gè)問(wèn)題了。所以這次總結(jié)一下這部分的知識(shí)內(nèi)容，文字內(nèi)容比較多，可能會(huì)有些枯燥，但對(duì)于這方面感興趣的人來(lái)說(shuō)還是比較有意思的。

MySQL的主從復(fù)制

我們的一般在大規(guī)模的項(xiàng)目上，都是使用MySQL的復(fù)制功能來(lái)創(chuàng)建MySQL的主從集群的。主要是可以通過(guò)為服務(wù)器配置一個(gè)或多個(gè)備庫(kù)的方式來(lái)進(jìn)行數(shù)據(jù)同步。復(fù)制的功能不僅有利于構(gòu)建高性能應(yīng)用，同時(shí)也是高可用、可擴(kuò)展性、災(zāi)難恢復(fù)、備份以及數(shù)據(jù)倉(cāng)庫(kù)等工作的基礎(chǔ)。

說(shuō)的通俗一點(diǎn)，通過(guò)MySQL的主從復(fù)制來(lái)實(shí)現(xiàn)讀寫(xiě)分離，相比單點(diǎn)數(shù)據(jù)庫(kù)又讀又寫(xiě)來(lái)說(shuō)，提升了業(yè)務(wù)系統(tǒng)性能，優(yōu)化了用戶體驗(yàn)。另外通過(guò)主從復(fù)制實(shí)現(xiàn)了數(shù)據(jù)庫(kù)的高可用，當(dāng)主節(jié)點(diǎn)MySQL掛了的時(shí)候，可以用從庫(kù)來(lái)頂上。

MySQL支持的復(fù)制方式

MySQL支持三種復(fù)制方式：

基于語(yǔ)句的復(fù)制（也稱為邏輯復(fù)制）主要是指，在主數(shù)據(jù)庫(kù)上執(zhí)行的SQL語(yǔ)句，在從數(shù)據(jù)庫(kù)上會(huì)重復(fù)執(zhí)行一遍。MySQL默認(rèn)采用的就是這種復(fù)制，效率比較高。但是也是有一定的問(wèn)題的，如果SQL中使用uuid()、rand()等函數(shù)，那么復(fù)制到從庫(kù)的數(shù)據(jù)就會(huì)有偏差。 基于行的復(fù)制，指將更新處理后的數(shù)據(jù)復(fù)制到從數(shù)據(jù)庫(kù)，而不是執(zhí)行一邊語(yǔ)句。從MySQL5.1的版本才被支持。 混合復(fù)制，默認(rèn)采用語(yǔ)句復(fù)制，當(dāng)發(fā)現(xiàn)語(yǔ)句不能進(jìn)行精準(zhǔn)復(fù)制數(shù)據(jù)時(shí)（例如語(yǔ)句中含有uuid()、rand()等函數(shù)），采用基于行的復(fù)制。 主從復(fù)制原理

MySQL的復(fù)制原理概述上來(lái)講大體可以分為這三步

在主庫(kù)上把數(shù)據(jù)更改，記錄到二進(jìn)制日志（Binary Log）中。 從庫(kù)將主庫(kù)上的日志復(fù)制到自己的中繼日志（Relay Log）中。 備庫(kù)讀取中繼日志中的事件，將其重放到備庫(kù)數(shù)據(jù)之上。

主要過(guò)程如下圖：

下面來(lái)詳細(xì)說(shuō)一下復(fù)制的這三步：

第一步：是在主庫(kù)上記錄二進(jìn)制日志，首先主庫(kù)要開(kāi)啟binlog日志記錄功能，并授權(quán)Slave從庫(kù)可以訪問(wèn)的權(quán)限。這里需要注意的一點(diǎn)就是binlog的日志里的順序是按照事務(wù)提交的順序來(lái)記錄的而非每條語(yǔ)句的執(zhí)行順序。

第二步：從庫(kù)將binLog復(fù)制到其本地的RelayLog中。首先從庫(kù)會(huì)啟動(dòng)一個(gè)工作線程，稱為I/O線程，I/O線程跟主庫(kù)建立一個(gè)普通的客戶端連接，然后主庫(kù)上啟動(dòng)一個(gè)特殊的二進(jìn)制轉(zhuǎn)儲(chǔ)（binlog dump）線程，此轉(zhuǎn)儲(chǔ)線程會(huì)讀取binlog中的事件。當(dāng)追趕上主庫(kù)后，會(huì)進(jìn)行休眠，直到主庫(kù)通知有新的更新語(yǔ)句時(shí)才繼續(xù)被喚醒。 這樣通過(guò)從庫(kù)上的I/O線程和主庫(kù)上的binlog dump線程，就將binlog數(shù)據(jù)傳輸?shù)綇膸?kù)上的relaylog中了。

第三步：從庫(kù)中啟動(dòng)一個(gè)SQL線程，從relaylog中讀取事件并在備庫(kù)中執(zhí)行，從而實(shí)現(xiàn)備庫(kù)數(shù)據(jù)的更新。

==這種復(fù)制架構(gòu)實(shí)現(xiàn)了獲取事件和重放事件的解耦，運(yùn)行I/O線程能夠獨(dú)立于SQL線程之外工作。但是這種架構(gòu)也限制復(fù)制的過(guò)程，最重要的一點(diǎn)是在主庫(kù)上并發(fā)運(yùn)行的查詢?cè)趥鋷?kù)中只能串行化執(zhí)行，因?yàn)橹挥幸粋€(gè)SQL線程來(lái)重放中繼日志中的事件。==

說(shuō)到這個(gè)主從復(fù)制的串行化執(zhí)行的問(wèn)題，我就想到了一個(gè)之前在工作中遇到的一個(gè)問(wèn)題，就是有這么一個(gè)業(yè)務(wù)場(chǎng)景，我們有一個(gè)操作是初始化一批數(shù)據(jù)，數(shù)據(jù)是從一個(gè)外部系統(tǒng)的接口中獲取的，然后我是通過(guò)線程池里的多個(gè)線程并行從外部系統(tǒng)的接口中獲取數(shù)據(jù)，每個(gè)線程獲取到數(shù)據(jù)后，直接插入到數(shù)據(jù)庫(kù)中。然后在數(shù)據(jù)全部入庫(kù)完成后，然后去執(zhí)行批量查詢，將剛插入到數(shù)據(jù)庫(kù)中的數(shù)據(jù)查詢出來(lái)，放到ElasticSearch中。結(jié)果每次放入到ES中的數(shù)據(jù)總是不完整，后來(lái)研究了半天都不行，最終是讓查詢也走的主庫(kù)才解決的問(wèn)題。當(dāng)時(shí)不知道是MySQL主從復(fù)制的串行化從而導(dǎo)致的這個(gè)問(wèn)題。

MySQL主從復(fù)制模式

MySQL的主從復(fù)制其實(shí)是支持，異步復(fù)制、半同步復(fù)制、GTID復(fù)制等多種復(fù)制模式的。

異步模式

MySQL的默認(rèn)復(fù)制模式就是異步模式，主要是指MySQL的主服務(wù)器上的I/O線程，將數(shù)據(jù)寫(xiě)到binlong中就直接返回給客戶端數(shù)據(jù)更新成功，不考慮數(shù)據(jù)是否傳輸?shù)綇姆?wù)器，以及是否寫(xiě)入到relaylog中。在這種模式下，復(fù)制數(shù)據(jù)其實(shí)是有風(fēng)險(xiǎn)的，一旦數(shù)據(jù)只寫(xiě)到了主庫(kù)的binlog中還沒(méi)來(lái)得急同步到從庫(kù)時(shí)，就會(huì)造成數(shù)據(jù)的丟失。

但是這種模式確也是效率最高的，因?yàn)樽兏鼣?shù)據(jù)的功能都只是在主庫(kù)中完成就可以了，從庫(kù)復(fù)制數(shù)據(jù)不會(huì)影響到主庫(kù)的寫(xiě)數(shù)據(jù)操作。

上面我也說(shuō)了，這種異步復(fù)制模式雖然效率高，但是數(shù)據(jù)丟失的風(fēng)險(xiǎn)很大，所以就有了后面要介紹的半同步復(fù)制模式。

半同步模式

MySQL從5.5版本開(kāi)始通過(guò)以插件的形式開(kāi)始支持半同步的主從復(fù)制模式。什么是半同步主從復(fù)制模式呢？ 這里通過(guò)對(duì)比的方式來(lái)說(shuō)明一下：

異步復(fù)制模式：上面我們已經(jīng)介紹了，異步復(fù)制模式，主庫(kù)在執(zhí)行完客戶端提交的事務(wù)后，只要將執(zhí)行邏輯寫(xiě)入到binlog后，就立即返回給客戶端，并不關(guān)心從庫(kù)是否執(zhí)行成功，這樣就會(huì)有一個(gè)隱患，就是在主庫(kù)執(zhí)行的binlog還沒(méi)同步到從庫(kù)時(shí)，主庫(kù)掛了，這個(gè)時(shí)候從庫(kù)就就會(huì)被強(qiáng)行提升為主庫(kù)，這個(gè)時(shí)候就有可能造成數(shù)據(jù)丟失。 同步復(fù)制模式：當(dāng)主庫(kù)執(zhí)行完客戶端提交的事務(wù)后，需要等到所有從庫(kù)也都執(zhí)行完這一事務(wù)后，才返回給客戶端執(zhí)行成功。因?yàn)橐鹊剿袕膸?kù)都執(zhí)行完，執(zhí)行過(guò)程中會(huì)被阻塞，等待返回結(jié)果，所以性能上會(huì)有很嚴(yán)重的影響。 半同步復(fù)制模式：半同步復(fù)制模式，可以說(shuō)是介于異步和同步之間的一種復(fù)制模式，主庫(kù)在執(zhí)行完客戶端提交的事務(wù)后，要等待至少一個(gè)從庫(kù)接收到binlog并將數(shù)據(jù)寫(xiě)入到relay log中才返回給客戶端成功結(jié)果。半同步復(fù)制模式，比異步模式提高了數(shù)據(jù)的可用性，但是也產(chǎn)生了一定的性能延遲，最少要一個(gè)TCP/IP連接的往返時(shí)間。

半同步復(fù)制模式，可以很明確的知道，在一個(gè)事務(wù)提交成功之后，此事務(wù)至少會(huì)存在于兩個(gè)地方一個(gè)是主庫(kù)一個(gè)是從庫(kù)中的某一個(gè)。主要原理是，在master的dump線程去通知從庫(kù)時(shí)，增加了一個(gè)ACK機(jī)制，也就是會(huì)確認(rèn)從庫(kù)是否收到事務(wù)的標(biāo)志碼，master的dump線程不但要發(fā)送binlog到從庫(kù)，還有負(fù)責(zé)接收slave的ACK。當(dāng)出現(xiàn)異常時(shí)，Slave沒(méi)有ACK事務(wù)，那么將自動(dòng)降級(jí)為異步復(fù)制，直到異常修復(fù)后再自動(dòng)變?yōu)榘胪綇?fù)制

MySQL半同步復(fù)制的流程如下：

半同步復(fù)制的隱患半同步復(fù)制模式也存在一定的數(shù)據(jù)風(fēng)險(xiǎn)，當(dāng)事務(wù)在主庫(kù)提交完后等待從庫(kù)ACK的過(guò)程中，如果Master宕機(jī)了，這個(gè)時(shí)候就會(huì)有兩種情況的問(wèn)題。

事務(wù)還沒(méi)發(fā)送到Slave上：若事務(wù)還沒(méi)發(fā)送Slave上，客戶端在收到失敗結(jié)果后，會(huì)重新提交事務(wù)，因?yàn)橹匦绿峤坏氖聞?wù)是在新的Master上執(zhí)行的，所以會(huì)執(zhí)行成功，后面若是之前的Master恢復(fù)后，會(huì)以Slave的身份加入到集群中，這個(gè)時(shí)候，之前的事務(wù)就會(huì)被執(zhí)行兩次，第一次是之前此臺(tái)機(jī)器作為Master的時(shí)候執(zhí)行的，第二次是做為Slave后從主庫(kù)中同步過(guò)來(lái)的。 事務(wù)已經(jīng)同步到Slave上：因?yàn)槭聞?wù)已經(jīng)同步到Slave了，所以當(dāng)客戶端收到失敗結(jié)果后，再次提交事務(wù)，你那么此事務(wù)就會(huì)再當(dāng)前Slave機(jī)器上執(zhí)行兩次。

為了解決上面的隱患，MySQL從5.7版本開(kāi)始，增加了一種新的半同步方式。新的半同步方式的執(zhí)行過(guò)程是將“Storage Commit”這一步移動(dòng)到了“Write Slave dump”后面。這樣保證了只有Slave的事務(wù)ACK后，才提交主庫(kù)事務(wù)。MySQL 5.7.2版本新增了一個(gè)參數(shù)來(lái)進(jìn)行配置：rpl_semi_sync_master_wait_point，此參數(shù)有兩個(gè)值可配置：

AFTER_SYNC：參數(shù)值為AFTER_SYNC時(shí)，代表采用的是新的半同步復(fù)制方式。 AFTER_COMMIT：代表采用的是之前的舊方式的半同步復(fù)制模式。

MySQL從5.7.2版本開(kāi)始，默認(rèn)的半同步復(fù)制方式就是AFTER_SYNC方式了，但是方案不是萬(wàn)能的，因?yàn)锳FTER_SYNC方式是在事務(wù)同步到Slave后才提交主庫(kù)的事務(wù)的，若是當(dāng)主庫(kù)等待Slave同步成功的過(guò)程中Master掛了，這個(gè)Master事務(wù)提交就失敗了，客戶端也收到了事務(wù)執(zhí)行失敗的結(jié)果了，但是Slave上已經(jīng)將binLog的內(nèi)容寫(xiě)到Relay Log里了，這個(gè)時(shí)候，Slave數(shù)據(jù)就會(huì)多了，但是多了數(shù)據(jù)一般問(wèn)題不算嚴(yán)重，多了總比少了好。MySQL，在沒(méi)辦法解決分布式數(shù)據(jù)一致性問(wèn)題的情況下，它能保證的是不丟數(shù)據(jù)，多了數(shù)據(jù)總比丟數(shù)據(jù)要好。

這里說(shuō)幾個(gè)的半同步復(fù)制模式的參數(shù)：

mysql> show variables like ’%Rpl%’;+-------------------------------------------+------------+| Variable_name | Value |+-------------------------------------------+------------+| rpl_semi_sync_master_enabled | ON || rpl_semi_sync_master_timeout | 10000 || rpl_semi_sync_master_trace_level | 32 || rpl_semi_sync_master_wait_for_slave_count | 1 || rpl_semi_sync_master_wait_no_slave| ON || rpl_semi_sync_master_wait_point | AFTER_SYNC || rpl_stop_slave_timeout | 31536000 |+-------------------------------------------+------------+

-- 半同步復(fù)制模式開(kāi)關(guān)rpl_semi_sync_master_enabled-- 半同步復(fù)制，超時(shí)時(shí)間，單位毫秒，當(dāng)超過(guò)此時(shí)間后，自動(dòng)切換為異步復(fù)制模式 rpl_semi_sync_master_timeout-- MySQL 5.7.3引入的，該變量設(shè)置主需要等待多少個(gè)slave應(yīng)答，才能返回給客戶端，默認(rèn)為1。rpl_semi_sync_master_wait_for_slave_count-- 此值代表當(dāng)前集群中的slave數(shù)量是否還能夠滿足當(dāng)前配置的半同步復(fù)制模式，默認(rèn)為ON，當(dāng)不滿足半同步復(fù)制模式后，全部Slave切換到異步復(fù)制，此值也會(huì)變?yōu)镺FFrpl_semi_sync_master_wait_no_slave-- 代表半同步復(fù)制提交事務(wù)的方式，5.7.2之后，默認(rèn)為AFTER_SYNCrpl_semi_sync_master_wait_point GTID模式

MySQL從5.6版本開(kāi)始推出了GTID復(fù)制模式，GTID即全局事務(wù)ID (global transaction identifier)的簡(jiǎn)稱，GTID是由UUID+TransactionId組成的，UUID是單個(gè)MySQL實(shí)例的唯一標(biāo)識(shí)，在第一次啟動(dòng)MySQL實(shí)例時(shí)會(huì)自動(dòng)生成一個(gè)server_uuid, 并且默認(rèn)寫(xiě)入到數(shù)據(jù)目錄下的auto.cnf(mysql/data/auto.cnf)文件里。TransactionId是該MySQL上執(zhí)行事務(wù)的數(shù)量，隨著事務(wù)數(shù)量增加而遞增。這樣保證了GTID在一組復(fù)制中，全局唯一。

這樣通過(guò)GTID可以清晰的看到，當(dāng)前事務(wù)是從哪個(gè)實(shí)例上提交的，提交的第多少個(gè)事務(wù)。

來(lái)看一個(gè)GTID的具體形式：

mysql> show master status;+-----------+----------+--------------+------------------+-------------------------------------------+| File | Position | Binlog_Do_DB | Binlog_Ignore_DB | Executed_Gtid_Set |+-----------+----------+--------------+------------------+-------------------------------------------+| on.000003 | 187 | | | 76147e28-8086-4f8c-9f98-1cf33d92978d:1-322|+-----------+----------+--------------+------------------+-------------------------------------------+1 row in set (0.00 sec)GTID的工作原理

由于GTID在一組主從復(fù)制集群中的唯一性，從而保證了每個(gè)GTID的事務(wù)只在一個(gè)MySQL上執(zhí)行一次。 那么是怎么實(shí)現(xiàn)這種機(jī)制的呢？GTID的原理又是什么樣的呢？

當(dāng)從服務(wù)器連接主服務(wù)器時(shí)，把自己執(zhí)行過(guò)的GTID（Executed_Gtid_Set: 即已經(jīng)執(zhí)行的事務(wù)編碼）以及獲取到GTID（Retrieved_Gtid_Set: 即從庫(kù)已經(jīng)接收到主庫(kù)的事務(wù)編號(hào)）都傳給主服務(wù)器。主服務(wù)器會(huì)從服務(wù)器缺少的GTID以及對(duì)應(yīng)的transactionID都發(fā)送給從服務(wù)器，讓從服務(wù)器補(bǔ)全數(shù)據(jù)。當(dāng)主服務(wù)器宕機(jī)時(shí)，會(huì)找出同步數(shù)據(jù)最成功的那臺(tái)conf服務(wù)器，直接將它提升為主服務(wù)器。若是強(qiáng)制要求某一臺(tái)不是同步最成功的一臺(tái)從服務(wù)器為主，會(huì)先通過(guò)change命令到最成功的那臺(tái)服務(wù)器，將GTID進(jìn)行補(bǔ)全，然后再把強(qiáng)制要求的那臺(tái)機(jī)器提升為主。

主要數(shù)據(jù)同步機(jī)制可以分為這幾步：

==master更新數(shù)據(jù)時(shí)，在事務(wù)前生產(chǎn)GTID，一同記錄到binlog中。== ==slave端的i/o線程，將變更的binlog寫(xiě)入到relay log中。== ==sql線程從relay log中獲取GTID，然后對(duì)比Slave端的binlog是否有記錄。== ==如果有記錄，說(shuō)明該GTID的事務(wù)已經(jīng)執(zhí)行，slave會(huì)忽略該GTID。== ==如果沒(méi)有記錄，Slave會(huì)從relay log中執(zhí)行該GTID事務(wù)，并記錄到binlog。== ==在解析過(guò)程中，判斷是否有主鍵，如果沒(méi)有主鍵就使用二級(jí)索引，再?zèng)]有二級(jí)索引就掃描全表。==

初始結(jié)構(gòu)如下圖

通過(guò)上圖我們可以看出來(lái)，當(dāng)Master掛掉后，Slave-1執(zhí)行完了Master的事務(wù)，Slave-2延時(shí)一些，所以沒(méi)有執(zhí)行完Master的事務(wù)，這個(gè)時(shí)候提升Slave-1為主，Slave-2連接了新主（Slave-1）后，將最新的GTID傳給新主，然后Slave-1就從這個(gè)GTID的下一個(gè)GTID開(kāi)始發(fā)送事務(wù)給Slave-2。這種自我尋找復(fù)制位置的模式減少事務(wù)丟失的可能性以及故障恢復(fù)的時(shí)間。

GTID的優(yōu)劣勢(shì)

通過(guò)上面的分析我們可以得出GTID的優(yōu)勢(shì)是：

==每一個(gè)事務(wù)對(duì)應(yīng)一個(gè)執(zhí)行ID，一個(gè)GTID在一個(gè)服務(wù)器上只會(huì)執(zhí)行一次;== ==GTID是用來(lái)代替?zhèn)鹘y(tǒng)復(fù)制的方法，GTID復(fù)制與普通復(fù)制模式的最大不同就是不需要指定二進(jìn)制文件名和位置;== ==減少手工干預(yù)和降低服務(wù)故障時(shí)間，當(dāng)主機(jī)掛了之后通過(guò)軟件從眾多的備機(jī)中提升一臺(tái)備機(jī)為主機(jī);==

GTID的缺點(diǎn)也很明顯：

==首先不支持非事務(wù)的存儲(chǔ)引擎；== ==不支持create table ... select 語(yǔ)句復(fù)制(主庫(kù)直接報(bào)錯(cuò));(原理: 會(huì)生成兩個(gè)sql, 一個(gè)是DDL創(chuàng)建表SQL, 一個(gè)是insert into 插入數(shù)據(jù)的sql; 由于DDL會(huì)導(dǎo)致自動(dòng)提交, 所以這個(gè)sql至少需要兩個(gè)GTID, 但是GTID模式下, 只能給這個(gè)sql生成一個(gè)GTID)== ==不允許一個(gè)SQL同時(shí)更新一個(gè)事務(wù)引擎表和非事務(wù)引擎表;== ==在一個(gè)MySQL復(fù)制群組中，要求全部開(kāi)啟GTID或關(guān)閉GTID。== ==開(kāi)啟GTID需要重啟 (mysql5.7除外);== ==開(kāi)啟GTID后，就不再使用原來(lái)的傳統(tǒng)復(fù)制方式（不像半同步復(fù)制，半同步復(fù)制失敗后，可以降級(jí)到異步復(fù)制）;== ==對(duì)于create temporary table 和 drop temporary table語(yǔ)句不支持;== ==不支持sql_slave_skip_counter;==

其實(shí)GTID的這部分內(nèi)容挺多的，如果有想深入研究的可以去看看這篇文章。 最后說(shuō)幾個(gè)開(kāi)啟GTID的必備條件：

MySQL 5.6 版本，在my.cnf文件中添加:

gtid_mode=on (必選) #開(kāi)啟gtid功能log_bin=log-bin=mysql-bin (必選) #開(kāi)啟binlog二進(jìn)制日志功能log-slave-updates=1 (必選) #也可以將1寫(xiě)為onenforce-gtid-consistency=1 (必選) #也可以將1寫(xiě)為on MySQL 5.7或更高版本，在my.cnf文件中添加:

gtid_mode=on (必選)enforce-gtid-consistency=1 （必選）log_bin=mysql-bin （可選） #高可用切換，最好開(kāi)啟該功能log-slave-updates=1 （可選） #高可用切換，最好打開(kāi)該功能

以上就是詳解MySQL的半同步的詳細(xì)內(nèi)容，更多關(guān)于MySQL的半同步的資料請(qǐng)關(guān)注好吧啦網(wǎng)其它相關(guān)文章！