メインコンテンツへスキップ
バージョン: 5.0

概念

このセクションでは、Apache RocketMQ のコアとなる概念について説明します。

トピック​

トピックは、Apache RocketMQで同じビジネスロジックに属するメッセージの転送と保存に使用される最上位のコンテナです。詳細はこちら トピック。

メッセージタイプ​

タイプ管理とセキュリティ検証のためのメッセージ転送特性によって定義されたカテゴリ。Apache RocketMQは、NORMAL、FIFO、TRANSACTION、DELAYメッセージタイプをサポートしています。

情報

バージョン5.0以降、Apache RocketMQはメッセージタイプの検証の強制をサポートしています。つまり、各トピックは単一タイプのメッセージのみの送信を許可します。これにより、本番システムの運用と管理が容易になり、混乱を防ぐことができます。ただし、バージョン4.xとの下位互換性を確保するために、検証機能はデフォルトで有効になっています。

メッセージキュー​

MessageQueueは、Apache RocketMQでメッセージを保存および送信するために使用されるコンテナです。MessageQueueは、Apache RocketMQメッセージの最小の保存単位です。詳細はこちら MessageQueue。

メッセージ​

メッセージは、Apache RocketMQにおけるデータ伝送の最小単位です。プロデューサーは、ビジネスデータのロードと拡張属性をメッセージにカプセル化し、メッセージをApache RocketMQブローカーに送信します。その後、ブローカーは関連するセマンティクスに基づいてコンシューマーにメッセージを配信します。詳細はこちらメッセージ。

メッセージビュー​

MessageViewは、開発の観点からのメッセージに対する読み取り専用のインターフェースです。メッセージビューを使用すると、メッセージ内の複数のプロパティとペイロード情報を読み取ることができますが、メッセージ自体に変更を加えることはできません。

メッセージタグ​

MessageTagは、メッセージをトピックレベル以下に細分化できる、きめ細かいメッセージ分類プロパティです。コンシューマーは、特定のタグを購読することでメッセージのフィルタリングを実装します。詳細はこちら メッセージフィルタ。

メッセージオフセット​

メッセージは、優先順位に従ってキューに格納され、各メッセージはキュー内にLong型の固有の座標を持ち、これはメッセージサイトとして定義されます。詳細はこちら コンシューマーの進捗管理。

コンシューマーオフセット​

メッセージは、コンシューマーによって消費された後、すぐにキューから削除されるわけではありません。Apache RocketMQは、各コンシューマーグループに基づいて最後に消費されたメッセージを記録します。詳細はこちら コンシューマーの進捗管理。

メッセージキー​

MessageKeyは、メッセージ指向のインデックスプロパティです。メッセージインデックスを設定することで、対応するメッセージコンテンツをすばやく検索できます。

プロデューサー​

Apache RocketMQのプロデューサーは、メッセージを作成してサーバーに送信する機能的なメッセージングエンティティです。プロデューサーは通常、ビジネスシステムに統合され、Apache RocketMQでデータをメッセージとしてカプセル化し、メッセージをサーバーに送信する役割を果たします。詳細はこちら プロデューサー。

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

Apache RocketMQは、トランザクションメッセージングメカニズムを使用しており、プロデューサーはトランザクションチェッカーを実装して、トランザクションの最終的な整合性を確保する必要があります。詳細はこちらトランザクションメッセージ。

コンシューマーグループ​

コンシューマーグループは、Apache RocketMQで同じ消費動作を使用するコンシューマーを含むロードバランシンググループです。詳細はこちら コンシューマーグループ。

コンシューマー​

コンシューマーは、Apache RocketMQでメッセージを受信して処理するエンティティです。コンシューマーは通常、ビジネスシステムに統合されます。Apache RocketMQブローカーからメッセージを取得し、メッセージをビジネスロジックが認識して処理できる情報に変換します。詳細はこちら コンシューマー。

サブスクリプション​

サブスクリプションは、Apache RocketMQでコンシューマーがメッセージを取得および処理するためのルールとステータス設定です。サブスクリプションは、コンシューマーグループによってブローカーに動的に登録されます。その後、メッセージは、サブスクリプションによって定義されたフィルタルールに基づいて照合され、消費されます。詳細はこちら サブスクリプション。