ApsaraMQ for RocketMQ:用語

Topic

• Topic は、ApsaraMQ for RocketMQ におけるメッセージの送信とストレージのための最上位のコンテナーです。同じ業務カテゴリに属するメッセージを識別するために使用されます。Topic はその名前によって一意に識別されます。詳細については、「Topics」をご参照ください。

Lite topic

• Topic が Lite タイプの場合、その下に lite topic を作成できます。メッセージのストレージコンテナーは、Topic と lite topic の組み合わせによって一意に識別されます。デフォルトでは、各ストレージコンテナーは 1 つのキューで構成されます。詳細については、「Lite topic モデル」をご参照ください。

メッセージタイプ

• メッセージタイプは、ApsaraMQ for RocketMQ におけるメッセージを、その送信特性に基づいて分類したものです。メッセージタイプは、タイプ管理とセキュリティ検証に使用されます。ApsaraMQ for RocketMQ は、通常メッセージ、順序付きメッセージ、トランザクションメッセージ、およびスケジュール/遅延メッセージをサポートしています。

メッセージキュー

• メッセージキューは、ApsaraMQ for RocketMQ におけるメッセージの保存と送信のための実際のコンテナーです。また、メッセージの最小ストレージユニットでもあります。ApsaraMQ for RocketMQ のすべての Topic は複数のキューで構成されています。この設計により、キューの水平分割と各キュー内でのストリーミングストレージが可能になります。キューは QueueId によって一意に識別されます。詳細については、「メッセージキュー」をご参照ください。

メッセージ

• メッセージは、ApsaraMQ for RocketMQ におけるデータ送信の最小単位です。プロデューサーは、業務データのペイロードと拡張プロパティをメッセージにカプセル化し、ApsaraMQ for RocketMQ サーバーに送信します。その後、サーバーは関連するセマンティクスに基づいて、処理のためにメッセージをコンシューマーに配信します。詳細については、「メッセージ」をご参照ください。

メッセージビュー

• メッセージビューは、開発者の視点から ApsaraMQ for RocketMQ によって提供される読み取り専用インターフェイスです。メッセージビューを使用すると、メッセージの複数のプロパティとペイロードを読み取ることができますが、メッセージ自体を変更することはできません。

メッセージタグ

• メッセージタグは、ApsaraMQ for RocketMQ における詳細なメッセージ分類のためのプロパティです。これにより、Topic の下でメッセージをサブカテゴリ化できます。コンシューマーは、特定のタグをサブスクライブすることで、詳細なフィルターを使用できます。詳細については、「メッセージのフィルタリング」をご参照ください。

メッセージオフセット

• メッセージは、ApsaraMQ for RocketMQ サーバーに到着した順序で Topic のキューに保存されます。キュー内の各メッセージには、一意の Long 型の座標があります。この座標がメッセージオフセットです。詳細については、「コンシューマーの進捗管理」をご参照ください。

コンシューマオフセット

• メッセージは、消費された後もキューからすぐには削除されません。各使用者グループに対して、ApsaraMQ for RocketMQ は最後に消費されたメッセージのオフセットを記録します。この記録されたオフセットがコンシューマオフセットです。詳細については、「コンシューマーの進捗管理」をご参照ください。

メッセージキー

• メッセージキーは、ApsaraMQ for RocketMQ によって提供されるメッセージのインデックスプロパティです。メッセージキーを設定することで、対応するメッセージの内容を迅速に見つけることができます。

プロデューサー

• ApsaraMQ for RocketMQ システムにおいて、プロデューサーはメッセージを構築してサーバーに送信する実行エンティティです。プロデューサーは通常、業務システムに統合されます。業務データを ApsaraMQ for RocketMQ メッセージにカプセル化し、サーバーに送信します。詳細については、「プロデューサー」をご参照ください。

トランザクションチェッカー

• トランザクションチェッカーは、ApsaraMQ for RocketMQ のプロデューサーがローカルトランザクションのチェックを実行し、異常なトランザクションから回復するために使用するリスナーです。トランザクションチェッカーは、業務データのステータスに基づいて、トランザクションメッセージの解像度をチェックして決定する必要があります。詳細については、「トランザクションメッセージ」をご参照ください。

トランザクションの解像度

• トランザクションの解像度は、ApsaraMQ for RocketMQ での送信プロセス中のトランザクションメッセージのコミットステータスの識別子です。サーバーはトランザクションの解像度を使用して、トランザクションメッセージをコミットして配信するかどうかを制御します。トランザクションの解像度には、コミット、ロールバック、および保留が含まれます。詳細については、「トランザクションメッセージ」をご参照ください。

