グループには、同じロジックに基づいて同じタイプのメッセージを生成または消費するプロデューサまたはコンシューマが含まれます。 ApsaraMQ for RocketMQを使用してメッセージを生成または消費するには、同じタイプのプロデューサーインスタンスまたはコンシューマーインスタンスを識別するグループを作成する必要があります。 このトピックでは、ApsaraMQ for RocketMQコンソールでグループを作成および削除する方法について説明します。 このトピックでは、グループの詳細を表示する方法についても説明します。
制限事項
ApsaraMQ for RocketMQインスタンスに最大1,000個のグループを作成できます。 できるだけ早い機会に不要になったグループを再利用するか、グループを削除することをお勧めします。 グループの上限を引き上げたい場合は、ApsaraMQ for RocketMQテクニカルサポートまでお問い合わせください。
インスタンス間でグループを使用することはできません。 たとえば、インスタンスaで作成されたグループは、インスタンスBでは使用できません。
ApsaraMQ for RocketMQでは、コンシューマはHTTPまたはTCPプロトコルを介してメッセージを消費できます。 異なる消費者グループは異なるプロトコルを使用できます。 グループ内のすべてのコンシューマーに同じプロトコルを指定することを推奨します。
同じグループ内のコンシューマが異なるプロトコルでメッセージを消費する場合、メッセージ消費が失敗し、メッセージの重複またはメッセージの損失が発生する可能性があります。
グループ内のコンシューマがメッセージを消費するプロトコルを変更するには、約1〜2時間が必要です。
グループ内のコンシューマーがApsaraMQ for RocketMQコンソールに表示されているプロトコルとは異なるプロトコルでメッセージを消費すると、コンソールに表示されるデータが不正確になる可能性があります。 これは、グループのメッセージングには影響しません。 この場合、ApsaraMQ for RocketMQテクニカルサポートに連絡して、コンソールに表示されるプロトコルを、グループ内のコンシューマーが使用するプロトコルに変更できます。
コンシューマーごとにグループIDを指定する必要があります。 プロデューサーごとにグループIDを指定する必要はありません。
グループIDの命名規則
グループIDは2 ~ 64文字で、英数字、ハイフン (-) 、およびアンダースコア (_) を使用できます。 グループIDにプレフィックスGID_またはGID-を含めることを推奨します。
グループが属するインスタンスに名前空間がある場合、グループのIDはインスタンス内で一意である必要があります。 グループIDは、インスタンス内の既存のグループIDまたはトピック名と同じにすることはできません。 異なるインスタンスのグループIDとトピック名は同じにすることができます。 たとえば、インスタンスaのグループIDは、インスタンスBのグループIDまたはトピック名と同じにすることができます。
グループが属するインスタンスに名前空間が含まれていない場合、グループIDはインスタンスおよびリージョン間でグローバルに一意である必要があります。 グループIDは、Alibaba CloudアカウントのApsaraMQ for RocketMQの既存のグループIDまたはトピック名と同じにすることはできません。
ApsaraMQ for RocketMQコンソールの インスタンスの詳細 ページの 基本情報 セクションで、インスタンスに名前空間が含まれているかどうかを確認できます。
コンシューマーグループの作成
ApsaraMQ for RocketMQコンソールにログインします。 左側のナビゲーションウィンドウで、インスタンス数 をクリックします。
上部のナビゲーションバーで、中国 (杭州) などのリージョンを選択します。 [インスタンス] ページで、管理するインスタンスの名前をクリックします。
左側のナビゲーションウィンドウで、グループ管理.
グループ管理ページで、クライアントSDKのプロトコルを選択し、グループの作成.
ApsaraMQ for RocketMQは、クライアントSDKのTCP プロトコルとHTTP プロトコルをサポートしています。
表示されるパネルで、[グループID] および [説明] パラメーターを設定し、[OK] をクリックします。
グループの削除
グループを削除すると、グループのIDで識別されるコンシューマーインスタンスはメッセージの受信を停止します。 グループ内のリソースも削除され、復元できません。 グループを削除するときは注意してください。
インスタンス数 ページで、管理するインスタンスの名前をクリックします。 表示されるページの左側のナビゲーションウィンドウで、グループ管理 をクリックします。
グループリストで、管理するグループを見つけ、詳細で、操作列を選択し、削除ドロップダウンリストから
表示されるメッセージで、OK.
グループの詳細を表示する
インスタンス数 ページで、管理するインスタンスの名前をクリックします。 表示されるページの左側のナビゲーションウィンドウで、グループ管理 をクリックします。
グループリストで、管理するグループを見つけます。 次に、グループのIDをクリックするか、グループに対応する 操作 列の 詳細 をクリックして、[グループの詳細] ページに移動します。
その他操作
グループ管理 ページでは、次の操作も実行できます。
左側のナビゲーションウィンドウで、グループ管理.
[グループ] リストで、管理するグループを見つけ、操作 列の 詳細 をクリックし、ドロップダウンリストから次のいずれかの操作を選択します。
高速アクセス: ApsaraMQ for RocketMQが複数のプログラミング言語のSDKに提供する参照を表示します。
消費地点をリセットする: コンシューマーオフセットをリセットして、累積または不要なメッセージをスキップし、新しいオフセットからメッセージの消費を開始します。 特定の時点より前のメッセージが消費されるかどうかに関係なく、特定の時点より後にメッセージを消費することもできます。 詳細については、「コンシューマオフセットのリセット」をご参照ください。
Cloud Monitor: グループ内のメッセージの作成または消費のモニタリングデータを表示します。
ダッシュボード: グループの消費メトリック統計を表示します。
関連ドキュメント
次のAPIを呼び出してグループを管理できます。
OnsGroupCreate: グループを作成します。
OnsGroupDelete: グループを削除します。
OnsGroupList: ApsaraMQ for RocketMQインスタンスのすべてのグループを照会します。
OnsGroupSubDetail: グループがサブスクライブするトピックを照会します。
OnsGroupConsumerUpdate: グループの読み取りおよび書き込み権限を設定します。