MySQL中半同步模式的實(shí)現(xiàn)示例

更新時(shí)間：2024年09月09日 15:43:36 作者：妍妍的寶貝

MySQL半同步復(fù)制是一種解決主從數(shù)據(jù)一致性問(wèn)題的機(jī)制,本文就來(lái)介紹一下MySQL中半同步模式的實(shí)現(xiàn)示例,具有一定的參考價(jià)值,感興趣的可以了解一下

1 半同步簡(jiǎn)介: 解決主從數(shù)據(jù)一致性問(wèn)題

MySQL 半同步復(fù)制是一種機(jī)制，旨在解決主從數(shù)據(jù)的一致性問(wèn)題。它的主要目標(biāo)是在主服務(wù)器提交事務(wù)之前等待至少一個(gè)從服務(wù)器確認(rèn)收到了該事務(wù)的二進(jìn)制日志事件。這樣可以確保主服務(wù)器上的事務(wù)在從服務(wù)器上至少有一個(gè)副本，從而提高數(shù)據(jù)可靠性。

在默認(rèn)情況下，MySQL的復(fù)制是異步的，這意味著主服務(wù)器及其從服務(wù)器是獨(dú)立的。異步復(fù)制可以提供最佳的性能，因?yàn)橹鞣?wù)器在將更新的數(shù)據(jù)寫(xiě)入它的二進(jìn)制日志（Binlog）文件中后，無(wú)需等待驗(yàn)證更新數(shù)據(jù)是否已經(jīng)復(fù)制到從服務(wù)器中，就可以自由處理其它進(jìn)入的事務(wù)處理請(qǐng)求。但這也同時(shí)帶來(lái)了很高的風(fēng)險(xiǎn)，如果在主服務(wù)器或從服務(wù)器端發(fā)生故障，會(huì)造成主從數(shù)據(jù)的不一致，甚至在恢復(fù)時(shí)造成數(shù)據(jù)丟失。

從MySQL5.5開(kāi)始引入了一種半同步復(fù)制功能，該功能可以確保主服務(wù)器和訪問(wèn)鏈中至少一臺(tái)從服務(wù)器之間的數(shù)據(jù)一致性和冗余。在這種配置結(jié)構(gòu)中，一臺(tái)主服務(wù)器和其許多從服務(wù)器都進(jìn)行了配置，這樣在復(fù)制拓?fù)渲校辽儆幸慌_(tái)從服務(wù)器在父主服務(wù)器進(jìn)行事務(wù)處理前，必須確認(rèn)更新已經(jīng)收到并寫(xiě)入了其中繼日志（Relay Log）。當(dāng)出現(xiàn)超時(shí)，源主服務(wù)器必須暫時(shí)切換到異步復(fù)制模式重新復(fù)制，直到至少有一臺(tái)設(shè)置為半同步復(fù)制模式的從服務(wù)器及時(shí)收到信息。繼5.5半同步復(fù)制后，MySQL5.6又對(duì)其進(jìn)行了優(yōu)化和改進(jìn)，其中有兩個(gè)地方較為重要：

1> 在主從切換后，在傳統(tǒng)的方式里，需要找到binlog和POS點(diǎn)，然后更改master指向，而在mysql5.6里，你無(wú)須再知道binlog和POS點(diǎn)，你只需要知道m(xù)aster的IP、端口，賬號(hào)密碼即可，因?yàn)橥綇?fù)制是自動(dòng)的，mysql通過(guò)內(nèi)部機(jī)制GTID自動(dòng)找點(diǎn)同步。 ?

2> 多線程復(fù)制，以前的版本，同步復(fù)制是單線程的，只能一個(gè)一個(gè)執(zhí)行，在MySQL5.6里，可以做到多個(gè)庫(kù)之間的多線程復(fù)制，但一個(gè)庫(kù)里的表，多線程復(fù)制是無(wú)效的。

