メッセージ消費の例外が発生した場合、ApsaraMQ for RocketMQコンソールにログインして、グループ内のコンシューマーの詳細を表示し、例外の考えられる原因を特定できます。 表示できるコンシューマーの詳細には、接続ステータス、サブスクリプションの一貫性、メッセージ消費関連のメトリック、およびクライアント情報が含まれます。
一般的なシナリオ
グループ内のコンシューマーの詳細には、接続ステータス、サブスクリプション、1秒あたりのメッセージ受信トランザクション (TPS) 、累積メッセージ数、およびJStack情報が含まれます。 ほとんどの場合、詳細は、次の表に示すシナリオで例外のトラブルシューティングに使用されます。
シナリオ | 問題の説明 | 提案 |
一貫性のないサブスクリプション | 対応するグループの グループ詳細 ページの サブスクリプション関係 セクションに、次のメッセージが表示されますサブスクリプション関係が一致していません。できるだけ早く処理してください! | 詳細については、「Inconsistent subscriptions」をご参照ください。 |
メッセージの蓄積 | 対応するグループの グループ詳細 ページで、処理中のメッセージ数 、レディネスメッセージの数 、および キュータイム パラメーターの値が予想よりも高くなっています。 | 詳細については、「」をご参照ください。蓄積されたメッセージをどのように処理できますか? |
グループに関する基本情報の表示
手順
ApsaraMQ for RocketMQコンソールにログインします。 左側のナビゲーションウィンドウで、インスタンス数 をクリックします。
上部のナビゲーションバーで、中国 (杭州) などのリージョンを選択します。 [インスタンス] ページで、管理するインスタンスの名前をクリックします。
左側のナビゲーションウィンドウで、グループ管理 をクリックします。 表示されるページで、管理するグループの名前をクリックします。
クエリ結果
次の図は、クエリ結果のサンプルを示しています。
項目 | 説明 |
消費者ステータス |
|
消費モード | コンシューマがメッセージをサブスクライブするために使用する消費モード。 ApsaraMQ for RocketMQは、クラスタリング消費モードとブロードキャスト消費モードをサポートしています。 デフォルトでは、クラスタリング消費モードが使用されます。 クライアントで消費モードを変更できます。 詳細については、「クラスタリング消費とブロードキャスト消費」をご参照ください。 |
リアルタイム消費速度 | グループ内のすべてのコンシューマーがメッセージを受信するために使用するTPSの総数。 |
処理中のメッセージ数 | クライアントが処理中で、クライアントが消費結果を返していないメッセージの数。 |
レディネスメッセージの数 | コンシューマーに表示され、ApsaraMQ for RocketMQブローカーで使用できるメッセージの数。 |
キュータイム | 現在の時点と最も早い準備完了メッセージの準備完了時刻との間の間隔。 このメトリックは、コンシューマがメッセージをプルする時間を示します。 |
サブスクリプション関係 | グループ内のすべてのコンシューマーのサブスクリプションが一貫しているかどうか、および各コンシューマーがサブスクライブしているタグが表示されます。 サブスクリプションの一貫性については、「サブスクリプションの一貫性」をご参照ください。 ApsaraMQ for RocketMQでは、接続されているクライアントのサブスクリプションのみを表示できます。 |
クライアント接続情報 | 各クライアントのIPアドレス、バージョン、スタックの詳細など、接続されているクライアントに関する情報を表示します。 |
グループ内のメッセージ蓄積に関する情報の表示
手順
グループ管理 ページで、ダッシュボード をクリックします。
ダッシュボード機能を使用して、インスタンスのすべてのメトリックを表示することもできます。 詳細いついては、「ダッシュボード」をご参照ください。
クエリ結果
グループのダッシュボードには、メッセージの蓄積量、メッセージの消費率、トピック内のメッセージの蓄積量、メッセージの生成率と消費率の変化を示すグラフなど、現在の消費シナリオに関連するメトリックが表示されます。
消費例外が発生した場合、次の手順に基づいて例外のトラブルシューティングを行うことができます。
図1: 消費シナリオインジケータで、蓄積されたメッセージの数が最も多いトピックを見つけます。
ページの上部で、トピックドロップダウンリストから図1で見つけたトピックを選択します。
例外が発生する時間範囲を絞り込むには、図2と図3のメッセージ蓄積量とメッセージ生成率と消費率の変化傾向を表示します。
時間範囲内にバックエンド操作が実行されるか、ネットワーク例外が発生するかを判断します。
関連ドキュメント
ApsaraMQ for RocketMQでは、次のAPI操作を呼び出して、グループのコンシューマー詳細とメッセージ蓄積をクエリすることもできます。