MySQL Clusterにおけるレプリケーションの基礎

連載 :

99.999％の高可用性とSQL＋NoSQLの柔軟性を併せ持つ「MySQL Cluster」運用ガイド

2015年10月29日(木)

本連載では、実際に「MySQL Cluster」を利用するためのチュートリアルとなるように、その特徴と基本的なアーキテクチャからインストール方法、基本的な操作などをコマンド付きで解説していきます。第7回の今回は、MySQL Clusterにおけるレプリケーションのメリットや仕組み、注意事項について解説します。

前提となる環境

記事中のコマンド例は、第2回でインストールした環境に第5回で紹介したサンプルデータベース（worldデータベース）を作成した状態を前提としています（追加設定としてmysqlユーザーの環境変数"PATH"に"/home/mysql/mysqlc/bin"も追加した状態を前提）。

レプリケーションのメリットと主な用途

MySQL Clusterでは、通常のMySQL Serverと同様の仕組みでマスターからスレーブへバイナリログを転送してレプリケーションを構築できるため、MySQL Serverのレプリケーション運用ノウハウを活かせます。また、MySQL ClusterからMySQL Clusterへレプリケーションするだけでなく、MySQL Clusterから通常のMySQL Serverへレプリケーションを行なうこともできます。

MySQL Clusterでレプリケーションを使用する主な用途は、次の通りです。

ディザスタリカバリサイトを構築する（MySQL ClusterからMySQL Clusterへのレプリケーション）
MySQL Clusterが苦手なクエリをMySQL Serverで処理する（MySQL ClusterからMySQL Serverへのレプリケーション）

ディザスタリカバリサイトを構築する

例えば東京と大阪のような地理的に離れた場所にそれぞれMySQL Clusterを構成し、それらをレプリケーションで連携することで実現できます。

MySQL Clusterが苦手なクエリをMySQL Serverで処理する

通常のMySQL Serverと比べた場合にMySQL Clusterが苦手なクエリとは、範囲検索やテーブルの全件データを検索するようなスキャン系の処理、複数テーブルを結合するJOIN処理です。MySQL Clusterは内部で自動的にデータをシャーディング（分割して複数のサーバーに分散）しているため、クエリの実行結果を返すノード間のネットワーク通信時間もレスポンスタイムに影響を与える要因となります。そしてスキャン系の処理やJOIN処理を実行した場合は、SQLノードが複数のデータノードと通信したり、データノード間で通信したりする必要があるため、1件だけデータを取り出す処理と比べてネットワーク通信時間がレスポンスタイムに与える影響が大きくなります。また、多重処理を実行する環境ではノード間のデータ処理がネットワーク帯域を圧迫してしまい、ボトルネックとなるケースもあります。

そこでMySQL ClusterからMySQL Serverにレプリケーションを構成し、このようなクエリをMySQL Serverで処理することで、それぞれのノード間でのネットワーク通信時間に依存したレスポンスタイムの悪化を改善したり、ネットワーク帯域の圧迫によるボトルネック発生を防いだりできるようになります。

MySQL Clusterのレプリケーションの仕組み

前述したように、MySQL ClusterのレプリケーションにはMySQL Serverのレプリケーション運用ノウハウを活かせますが、MySQL Cluster固有の仕組みや注意事項もあります。

MySQL Clusterのバイナリログ出力

バイナリログはデータベースの更新内容を記録しているログファイルです。通常のMySQL Serverでデータベースを更新できるのはMySQL Serverが稼働しているサーバー1台だけですが、MySQL Cluster環境では複数のSQLノードがあり、それぞれのSQLノードからデータベースを更新できるため、バイナリログを出力しているSQLノードは自ノード以外で実行した更新内容もバイナリログに記録する必要があります。

そのための仕組みが「Binlog Injector」と呼ばれる、通常のMySQL ServerにはないMySQL ClusterのSQLノード固有のスレッドです。MySQL Clusterを構成しているSQLノードでバイナリログを出力すると、そのSQLノード上にあるBinlog Injectorスレッドがデータノードでの更新内容を受け取り、直列化（Epochでソート）してバイナリログに書き込みます（図1）。