1.用戶線程寫(xiě)入完成后master中的dump會(huì)把日志推送到slave端

2.slave中的io線程接收后保存到relaylog中繼日志

3.保存完成后slave向master端返回ack

4.在未接受到slave的ack時(shí)master端時(shí)不做提交的，一直處于等待當(dāng)收到ack后提交到存儲(chǔ)引擎

5.在5.6版本中用到的時(shí)after_commit模式，after_commit模式時(shí)先提交在等待ack返回后輸出ok

2 實(shí)現(xiàn)半同步模式實(shí)踐操作

2.1 MASTER

mysql> INSTALL PLUGIN rpl_semi_sync_master SONAME 'semisync_master.so';

mysql> SELECT PLUGIN_NAME, PLUGIN_STATUS
    -> FROM INFORMATION_SCHEMA.PLUGINS
    -> WHERE PLUGIN_NAME LIKE '%semi%';
+----------------------+---------------+
| PLUGIN_NAME          | PLUGIN_STATUS |
+----------------------+---------------+
| rpl_semi_sync_master | ACTIVE        |
+----------------------+---------------+

[root@mysql-01 ~]# vim /etc/my.cnf 

[mysqld]
datadir=/data/mysql
socket=/data/mysql/mysql.sock
symbolic-links=0
log_bin=mysql-bin
server_id=10
gtid_mode=ON
enforce-gtid-consistency=ON
rpl_semi_sync_master_enabled=1    # 增加模塊 master 端自啟動(dòng) 


[root@mysql-01 ~]# systemctl restart mysqld


# 查看模塊是否安裝成功
mysql> SELECT PLUGIN_NAME, PLUGIN_STATUS
    -> FROM INFORMATION_SCHEMA.PLUGINS
    -> WHERE PLUGIN_NAME LIKE '%semi%';
+----------------------+---------------+
| PLUGIN_NAME          | PLUGIN_STATUS |
+----------------------+---------------+
| rpl_semi_sync_master | ACTIVE        |
+----------------------+---------------+

mysql> SHOW VARIABLES LIKE 'rpl_semi_sync%';
+-------------------------------------------+------------+
| 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 |
+-------------------------------------------+------------+

