mysqlの準同期レプリケーションを使ってみる

mysqlの準同期レプリケーションの考え方

mysqlのレプリケーションは、デフォルトの動作は、非同期レプリケーションです。
非同期なので、マスターとスレーブで何らかの障害が発生し、停止した場合、 そのリカバリがどこまで必要かは、ログ情報に頼ることになり、非常にメンテナンスに手間がかかりました。

今回、この準同期レプリケーションにて、少なくともマスター側は、スレーブ側がどこまでデータを更新しているか、認識できるようになりました。（完璧ではありませんが、非同期と比較すれば格段に認識できます）

その仕組みは、非常に簡単で、
COMMITが完了した時点で、マスター側でバイナリログへ書き込み、スレーブにもそのバイナリログ情報が転送されます。
スレーブでは、バイナリログ情報が受信できたら、マスターへ応答(ACK)を送信します。スレーブは、その後データベースへ反映します。
マスターは、その応答(ACK)を受信した後、データベースへ反映します。

ここでスレーブから応答(ACK)をもらうか否かが準同期と非同期の違いになります。つまり、スレーブへは更新情報が確かに届いたかどうかをマスターは認識できることを意味します。

以下は、その処理の流れを図にしたものです。

mysqlの準同期レプリケーション設定を行う

以前の記事 mysqlのレプリケーションを使う で 設定を行った マスタースレーブ型のレプリケーションが既に動作しているものとして、以降、記載します。
( マスタースレーブ型のレプリケーションの設定方法については、mysqlのレプリケーションを使う で確認してください。 )

準同期レプリケーションの設定は、mysqlの設定ファイル(my.cnf)の編集を行うことで利用できます。
以下、マスターとスレーブのそれぞれの設定について解説します。

mysqlの設定ファイル(my.cnf)を編集します。

...
[mysqld]
...
# Replication
server-id      = 101
log-bin        = /var/lib/mysqllogs/bin-log
# Semisynchronous Replication(Master)
plugin-load=rpl_semi_sync_master=semisync_master.so
rpl_semi_sync_master_enabled=1
rpl_semi_sync_master_timeout=5000
...

...
[mysqld]
...
# Replication
server-id      = 102
log-bin        = /var/lib/mysqllogs/bin-log
# Semisynchronous Replication(Slave)
plugin-load=rpl_semi_sync_slave=semisync_slave.so
rpl_semi_sync_slave_enabled=1
...

mysqlを再起動します。

$ /etc/init.d/mysqld restart
mysqld を停止中:                                           [  OK  ]
mysqld を起動中:                                           [  OK  ]

mysqlの準同期レプリケーションの動作確認を行う

以下のように マスターとスレーブで、それぞれ時系列で以下のように確認を行います。

> CREATE TABLE autoinc1(
	col INT NOT NULL AUTO_INCREMENT PRIMARY KEY
);

> select * from autoinc1;
Empty set (0.00 sec)

> BEGIN;
Query OK, 0 rows affected (0.00 sec)
 
> INSERT INTO autoinc1 VALUES (NULL);
Query OK, 1 row affected (0.00 sec)

> STOP SLAVE;
Query OK, 0 rows affected (0.01 sec)

> COMMIT;
Query OK, 0 rows affected (5.00 sec)

> select * from autoinc1;
+-----+
| col |
+-----+
|   1 |
+-----+
 
1 rows in set (0.00 sec)

> select * from autoinc1;
Empty set (0.00 sec)

> START SLAVE;
Query OK, 0 rows affected (0.01 sec)
 
> select * from autoinc1;
+-----+
| col |
+-----+
|   1 |
+-----+
 
1 rows in set (0.00 sec)