第4回で解説したように、同じEpochの更新内容は同じ時間帯に更新された内容となるため、Epochでソートしてバイナリログに書き込むことで、スレーブにレプリケーションした際も同じ内容（順番）でデータを更新できます。

Epochとの対応を記録しているテーブル（表1）

MySQL Clusterのレプリケーションでは、Epochを基準にバイナリログのファイル名やポジションを判断するケースがあります。その際に参照するEpochとの対応を記録しているテーブルがndb_binlog_indexです。また、スレーブ側でバイナリログの内容をどこまで（どのEpochまで）反映しているかを記録するテーブルがndb_apply_statusです。いずれもmysqlデータベース内のテーブルです。

表1: Epochとの対応を記録しているテーブル

名称	存在場所	ストレージエンジン	内容
ndb_binlog_index	マスター	MyISAM	Epochとバイナリログファイル／ポジションの対応関係を記録
ndb_apply_status	スレーブ	NDB	スレーブ側でバイナリログの内容をどのEpochまで反映したかを記録

MySQL Clusterでレプリケーションを構成する場合、通常はマスター側の2～3台のSQLノードでバイナリログ出力を有効にします（理由は後述）。そのためSQLノード毎にEpochとバイナリログポジションの対応を確認できるように、ndb_binlog_indexテーブルのストレージエンジンはNDBではなくMyISAMになっています。

一方、スレーブ側でバイナリログの内容をどのEpochまで反映したかを確認する際は、全SQLノードから同じ情報を確認できる必要があるため、ndb_apply_statusテーブルはNDBストレージエンジンを使用しています。

SQLノード1、2でバイナリログ出力を有効にし、データ更新後にそれぞれのSQLノードでndb_binlog_indexを確認した例がリスト1〜リスト4です。Epochを基準に情報を確認すると、同じEpochの情報が異なるバイナリログファイルに出力されています。

まず、SQLノード1に接続して現在のバイナリログ出力とEpochを確認します（リスト1）。

リスト1: 現在のバイナリログ出力とEpochを確認

01# SQLノード1に接続
02$ mysql -u root -h 127.0.0.1
03 
04# バイナリログの出力状況を確認
05mysql> SHOW MASTER LOGS;
06+---------------+-----------+
07| Log_name      | File_size |
08+---------------+-----------+
09| binlog.000001 |       120 |
10+---------------+-----------+
111 row in set (0.00 sec)
12 
13# 現在のEpochを確認(latest_epochが現在のEpoch)
14mysql> SHOW ENGINE NDB STATUS\G
15<中略>
16*************************** 15. row ***************************
17  Type: ndbcluster
18  Name: binlog
19Status: latest_epoch=103671920590854, latest_trans_epoch=103633265885196, latest_received_binlog_epoch=103671920590854, latest_handled_binlog_epoch=103671920590854, latest_applied_binlog_epoch=103568841375758
2015 rows in set (0.01 sec)

次にデータを追加（INSERT）し、SHOW ENGINE NDB STATUSの結果からデータ追加時のEpochを確認します（リスト2）。latest_trans_epochには、このSQLノードで実行された最後のトランザクションのEpochが出力されるため、latest_trans_epochの値からデータ追加時のEpochを判断できます。

リスト2: データを追加し、データ追加時のEpochを確認

01# データを追加
02mysql> INSERT INTO world.City VALUES(10000,'TEST','JPN','TEST',0);
03Query OK, 1 row affected (0.00 sec)
04 
05# データ更新時のEpochを確認(latest_trans_epoch= 103779294773259)
06mysql> SHOW ENGINE NDB STATUS\G
07<中略>
08*************************** 16. row ***************************
09  Type: ndbcluster
10  Name: binlog
11Status: latest_epoch=103809359544320, latest_trans_epoch=103779294773259, latest_received_binlog_epoch=103809359544320, latest_handled_binlog_epoch=103809359544320, latest_applied_binlog_epoch=103779294773259
1216 rows in set (0.00 sec)