mysql> SHOW STATUS LIKE 'Rpl_semi_sync%';
+--------------------------------------------+-------+
| Variable_name                              | Value |
+--------------------------------------------+-------+
| Rpl_semi_sync_master_clients               | 0     |  -- (1) 表示當(dāng)前有多少個(gè)從服務(wù)器客戶端正在進(jìn)行半同步復(fù)制。
| Rpl_semi_sync_master_net_avg_wait_time     | 0     |  -- (2) 表示主服務(wù)器在等待從服務(wù)器確認(rèn)時(shí)網(wǎng)絡(luò)平均等待時(shí)間（毫秒）。這里的值為0，表示沒(méi)有平均網(wǎng)絡(luò)等待時(shí)間。
| Rpl_semi_sync_master_net_wait_time         | 0     |  -- (3) 表示主服務(wù)器在網(wǎng)絡(luò)等待上的總時(shí)間（毫秒）。這里的值同樣為0，表示沒(méi)有總的網(wǎng)絡(luò)等待時(shí)間。
| Rpl_semi_sync_master_net_waits             | 0     |  -- (4) 表示主服務(wù)器因網(wǎng)絡(luò)原因等待的次數(shù)。這里的值為0，表示沒(méi)有因網(wǎng)絡(luò)原因?qū)е碌牡却?
| Rpl_semi_sync_master_no_times              | 0     |  -- (5) 表示主服務(wù)器沒(méi)有等待任何從服務(wù)器確認(rèn)的次數(shù)。這里的值為0，表示所有事務(wù)都至少等待了一個(gè)從服務(wù)器的確認(rèn)。
| Rpl_semi_sync_master_no_tx                 | 0     |  -- (6) 表示主服務(wù)器沒(méi)有提交任何事務(wù)的次數(shù)。這里的值為0，表示所有事務(wù)都進(jìn)行了半同步復(fù)制。
| Rpl_semi_sync_master_status                | ON    |  -- (7) 表示半同步復(fù)制當(dāng)前是否啟用。在這里，半同步復(fù)制是啟用的。
| Rpl_semi_sync_master_timefunc_failures     | 0     |  -- (8) 表示由于時(shí)間函數(shù)失敗而導(dǎo)致半同步復(fù)制失敗的次數(shù)。這里的值為0，表示沒(méi)有時(shí)間函數(shù)失敗。
| Rpl_semi_sync_master_tx_avg_wait_time      | 0     |  -- (9) 表示主服務(wù)器在等待從服務(wù)器確認(rèn)事務(wù)時(shí)的平均等待時(shí)間（毫秒）。這里的值為0，表示沒(méi)有平均等待時(shí)間。
| Rpl_semi_sync_master_tx_wait_time          | 0     |  -- (10) 表示主服務(wù)器等待從服務(wù)器確認(rèn)事務(wù)的總等待時(shí)間（毫秒）。這里的值為0，表示沒(méi)有總的等待時(shí)間。
| Rpl_semi_sync_master_tx_waits              | 0     |  -- (11) 表示主服務(wù)器等待從服務(wù)器確認(rèn)事務(wù)的次數(shù)。這里的值為0，表示沒(méi)有等待時(shí)間。
| Rpl_semi_sync_master_wait_pos_backtraverse | 0     |  -- (12) 表示主服務(wù)器在等待從服務(wù)器確認(rèn)時(shí)回溯binlog位置的次數(shù)。這里的值為0，表示沒(méi)有回溯binlog位置。
| Rpl_semi_sync_master_wait_sessions         | 0     |  -- (13) 表示主服務(wù)器等待從服務(wù)器確認(rèn)事務(wù)時(shí)涉及的會(huì)話數(shù)量。這里的值為0，表示沒(méi)有等待會(huì)話。
| Rpl_semi_sync_master_yes_tx                | 0     |  -- (14) 表示主服務(wù)器成功提交事務(wù)并得到從服務(wù)器確認(rèn)的次數(shù)。這里的值為0，表示沒(méi)有事務(wù)成功提交并得到確認(rèn)。
+--------------------------------------------+-------+

2.2 SLAVE 1

mysql> INSTALL PLUGIN rpl_semi_sync_slave SONAME 'semisync_slave.so';

[root@mysql-02 ~]# vim /etc/my.cnf

[mysqld]
datadir=/data/mysql
socket=/data/mysql/mysql.sock
symbolic-links=0
server_id=20
gtid_mode=ON
enforce-gtid-consistency=ON
rpl_semi_sync_slave_enabled=1

[root@mysql-02 ~]# systemctl restart mysqld

[root@mysql-02 ~]# mysql -uroot -pOpenlab123!

mysql> SHOW VARIABLES LIKE 'rpl_semi_sync%';
+---------------------------------+-------+
| Variable_name                   | Value |
+---------------------------------+-------+
| rpl_semi_sync_slave_enabled     | ON    |
| rpl_semi_sync_slave_trace_level | 32    |
+---------------------------------+-------+

mysql> SHOW STATUS LIKE 'Rpl_semi_sync%';  # 查看模塊是否加載
+----------------------------+-------+
| Variable_name              | Value |
+----------------------------+-------+
| Rpl_semi_sync_slave_status | ON    |
+----------------------------+-------+

2.3 SLAVE 2

mysql> INSTALL PLUGIN rpl_semi_sync_slave SONAME 'semisync_slave.so';

[root@mysql-02 ~]# vim /etc/my.cnf

