MQTT クライアントが接続または切断すると、バックエンドアプリケーションは、セッション管理、監査ログ、またはフェールオーバー処理のために、これらのイベントをリアルタイムで把握する必要があることがよくあります。クライアントステータス通知ルールは、これらのオンライン/オフラインイベントを ApsaraMQ for MQTT から ApsaraMQ for RocketMQ トピックに転送し、バックエンドサービスがそれらを利用できるようにします。
通知の送信先としてサポートされているのは、ApsaraMQ for RocketMQ 4.0 インスタンスのみです。MQTT インスタンスと RocketMQ インスタンスは同じリージョンにある必要があります。
仕組み
ApsaraMQ for MQTT クライアントがブローカーに接続または切断します。
ブローカーは、設定されたルールに基づいてステータス通知イベントを生成します。
イベントは、指定された ApsaraMQ for RocketMQ トピックに転送されます。
Elastic Compute Service (ECS) インスタンスにデプロイされたバックエンドサービスは、RocketMQ トピックをサブスクライブし、通知を処理します。
転送されたイベントのメッセージ構造の詳細については、「Message Queue for MQTT と Message Queue for Apache RocketMQ 間のメッセージ構造マッピング」をご参照ください。
クライアントステータス通知ルールの作成
開始する前に、以下があることを確認してください。
カーネルバージョン V3.x.x の ApsaraMQ for MQTT インスタンス
MQTT インスタンスと同じリージョンにある ApsaraMQ for RocketMQ 4.0 インスタンス
通知イベントを受信する RocketMQ トピック
監視する MQTT デバイス用に設定されたグループ ID
ルールを作成するには、次のステップに従います。
ApsaraMQ for MQTT コンソールにログインします。左側のナビゲーションウィンドウで、[インスタンス] をクリックします。
上部のナビゲーションバーで、ご利用のインスタンスが存在するリージョンを選択します。インスタンス名をクリックして、[インスタンス詳細] ページに移動します。
左側のナビゲーションウィンドウで、[ルール] をクリックします。ページの左上隅で、[ルール作成] をクリックします。
[基本情報の構成] ステップで、次のパラメーターを設定し、[次へ] をクリックします。
パラメーター 例 説明 ルール ID 111111 ルールのグローバルに一意の識別子。文字、数字、ハイフン (-)、アンダースコア (_) を含めることができます。少なくとも1つの文字または数字を含める必要があり、3～64文字の長さである必要があります。64文字を超える値は自動的に切り捨てられます。作成後に変更することはできません。 説明 migrate from rocketmq ルールの説明。 ステータス Enable ルールをすぐに有効にするかどうか。有効な値：[有効化]、[無効化]。 ルールタイプ Client Status Notification クライアントのオンライン/オフラインイベントを転送するには、[クライアントステータス通知] を選択します。その他の有効な値：[データアウトバウンド] (「ApsaraMQ for MQTT から他の Alibaba Cloud サービスへのデータのエクスポート」をご参照ください)、[データインバウンド] (「他のクラウドサービスから ApsaraMQ for MQTT へのデータのインポート」をご参照ください)。 [ルールソースの構成] ステップで、データソースを設定し、[次へ] をクリックします。
パラメーター 例 説明 グループ ID GID_Client_Status ステータスイベントが転送されるデバイスのグループ ID。グループ ID の詳細については、「用語」をご参照ください。 [ルール送信先の構成] ステップで、転送されたイベントの送信先を設定し、[作成] をクリックします。
パラメーター 例 説明 宛先サービスの種類 Message Queue for Apache RocketMQ ステータスイベントを受信するクラウドサービス。ApsaraMQ for RocketMQ のみがサポートされています。 Message Queue for Apache RocketMQ インスタンス MQ_INST_13801563067\*\*\*\*\*_BbyOD2jQ イベントを受信する ApsaraMQ for RocketMQ インスタンス。MQTT インスタンスと同じリージョンにある必要があります。 トピック TopicB 通知イベントを受信する RocketMQ トピック。
ルールが作成された後、[ルール] ページに表示されます。
ルールの編集
[ルール] ページで、対象のルールを見つけます。[操作] 列で、[その他] > [編集] を選択します。
[ルール編集] ページで、[ルール ID] を除く任意のパラメーターを変更します。
「[保存]」を、[ルールの送信先の設定] ステップでクリックします。
ルールの有効化または無効化
[ルール] ページで、対象のルールを見つけます。[操作] 列で、[その他] > [有効化] または [無効化] を選択します。
確認ダイアログボックスで、[OK] をクリックします。
ルールの削除
[ルール] ページで、対象のルールを見つけます。[操作] 列で、[その他] > [削除] を選択します。
確認ダイアログボックスで、[OK] をクリックします。