続いて、ndb_binlog_indexからEpochとバイナリログ出力の対応を確認します（リスト3）。リスト2で確認したEpoch（103779294773259）の情報が、SQLノード1ではbinlog.000001のポジション120に記録されていることが判断できます。

リスト3: ndb_binlog_indexの確認例（SQLノード1）

01mysql> SELECT * FROM mysql.ndb_binlog_index WHERE epoch=103779294773259\G
02*************************** 1. row ***************************
03      Position: 120
04          File: ./binlog.000001
05         epoch: 103779294773259
06       inserts: 1
07       updates: 0
08       deletes: 0
09     schemaops: 0
10orig_server_id: 0
11    orig_epoch: 0
12           gci: 24163
13 next_position: 504
14     next_file: ./binlog.000001
151 row in set (0.00 sec)

最後に、同じEpochの情報がSQLノード2においてどのバイナリログに出力されているかを確認します（リスト4）。リスト3と同様の手順でndb_binlog_indexを確認すると、Epoch（103779294773259）の情報がSQLノード2ではbinlog.000004のポジション187648に記録されていること、同じEpochの情報がSQLノード毎に異なるバイナリログファイル／ポジションに出力されていることが確認できます。

リスト4: ndb_binlog_indexの確認例（SQLノード2）

01# SQLノード2に接続
02$ mysql -u root -h 127.0.0.1 -P 3307
03 
04# バイナリログの出力状況を確認
05mysql> SHOW MASTER LOGS;
06+---------------+-----------+
07| Log_name      | File_size |
08+---------------+-----------+
09| binlog.000001 |      1284 |
10| binlog.000002 |       504 |
11| binlog.000003 |       204 |
12| binlog.000004 |    188032 |
13+---------------+-----------+
144 rows in set (0.00 sec)
15 
16# ndb_binlog_indexから、Epochとバイナリログ出力の対応を確認
17mysql> SELECT * FROM mysql.ndb_binlog_index WHERE epoch=103779294773259\G
18*************************** 1. row ***************************
19      Position: 187648
20          File: ./binlog.000004
21         epoch: 103779294773259
22       inserts: 1
23       updates: 0
24       deletes: 0
25     schemaops: 0
26orig_server_id: 0
27    orig_epoch: 0
28           gci: 24163
29 next_position: 188032
30     next_file: ./binlog.000004
311 row in set (0.00 sec)

マルチマスターレプリケーション構成時の競合検出ロジック

2組のMySQL Clusterがマスター／スレーブで双方向にレプリケーションを行うマルチマスターレプリケーションを構成した場合に、同じデータを両方のMySQL Clusterで更新した場合のデータ競合の検出や、検出したデータ競合を自動解決するためのロジックがあらかじめ用意されています（通常のMySQL Serverではこのようなロジックは用意されていないため、マルチマスターレプリケーションを構成した場合は競合検出ロジック自体をアプリケーション側に組み込む必要がある）。

MySQL Clusterでマルチマスターレプリケーションを構成した場合の競合検出の詳細については、下記のマニュアルを参照してください。

18.6.11. MySQL Cluster レプリケーションの競合解決
https://dev.mysql.com/doc/refman/5.6/ja/mysql-cluster-replication-conflict-resolution.html

レプリケーションの注意事項

MySQL Cluster環境でレプリケーションを使用する場合の注意事項について解説します。

レプリケーションチャネルを多重化する必要がある

SQLノードのBinlog Injectorスレッドは、SQLノードがデータノードに接続している時のみ機能します。つまり、SQLノードが停止していたり、再起動したりしている間に他のSQLノードから行われた更新内容はバイナリログに記録されません。予期せぬ障害やローリングリスタートなどで特定のSQLノードが停止する可能性に備えて、あるSQLノードが停止している間の更新内容を別のSQLノードで記録するため複数のSQLノードでバイナリログ出力を有効にし、レプリケーションチャネルを多重化する必要があります。