[mysqld]
datadir=/data/mysql
socket=/data/mysql/mysql.sock
symbolic-links=0
server_id=30
gtid_mode=ON
enforce-gtid-consistency=ON
rpl_semi_sync_slave_enabled=1

[root@mysql-02 ~]# systemctl restart mysqld

[root@mysql-02 ~]# mysql -uroot -pOpenlab123!

mysql> SHOW VARIABLES LIKE 'rpl_semi_sync%';
+---------------------------------+-------+
| Variable_name                   | Value |
+---------------------------------+-------+
| rpl_semi_sync_slave_enabled     | ON    |
| rpl_semi_sync_slave_trace_level | 32    |
+---------------------------------+-------+

mysql> SHOW STATUS LIKE 'Rpl_semi_sync%';  # 查看模塊是否加載
+----------------------------+-------+
| Variable_name              | Value |
+----------------------------+-------+
| Rpl_semi_sync_slave_status | ON    |
+----------------------------+-------+

2.4 查看client鏈接狀態(tài)

再次回到MASTER

[root@mysql-01 ~]# systemctl restart mysqld


mysql> SHOW STATUS LIKE 'Rpl_semi_sync%';
+--------------------------------------------+-------+
| Variable_name                              | Value |
+--------------------------------------------+-------+
| Rpl_semi_sync_master_clients               | 2     |  # 發(fā)現(xiàn)鏈接客戶端變成了兩個(gè)
| Rpl_semi_sync_master_net_avg_wait_time     | 0     |
| Rpl_semi_sync_master_net_wait_time         | 0     |
| Rpl_semi_sync_master_net_waits             | 0     |
| Rpl_semi_sync_master_no_times              | 0     |
| Rpl_semi_sync_master_no_tx                 | 0     |
| Rpl_semi_sync_master_status                | ON    |
| Rpl_semi_sync_master_timefunc_failures     | 0     |
| Rpl_semi_sync_master_tx_avg_wait_time      | 0     |
| Rpl_semi_sync_master_tx_wait_time          | 0     |
| Rpl_semi_sync_master_tx_waits              | 0     |
| Rpl_semi_sync_master_wait_pos_backtraverse | 0     |
| Rpl_semi_sync_master_wait_sessions         | 0     |
| Rpl_semi_sync_master_yes_tx                | 0     |
+--------------------------------------------+-------+

2.5 SLAVE 服務(wù)器故障模擬

2.5.1 停止 SLAVE 的 IO_THREAD

# SLAVE 1
mysql> STOP SLAVE IO_THREAD;
mysql> SHOW SLAVE STATUS\G

# SLAVE 2 
mysql> STOP SLAVE IO_THREAD;
mysql> SHOW SLAVE STATUS\G

2.5.2 查看SLAVE 的IO線程是否關(guān)閉

2.5.3 查看 MASTER 上 client 的連接狀態(tài)

mysql> SHOW STATUS LIKE 'Rpl_semi%';

2.5.4 在MASTER端插入數(shù)據(jù)

mysql> insert into wawa values(7,'www.shuyan');
Query OK, 1 row affected (10.00 sec)

                                    # 會(huì)卡住十秒鐘然后從同步轉(zhuǎn)為異步，再插入數(shù)據(jù)
mysql> SELECT * FROM wawa;
+----+-----------------+
| id | name            |
+----+-----------------+
|  1 | wawa            |
|  2 | shuyan          |
|  3 | shuyan and wawa |
|  4 | shuyan--------  |
|  5 | shuyan.com      |
|  6 | 12333           |
|  7 | www.shuyan      |
+----+-----------------+