使用者グループ

• ApsaraMQ for RocketMQ システムにおいて、使用者グループは、同一の消費動作を持つ複数のコンシューマーを含む負荷分散グループです。コンシューマーとは異なり、使用者グループは実行エンティティではなく、論理リソースです。ApsaraMQ for RocketMQ では、使用者グループ内で複数のコンシューマーを初期化することで、消費パフォーマンスの水平スケーリングと高可用性のディザスタリカバリを実現します。詳細については、「使用者グループ」をご参照ください。

コンシューマー

• ApsaraMQ for RocketMQ において、コンシューマーはメッセージを受信して処理する実行エンティティです。コンシューマーは通常、業務システムに統合されます。コンシューマーは ApsaraMQ for RocketMQ サーバーからメッセージを取得し、業務ロジックで処理するために業務で理解可能な情報に変換します。詳細については、「コンシューマー」をご参照ください。

消費結果

• 消費結果は、ApsaraMQ for RocketMQ の PushConsumer のリスナーがメッセージの処理を完了した後に返されます。これは、メッセージが正しく処理されたかどうかを示します。消費結果には、成功と失敗が含まれます。

サブスクリプション

• サブスクリプションは、ApsaraMQ for RocketMQ システムでコンシューマーがメッセージを取得して処理する方法に関するルールとステータスの構成です。サブスクリプションは、使用者グループによってサーバーに動的に登録されます。その後のメッセージ送信中に、サブスクリプションで定義されたフィルター ルールがメッセージのマッチングとコンシューマーの進捗のメンテナンスに使用されます。詳細については、「サブスクリプション」をご参照ください。

メッセージのフィルタリング

• コンシューマーは、特定のメッセージタグ (Tags) をサブスクライブすることでメッセージをフィルターし、フィルターされたメッセージセットのみを受信するようにできます。フィルター ルールの計算とマッチングは、ApsaraMQ for RocketMQ サーバーで完了します。詳細については、「メッセージのフィルタリング」をご参照ください。

コンシューマオフセットのリセット

• この機能は、使用者グループのサブスクライブされた Topic の消費進捗を特定の時点にリセットします。リセット後、コンシューマーは指定された時点以降にプロデューサーから ApsaraMQ for RocketMQ サーバーに送信されたメッセージを受信します。詳細については、「コンシューマオフセットのリセット」をご参照ください。

メッセージトレース

• メッセージトレースは、メッセージの完全なリンク情報を提供します。この情報は、メッセージがプロデューサーからコンシューマーに移動する際に、各関連ノードからの時間や場所などのデータから集約されます。メッセージトレースを使用すると、プロデューサーから ApsaraMQ for RocketMQ サーバーを経由してコンシューマーに至るまでのメッセージの完全なパスを明確に確認できます。これは、トラブルシューティングと問題の診断に役立ちます。

メッセージの蓄積

• メッセージの蓄積は、プロデューサーがコンシューマーの処理速度よりも速く ApsaraMQ for RocketMQ サーバーにメッセージを送信した場合に発生します。消費されていないメッセージは ApsaraMQ for RocketMQ サーバーに保存されます。

トランザクションメッセージ

• トランザクションメッセージは、ApsaraMQ for RocketMQ が提供する高度なメッセージタイプです。分散シナリオにおいて、メッセージの生成とローカルトランザクション間の結果整合性を保証します。

スケジュール/遅延メッセージ

• スケジュール/遅延メッセージは、ApsaraMQ for RocketMQ が提供する高度なメッセージタイプです。メッセージがサーバーに送信された後、指定された時間が経過した後にのみコンシューマーによって消費されます。特定の遅延時間を設定することで、分散シナリオで遅延スケジューリングとトリガー効果を実現できます。

順序付きメッセージ

• 順序付きメッセージは、ApsaraMQ for RocketMQ が提供する高度なメッセージタイプです。コンシューマーが送信された順序と同じ順序でメッセージを受信することを保証します。これにより、業務シナリオでのシーケンシャルな処理が可能になります。

Lite メッセージ

• Lite メッセージは、ApsaraMQ for RocketMQ が提供する高度なメッセージタイプです。数百万の lite topic の動的な作成をサポートし、自動化されたライフサイクル管理やパフォーマンス専有型サブスクリプションなどの特徴を提供します。詳細については、「Lite topic モデル」をご参照ください。