バイナリログ出力を有効にしているSQLノードが再起動すると、データに欠落が生じた可能性があることを示す「LOST_EVENTS」がバイナリログ内に記録されます。そして、このイベントを受け取ったスレーブはエラーとしてレプリケーションを停止します。

リスト5〜リスト8はLOST_EVENTSの確認例です。明示的にSQLノードを停止していますが、障害によりSQLノードが停止した場合でも、同様のLOST_EVENTSがバイナリログ内に記録されます。まず、現在のバイナリログのポジションと内容を確認します（リスト5）。現在のポジションはbinlog.000001の120です。

リスト5: 現在のバイナリログ出力を確認

01# 現在のバイナリログを確認
02$ mysql -u root -h 127.0.0.1
03mysql> SHOW MASTER LOGS;
04+---------------+-----------+
05| Log_name      | File_size |
06+---------------+-----------+
07| binlog.000001 |       120 |
08+---------------+-----------+
091 row in set (0.00 sec)
10 
11mysql> SHOW BINLOG EVENTS IN 'binlog.000001';
12+---------------+-----+-------------+-----------+-------------+-------------------------------------------------------------+
13| Log_name      | Pos | Event_type  | Server_id | End_log_pos | Info                                                        |
14+---------------+-----+-------------+-----------+-------------+-------------------------------------------------------------+
15| binlog.000001 |   4 | Format_desc |         1 |         120 | Server ver: 5.6.24-ndb-7.4.6-cluster-gpl-log, Binlog ver: 4 |
16+---------------+-----+-------------+-----------+-------------+-------------------------------------------------------------+
171 row in set (0.00 sec)

次にSQLノードを再起動してバイナリログの出力状況を再度確認すると、自動的にバイナリログがローテーションされてbinlog.000003まで出力されていました。またbinlog.000001の内容を"SHOW BINLOG EVENTS"で確認しましたが、特別なイベントは含まれていませんでした（リスト6）。

リスト6: SQLノードを再起動し、再度バイナリログの出力状況を確認

01# SQLノードを再起動
02$ mysqladmin -u root -h 127.0.0.1 shutdown
03$ mysqld --defaults-file=/home/mysql/mysqlc/my1.cnf &
04 
05# 再度、バイナリログの出力状況を確認
06$ mysql -u root -h 127.0.0.1
07mysql> SHOW MASTER LOGS;
08+---------------+-----------+
09| Log_name      | File_size |
10+---------------+-----------+
11| binlog.000001 |       143 |
12| binlog.000002 |       204 |
13| binlog.000003 |       120 |
14+---------------+-----------+
153 rows in set (0.00 sec)
16 
17mysql> SHOW BINLOG EVENTS IN 'binlog.000001';
18+---------------+-----+-------------+-----------+-------------+-------------------------------------------------------------+
19| Log_name      | Pos | Event_type  | Server_id | End_log_pos | Info                                                        |
20+---------------+-----+-------------+-----------+-------------+-------------------------------------------------------------+
21| binlog.000001 |   4 | Format_desc |         1 |         120 | Server ver: 5.6.24-ndb-7.4.6-cluster-gpl-log, Binlog ver: 4 |
22| binlog.000001 | 120 | Stop        |         1 |         143 |                                                             |
23+---------------+-----+-------------+-----------+-------------+-------------------------------------------------------------+
242 rows in set (0.00 sec)

続いてbinlog.000002の内容を確認すると（リスト7）、LOST_EVENTSが記録されていることが確認できました（binlog.000003には特別な出力はなかった）。

リスト7: LOST_EVENTSが記録されているバイナリログ