mysql> SHOW STATUS LIKE 'Rpl_semi%';
+--------------------------------------------+-------+
| Variable_name                              | Value |
+--------------------------------------------+-------+
| Rpl_semi_sync_master_clients               | 0     |
| Rpl_semi_sync_master_net_avg_wait_time     | 0     |
| Rpl_semi_sync_master_net_wait_time         | 0     |
| Rpl_semi_sync_master_net_waits             | 0     |
| Rpl_semi_sync_master_no_times              | 1     |
| Rpl_semi_sync_master_no_tx                 | 1     | # 一筆數(shù)據(jù)為同步
| Rpl_semi_sync_master_status                | OFF   | # 自動(dòng)轉(zhuǎn)為異步模式，等待slave恢復(fù)
| Rpl_semi_sync_master_timefunc_failures     | 0     | # 會(huì)自動(dòng)恢復(fù)
| Rpl_semi_sync_master_tx_avg_wait_time      | 0     |
| Rpl_semi_sync_master_tx_wait_time          | 0     |
| Rpl_semi_sync_master_tx_waits              | 0     |
| Rpl_semi_sync_master_wait_pos_backtraverse | 0     |
| Rpl_semi_sync_master_wait_sessions         | 0     |
| Rpl_semi_sync_master_yes_tx                | 0     |
+--------------------------------------------+-------+
14 rows in set (0.00 sec)

2.5.5 MASTER 還能寫(xiě)入數(shù)據(jù)的原因

為什么還能寫(xiě)入呢？是因?yàn)樗诔^(guò)超時(shí)時(shí)間的時(shí)候，模式由同步模式轉(zhuǎn)為異步模式

開(kāi)啟從服務(wù)器的 IO_THREAD 線程

# SLAVE 1
mysql> start slave io_thread;
# SLAVE 2
mysql> start slave io_thread;


# 在SLAVE上發(fā)現(xiàn)數(shù)據(jù)已經(jīng)同步過(guò)來(lái)了
mysql> select * from shuyan.wawa;
+----+-----------------+
| id | name            |
+----+-----------------+
|  1 | wawa            |
|  2 | shuyan          |
|  3 | shuyan and wawa |
|  4 | shuyan--------  |
|  5 | shuyan.com      |
|  6 | 12333           |
|  7 | www.shuyan      |
+----+-----------------+

在從服務(wù)器開(kāi)啟半同步復(fù)制時(shí)，主服務(wù)器會(huì)在等待從服務(wù)器響應(yīng)之前設(shè)置一個(gè)超時(shí)時(shí)間。如果超過(guò)這個(gè)時(shí)間還沒(méi)有收到從服務(wù)器的響應(yīng)，主服務(wù)器會(huì)自動(dòng)轉(zhuǎn)換為異步模式。當(dāng)從服務(wù)器恢復(fù)連接時(shí)，它會(huì)自動(dòng)接收到主服務(wù)器在此期間插入的所有數(shù)據(jù)。

當(dāng)從服務(wù)器IO_THREAD 線程恢復(fù)連接時(shí)，從服務(wù)器會(huì)按照 GTID 的順序接收并應(yīng)用來(lái)自主服務(wù)器的事務(wù)。

當(dāng)從服務(wù)器的 I/O 線程恢復(fù)連接時(shí)，它會(huì)查找 gtid_executed 列表中缺失的 GTID，并從相應(yīng)的二進(jìn)制日志文件和位置開(kāi)始復(fù)制。這樣，從服務(wù)器會(huì)按照 GTID 的順序接收并應(yīng)用來(lái)自主服務(wù)器的事務(wù)，從而保證數(shù)據(jù)的一致性和完整性

MySQL 半同步復(fù)制可以通過(guò) GTID（全局事務(wù)標(biāo)識(shí)符）來(lái)比對(duì)數(shù)據(jù)。當(dāng)從服務(wù)器恢復(fù)連接時(shí)，它會(huì)根據(jù) GTID 查找主服務(wù)器上尚未應(yīng)用的事務(wù)，并自動(dòng)接收到這些事務(wù)。

到此這篇關(guān)于MySQL中半同步模式的實(shí)現(xiàn)示例的文章就介紹到這了,更多相關(guān)MySQL 半同步模式內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: