ノード避難とクラスター負荷再分散

MQTTはステートフルな長時間接続アクセスプロトコルであり、一度確立された接続は容易に切断されません。そのため、クラスターのノードのアップグレード、メンテナンス、スケーリングはより困難になります。EMQXは、ユーザーのクラスター運用・保守を支援するために、ノード避難およびクラスター負荷再分散機能を提供しています。

ノード避難

クラスター内のノードをメンテナンスやアップグレードする必要がある場合、ノードを直接シャットダウンすると接続やセッションが失われ、データ損失が発生する可能性があります。さらに、この操作により多数のデバイスが一時的にオフラインになり再接続が発生してサーバー負荷が増大し、全体のビジネスに影響を与える可能性があります。

そこで、EMQXはノード避難機能を提供し、シャットダウン前に対象ノードのすべての接続およびセッションデータをクラスター内の他のノードに移行することで、全体のビジネスへの影響を軽減します。

動作の仕組み

ノード避難は以下の順序で動作します：

避難対象ノードは新規接続の受付を停止します。
避難対象ノードは設定されたレート（conn-evict-rateで指定）で現在のクライアントを徐々に切断します。切断されたクライアントは再接続機構を使ってクラスター内の他のノード（ターゲットノード）に接続します。再接続機構はプロトコルバージョンによって異なります：
- MQTT v3.1/v3.1.1クライアント：ロードバランシング戦略で指定され、クライアント側で再接続機構を有効にする必要があります；
- MQTT v5.0クライアント：redirect-toパラメータで指定されます。
ターゲットノードがクライアントとの再接続を完了し、セッションを引き継ぐのを待ちます（wait-takeoverで指定）。
再接続待機時間経過後、避難対象ノードに残る未引き継ぎのセッションをターゲットノードに移行します：
- セッション移行先ノードはmigrate-toで指定；
- セッション移行速度はsess-evict-rateで指定。

避難はいつでも停止可能です。避難中に避難対象ノードがシャットダウンした場合、ノード再起動後に避難プロセスが再開されます。

CLIによるノード避難の開始と停止

CLIコマンドでノード避難の開始、避難状況の取得、停止が可能です。

ノード避難の開始

以下のCLIコマンドでノード避難を開始します。--evacuationパラメータは避難操作であることを示します：

bash

./bin/emqx ctl rebalance start --evacuation \
    [--wait-health-check Secs] \
    [--redirect-to "Host1:Port1 Host2:Port2 ..."] \
    [--conn-evict-rate CountPerSec] \
    [--migrate-to "node1@host1 node2@host2 ..."] \
    [--wait-takeover Secs] \
    [--sess-evict-rate CountPerSec]

パラメータ	型	説明
`--wait-health-check`	正の整数	ノードがロードバランサー（LB）によりアクティブなバックエンドノードリストから除外されるまでの待機時間（秒、デフォルト60秒）。この時間経過後に避難処理が開始され、ソースノードは新規接続を拒否します。
`--redirect-to`	文字列	MQTT 5.0クライアントの再接続時にリダイレクトされるサーバーアドレス。詳細はMQTT 5.0仕様 - サーバーリダイレクションを参照。
`--conn-evict-rate`	正の整数	クライアント切断レート（接続数/秒）、デフォルトは毎秒500接続。
`--migrate-to`	文字列	セッションを避難するノードのスペースまたはカンマ区切りリスト。
`--wait-takeover`	正の整数	セッション避難開始までの待機時間（秒）、デフォルト60秒。
`--sess-evict-rate`	正の整数	セッション避難レート（セッション数/秒）、デフォルトは毎秒500セッション。

コード例

ノードemqx@127.0.0.1上のクライアントをemqx2@127.0.0.1およびemqx3@127.0.0.1に移行したい場合、emqx@127.0.0.1ノード上で以下のコマンドを実行します：

bash

./bin/emqx ctl rebalance start --evacuation \
	--wait-health-check 60 \
	--wait-takeover 200 \
	--conn-evict-rate 30 \
	--sess-evict-rate 30 \
	--migrate-to "emqx2@127.0.0.1 emqx3@127.0.0.1"
Rebalance(evacuation) started

このコマンドは、既存クライアントを毎秒30接続のレートで切断します。すべての接続が切断された後、200秒間待機し、その間にクライアントセッションが再接続されたノードに移行されます。その後、残りのセッションを毎秒30セッションのレートでemqx2@127.0.0.1およびemqx3@127.0.0.1ノードに移行します。

避難状況の取得

以下のCLIコマンドで避難状況を取得できます：

bash

./bin/emqx ctl rebalance status

返却例は以下の通りです：

bash

./bin/emqx ctl rebalance status
--------------------------------------------------------------------
Node 'emqx@node1.emqx.io': evacuation
Rebalance state: evicting_conns
Connection eviction rate: 3 connections/second
Session eviction rate: 3 sessions/second
Connection goal: 0
Session goal: 0
Session recipient nodes: ['emqx@node2.emqx.io','emqx@node3.emqx.io']
Channel statistics:
  current_connected: 9
  current_sessions: 30
  initial_connected: 30
  initial_sessions: 30

ノード避難の停止

以下のCLIコマンドで避難を停止できます：

bash

./bin/emqx ctl rebalance stop

返却例は以下の通りです：

bash

./bin/emqx ctl rebalance stop
Rebalance(evacuation) stopped

HTTP APIによるノード避難の開始・停止

HTTP APIでもノード避難の開始・停止が可能で、避難対象ノードをパラメータで指定する必要があります。詳細はAPIドキュメントを参照してください。

負荷再分散

MQTTがステートフルな長時間接続プロトコルであるため、接続確立後は容易に切断されません。ノードをスケールアウトしても既存接続は自動的に新規ノードに移動しません。そのため、新規クライアント接続が少ない場合、追加ノードが長期間低負荷のままになることがあります。このような場合、高負荷ノードから低負荷ノードへ手動で接続を移行し、クラスター負荷のバランスを取る必要があります。

動作の仕組み

負荷再分散は複数ノードが関与するため、より複雑な処理です。

任意のノードでクラスター負荷再分散タスクを開始できます。EMQXは各ノードの現在の接続負荷に基づき、必要な接続移行計画を自動計算します。高負荷ノードから低負荷ノードへ対応する数の接続とセッションを移行し、ノード間の負荷バランスを実現します。ワークフローは以下の通りです：

移行計画を計算し、再分散対象ノード（--nodesで指定）をソースノードとターゲットノードに分類：
- ソースノード：高負荷ノード
- ターゲットノード：低負荷ノード
ソースノードで新規接続の受付を停止。
一定期間（wait-health-checkで指定）待機し、ロードバランサー（LB）がソースノードをアクティブなバックエンドノードリストから除外するのを待つ。
ソースノード上の接続クライアントを徐々に切断し、平均接続数がターゲットノードと一致するまで続ける。
ターゲットノードがクライアントと再接続しセッションを引き継ぐのを待つ（wait-takeoverで指定）。
再接続待機時間経過後、ソースノードは残る未引き継ぎセッションをターゲットノードにsess-evict-rateで指定された速度で移行。

これで負荷再分散タスクは完了し、ソースノードは通常状態に戻ります。

TIP

負荷再分散は一時的な処理です。参加ノードのいずれかがクラッシュすると、全ノードで処理が中断されます。

CLIによる負荷再分散の開始と停止

CLIコマンドで負荷再分散の開始、状況取得、停止が可能です。

負荷再分散の開始

負荷再分散開始コマンドのフィールドは以下の通りです：

bash

rebalance start \
    [--nodes "node1@host1 node2@host2"] \
    [--wait-health-check Secs] \
    [--conn-evict-rate ConnPerSec] \
    [--abs-conn-threshold Count] \
    [--rel-conn-threshold Fraction] \
    [--conn-evict-rate ConnPerSec] \
    [--wait-takeover Secs] \
    [--sess-evict-rate CountPerSec] \
    [--abs-sess-threshold Count] \
    [--rel-sess-threshold Fraction]

フィールド	型	説明
`--nodes`	文字列	再分散に参加するノードのスペースまたはカンマ区切りリスト。コマンドを実行するノード（コーディネーター）を含む場合も含まない場合もあります。
`--wait-health-check`	正の整数	ノードがロードバランサー（LB）によりアクティブなバックエンドノードリストから除外されるまでの待機時間（秒、デフォルト60秒）。この時間経過後に負荷再分散処理が開始されます。
`--conn-evict-rate`	正の整数	ソースノードでのクライアント切断レート（接続数/秒）、デフォルトは毎秒500接続。
`--abs-conn-threshold`	正の整数	接続バランス判定の絶対閾値、デフォルト1000。
`--rel-conn-threshold`	数値 > 1.0	接続バランス判定の相対閾値、デフォルト1.1。
`--wait-takeover`	正の整数	すべての接続切断後、クライアントが再接続しセッションを引き継ぐまでの待機時間（秒、デフォルト60秒）。
`--sess-evict-rate`	正の整数	ソースノードでのセッション避難レート（セッション数/秒）、デフォルト毎秒500セッション。
`--abs-sess-threshold`	正の整数	セッションバランス判定の絶対閾値、デフォルト1000。
`--rel-sess-threshold`	数値 > 1.0	セッションバランス判定の相対閾値、デフォルト1.1。

セッションバランスの判定

接続がバランスしている条件は以下の通りです：

bash

avg(DonorConns) < avg(RecipientConns) + abs_conn_threshold
OR
avg(DonorConns) < avg(RecipientConns) * rel_conn_threshold

切断済みセッションにも同様のルールが適用されます。

例

3ノードemqx@127.0.0.1、emqx2@127.0.0.1、emqx3@127.0.0.1間で負荷再分散を行う場合、以下のコマンドを使用します：

bash

./bin/emqx ctl rebalance start \
	--wait-health-check 10 \
	--wait-takeover 60  \
	--conn-evict-rate 5 \
	--sess-evict-rate 5 \
	--abs-conn-threshold 30 \
	--abs-sess-threshold 30 \
	--nodes "emqx1@127.0.0.1 emqx2@127.0.0.1 emqx3@127.0.0.1"
Rebalance started

負荷再分散状況の取得

負荷再分散状況を取得するCLIコマンドは以下の通りです：

bash

./bin/emqx ctl rebalance status

例

bash

./bin/emqx ctl rebalance status
--------------------------------------------------------------------
Node 'emqx1@127.0.0.1': rebalance coordinator
Rebalance state: evicting_conns
Coordinator node: 'emqx1@127.0.0.1'
Donor nodes: ['emqx2@127.0.0.1','emqx3@127.0.0.1']
Recipient nodes: ['emqx1@127.0.0.1']
Connection eviction rate: 5 connections/second
Session eviction rate: 5 sessions/second
Connection goal: 0.0
Current average donor node connection count: 300.0

負荷再分散の停止

負荷再分散を停止するCLIコマンドは以下の通りです：

bash

emqx ctl rebalance stop

返却例は以下の通りです：

bash

./bin/emqx ctl rebalance stop
Rebalance stopped

HTTP APIによる負荷再分散の開始・停止

CLIで利用可能なすべての操作はAPIでも利用可能です。開始・停止コマンドはノードをパラメータとして指定する必要があります。詳細はAPIドキュメントを参照してください。

ロードバランサーの統合

ユーザーはロードバランサーを統合して避難／再分散を実施できます。切断されたクライアントが再接続を試みる際、ロードバランサーはバックエンドノードの現在の状態に基づき受け入れノードへリダイレクトします。ユーザーはロードバランサー統合のためにヘルスチェックパラメータを設定する必要があります。設定がないと過剰な切断が発生する可能性があります。これを支援するため、EMQXはヘルスチェック用REST APIを提供しています：

GET /api/v5/load_rebalance/availability_check

ヘルスチェックは、ドナーまたは避難中ノードに対してはHTTPコード503を返し、正常稼働中で接続を受け入れているノードにはHTTPコード200を返します。

例えば、3ノードのEMQXクラスターでMQTTリスナーがポート3001、3002、3003、REST APIポートが5001、5002、5003の場合、HAProxyの設定例は以下の通りです：

bash

defaults
  timeout connect 5s
  timeout client 60m
  timeout server 60m

listen mqtt
  bind *:1883
  mode tcp
  maxconn 50000
  timeout client 6000s
  default_backend emqx_cluster

backend emqx_cluster
  mode tcp
  balance leastconn
  option httpchk
  http-check send meth GET uri /api/v5/load_rebalance/availability_check hdr Authorization "Basic xxxxxx"
  server emqx1 127.0.0.1:3001 check port 5001 inter 1000 fall 2 rise 5 weight 1 maxconn 1000
  server emqx2 127.0.0.1:3002 check port 5002 inter 1000 fall 2 rise 5 weight 1 maxconn 1000
  server emqx3 127.0.0.1:3003 check port 5003 inter 1000 fall 2 rise 5 weight 1 maxconn 1000

Kubernetes

EMQX Operator

EMQX クラスター管理

API リファレンス

パスワード認証

監視

アクセスコントロール

統合

管理

Prometheus との統合

OpenTelemetry との統合

エンドツーエンドトレース

プラグインカタログ

JT/T 808 ゲートウェイ

GB/T 32960 ゲートウェイ

Volcengine RTC

シナリオ

GPT-Realtime

ノード避難とクラスター負荷再分散 ​