01mysql> SHOW BINLOG EVENTS IN 'binlog.000002';
02+---------------+-----+-------------+-----------+-------------+-------------------------------------------------------------+
03| Log_name      | Pos | Event_type  | Server_id | End_log_pos | Info                                                        |
04+---------------+-----+-------------+-----------+-------------+-------------------------------------------------------------+
05| binlog.000002 |   4 | Format_desc |         1 |         120 | Server ver: 5.6.24-ndb-7.4.6-cluster-gpl-log, Binlog ver: 4 |
06| binlog.000002 | 120 | Incident    |         1 |         160 | #1 (LOST_EVENTS)                                            |
07| binlog.000002 | 160 | Rotate      |         1 |         204 | binlog.000003;pos=4                                         |
08+---------------+-----+-------------+-----------+-------------+-------------------------------------------------------------+
093 rows in set (0.00 sec)
10 
11mysql> SHOW BINLOG EVENTS IN 'binlog.000003';
12+---------------+-----+-------------+-----------+-------------+-------------------------------------------------------------+
13| Log_name      | Pos | Event_type  | Server_id | End_log_pos | Info                                                        |
14+---------------+-----+-------------+-----------+-------------+-------------------------------------------------------------+
15| binlog.000003 |   4 | Format_desc |         1 |         120 | Server ver: 5.6.24-ndb-7.4.6-cluster-gpl-log, Binlog ver: 4 |
16+---------------+-----+-------------+-----------+-------------+-------------------------------------------------------------+
171 row in set (0.00 sec)

別の確認方法として、mysqlbinlogコマンドを使用した場合の例がリスト8です。出力結果に"Incident: LOST_EVENTS"が含まれていることを確認できます。

リスト8: mysqlbinlogでの確認例

01$ mysqlbinlog binlog.000002
02/*!50530 SET @@SESSION.PSEUDO_SLAVE_MODE=1*/;
03/*!40019 SET @@session.max_insert_delayed_threads=0*/;
04/*!50003 SET
05<中略>
06# at 120
07#151005 10:17:48 server id 1  end_log_pos 160 CRC32 0x27fcc2f5
08# Incident: LOST_EVENTS
09RELOAD DATABASE; # Shall generate syntax error
10<中略>
11# End of log file
12ROLLBACK /* added by mysqlbinlog */;
13/*!50003 SET COMPLETION_TYPE=@OLD_COMPLETION_TYPE*/;
14/*!50530 SET @@SESSION.PSEUDO_SLAVE_MODE=0*/;

LOST_EVENTSによりレプリケーションが停止した場合は、マスターのバイナリログ出力を継続している別のSQLノードに接続し直してレプリケーションを再開します。スレーブのndb_apply_statusを参照して反映済みのEpochを確認後、マスターのndb_binlog_indexを参照してバイナリログのファイル名とポジションを確認します。ndb_apply_statusやndb_binlog_indexを参照してレプリケーションを開始する方法の具体例は、次回で解説予定です。

バイナリログ出力を有効にするとノード間の通信量が増大する

SQLノードでバイナリログ出力を有効にすると、データノードでの更新内容をSQLノードに伝達するためノード間の通信量が増大します。その分他の処理に使用できる帯域が減りパフォーマンスの悪化につながる可能性があるため、バイナリログを出力するSQLノード数は必要最低限にします。一般的には2～3つのSQLノードでバイナリログ出力を有効にすると良いでしょう。

バイナリログのフォーマットはROWにする（ROWになる）

MySQL Clusterのバイナリログはデータノードで更新された内容をSQLノードに伝達して書き込まれますが、データノードではどのようなステートメント（SQL文）によりデータが更新されたのかを把握していません。そのためバイナリログのフォーマットは必然的にROWとなり、行ベースのレプリケーションが行われます。my.cnfの設定値として"binlog_format=MIXED"や"binlog_format=STATEMENT"のほかデフォルト設定（binlog_format=MIXED）で使用することもできますが、自動的に行ベースレプリケーションが行われます。混乱を避けるためにも、明示的に“binlog_format=ROW”を指定する方が良いでしょう。