メッセージ、ペイロード、およびシリアル化
Microsoft Azure Service Bus はメッセージを処理します。 メッセージには、ペイロードとメタデータが含まれています。 メタデータはキーと値のペアという形式をとり、ペイロードを記述し、処理の指示を Service Bus とアプリケーションに提供します。 ときには、メタデータ単独で送信者が受信者に伝える必要がある情報が運搬され、ペイロードは空のままという場合もあります。
.NET および Java 用の公式 Service Bus クライアントのオブジェクト モデルには、Service Bus でサポートされているワイヤ プロトコルと相互にマップされた Service Bus の抽象的なメッセージ構造が反映されています。
Service Bus メッセージは、どのような形式でもサービス側で Service Bus によって処理されないバイナリ ペイロード セクションと、2 つのプロパティ セットで構成されます。 "ブローカー プロパティ" は、システムによって事前定義されています。 この事前定義されているプロパティは、ブローカー内のメッセージ レベルの機能を制御するか、一般的な標準化されたメタデータ項目にマップされます。 "ユーザー プロパティ" は、アプリケーションが定義および設定できるキーと値のペアのコレクションです。
次の表に、事前定義されているブローカー プロパティの一覧を示します。 これらの名前は、すべての公式クライアント API と、HTTP プロトコル マッピングの JSON オブジェクト BrokerProperties でも使用されます。
カッコ内には、Advanced Message Queuing Protocol (AMQP) プロトコル レベルで使用される同等の名前を示しています。 次の名前ではパスカル ケースが使用されていますが、JavaScript および Python クライアントでは、それぞれキャメル ケースとスネーク ケースが使用されます。
| プロパティ名 | 説明 |
|---|---|
ContentType (content-type) |
これは省略可能であり、RFC2045 のセクション 5 の形式に従った記述子を使用してメッセージのペイロードを記述します (例: application/json)。 |
CorrelationId (correlation-id) |
相関関係のために、アプリケーションがメッセージのコンテキストを指定できるようにします (たとえば、応答されるメッセージの MessageId を示すなど)。 |
DeadLetterSource |
配信不能になっていて、後で配信不能キューから別のエンティティに自動転送されるメッセージでのみ設定されます。 メッセージが配信不能になったエンティティを示します。 このプロパティは読み取り専用です。 |
DeliveryCount |
このメッセージに対して試行された配信の数です。 このカウントは、メッセージのロックが有効期限切れになった場合、またはメッセージが受信者によって明示的に破棄された場合に増分されます。 このプロパティは読み取り専用です。 基になる AMQP 接続が閉じられると、配信の数は増加しません。 |
EnqueuedSequenceNumber |
このプロパティは、自動転送されたメッセージの場合に、元の送信地点で最初にメッセージに割り当てられたシーケンス番号を示します。 このプロパティは読み取り専用です。 |
EnqueuedTimeUtc |
メッセージがエンティティで受け入れおよび格納された UTC 時刻。 この値は、受信者が送信者の時計を信頼したくない場合に、信頼できる中立的な到着時間インジケーターとして使用できます。 このプロパティは読み取り専用です。 |
ExpiresAtUtc (absolute-expiry-time) |
有効期限切れが原因でメッセージが削除対象としてマークされ、エンティティから取得できなくなった UTC 時刻。 有効期限は TimeToLive プロパティによって制御されるため、このプロパティは EnqueuedTimeUtc と TimeToLive に基づいて計算されます。 このプロパティは読み取り専用です。 |
Label または Subject (subject) |
このプロパティを使用すると、アプリケーションは、電子メールの件名行と同様に標準化された方法でメッセージの目的を受信者に示すことができます。 |
LockedUntilUtc |
このプロパティは、ロックされた状態 (事前設定ではなくピーク ロック受信モード) で取得されたメッセージの場合に、メッセージがキュー/サブスクリプション内でロック状態に保持される期限の UTC 時刻を示します。 ロックが有効期限切れになると DeliveryCount が増分され、メッセージが再び取得可能になります。 このプロパティは読み取り専用です。 |
LockToken |
ロック トークンは、ブローカーが "ピーク ロック" 受信モードで保持しているロックへの参照です。 このトークンを使用すると、遅延 API を使用してロックをピン留めし、メッセージを通常の配信状態フローから除外することができます。 このプロパティは読み取り専用です。 |
MessageId (message-id) |
メッセージ識別子は、アプリケーションによって定義される、メッセージとそのペイロードを一意に識別する値です。 この識別子は自由形式の文字列で、GUID またはアプリケーションのコンテキストから派生した識別子を反映することができます。 有効にした場合、重複データ検出機能は、同じ MessageId を持つメッセージの 2 回目以降の送信を識別して削除します。 |
PartitionKey |
パーティション分割されたエンティティの場合、この値を設定すると、関連するメッセージを同じ内部パーティションに割り当てて、送信順序が正しく記録されるようにできます。 パーティションはハッシュ関数でこの値を介して選択され、直接選択することはできません。 セッションを認識するエンティティの場合、この値は SessionId プロパティによってオーバーライドされます。 |
ReplyTo (reply-to) |
これはアプリケーションによって定義される省略可能な値であり、メッセージの受信者への応答パスを表す標準的な方法です。 応答が必要な場合、送信者は、この値を応答の送信先にするキューまたはトピックの絶対または相対パスに設定します。 |
ReplyToSessionId (reply-to-group-id) |
この値は、ReplyTo の情報を補足し、応答が応答エンティティに送信されるときに設定する必要がある SessionId を指定します。 |
ScheduledEnqueueTimeUtc |
このプロパティは、遅延後にのみ取得可能になるメッセージの場合に、メッセージが論理的にエンキューされ、シーケンス処理されて取得可能になる UTC 時刻を定義します。 |
SequenceNumber |
このシーケンス番号は、メッセージがブローカーおよび関数によって受け入れおよび格納されるときに真の識別子として割り当てられる 64 ビットの整数です。 パーティション分割されたエンティティの場合、最上位の 16 ビットはパーティション識別子を表します。 シーケンス番号はギャップなしで単調に増分されます。 48 - 64 ビット範囲が使い果たされると、0 にロールオーバーされます。 このプロパティは読み取り専用です。 |
SessionId (group-id) |
この値はアプリケーションによって定義され、セッションを認識するエンティティの場合に、メッセージのセッションへの所属を指定します。 同じセッション識別子を持つメッセージがまとめてロックされ、正確な順序での処理と多重化が可能になります。 セッションを認識しないエンティティの場合、この値は無視されます。 |
TimeToLive |
この値は、EnqueueTimeUtc でキャプチャされた、メッセージがブローカーによって受け入れおよび格納された時刻から、それが有効期限切れになるまでの相対的な期間です。 明示的に設定しない場合、それぞれのキューまたはトピックの DefaultTimeToLive が値として見なされます。 メッセージレベルの TimeToLive 値をエンティティの DefaultTimeToLive の設定より長くすることはできません。 長い場合は、自動的に調整されます。 |
To (to) |
このプロパティはルーティング シナリオでの将来の使用のために予約されており、現在はブローカー自体で無視されます。 アプリケーションは、ルールに基づく自動転送チェーンのシナリオでこの値を使用して、メッセージの目的の論理送信先を示すことができます。 |
ViaPartitionKey |
メッセージがトランザクションのスコープ内の転送キュー経由で送信される場合、この値によって転送キューのパーティションが選択されます。 |
この抽象メッセージ モデルでは、メッセージを HTTPS を介してキューに送信し、AMQP を介して取得することができます。 いずれの場合も、メッセージはそれぞれのプロトコルのコンテキストで正常と見なされます。 ブローカー プロパティは必要に応じて変換され、ユーザー プロパティはそれぞれのプロトコルのメッセージ モデルで最適な場所にマップされます。 ユーザー プロパティは、HTTP では直接 HTTP ヘッダーと相互にマップされ、AMQP では application-properties マップと相互にマップされます。
メッセージのルーティングと相関関係
アプリケーションが特定の宛先にメッセージをルーティングできるように、上記のブローカー プロパティのサブセット (具体的には、To、ReplyTo、ReplyToSessionId、MessageId、CorrelationId、および SessionId) が使用されます。 この機能を示すために、いくつかのパターンについて考えてみましょう。
- 単純な要求/応答: 公開元がキューにメッセージを送信し、メッセージ コンシューマーからの応答を待ちます。 応答を受信するために、公開元は応答が配信されると予想されるキューを所有します。 キューのアドレスは、送信メッセージの ReplyTo プロパティで示されます。 コンシューマーが応答するときは、処理されるメッセージの MessageId を応答メッセージの CorrelationId プロパティにコピーし、ReplyTo プロパティで示された宛先にメッセージを配信します。 アプリケーションのコンテキストによっては、1 つのメッセージから複数の応答が生成される場合もあります。
- マルチキャスト要求/応答: 前のパターンのバリエーションとして、パブリッシャーがメッセージをトピックに送信し、複数のサブスクライバーがそのメッセージを使用できるようになります。 各サブスクライバーは、上記の方法で応答することができます。 このパターンは検出またはロール呼び出しのシナリオで使用され、応答者は通常、ユーザー プロパティによって、またはペイロード内で自身を識別します。 ReplyTo がトピックをポイントしている場合、そのような検出応答のセットを対象ユーザーに配布できます。
- 多重化: このセッション機能により、1 つのキューまたはサブスクリプションで関連するメッセージのストリームを多重化して、受信者がロックされたセッションを保持している間に、一致する SessionId 値で識別された関連するメッセージの各セッション (またはグループ) が特定の受信者にルーティングされるようにできます。 セッションの詳細については、こちらをご覧ください。
- 多重化された要求/応答: このセッション機能を使用すると、多重化された応答を有効にして、複数の発行元が応答キューを共有できるようになります。 発行元は ReplyToSessionId を設定することにより、その値を応答メッセージの SessionId プロパティにコピーするようにコンシューマーに指示できます。 発行キューまたはトピックがセッションを認識する必要はありません。 メッセージが送信されると、発行元はセッション レシーバーを条件付きで受け入れることにより、特定の SessionId を持つセッションだけを待機してキューで具体化できます。
Service Bus 名前空間内のルーティングは、自動転送チェーンとトピック サブスクリプション規則によって実現できます。 名前空間の間のルーティングは、Azure LogicApps の使用によって実現できます。 前の一覧に示したように、To プロパティは将来の使用のために予約されており、最終的には特別に有効にされた機能を持つブローカーによって解釈される可能性があります。 ルーティングを実装するアプリケーションは、To プロパティを使用せずにユーザー プロパティに基づいて実装する必要があります。ただし、現時点では To プロパティを使用しても互換性の問題は発生しません。
ペイロードのシリアル化
ペイロードは、転送中または Service Bus 内に格納されているときには常に、不透明なバイナリ ブロックです。 ContentType プロパティにより、アプリケーションは IETF RFC2045 に従ってペイロードを記述できます。これはプロパティ値に対する推奨形式である MIME コンテンツ タイプの記述です (例: application/json;charset=utf-8)。
Java または .NET Standard バージョンとは異なり、.NET Framework バージョンの Service Bus API では、任意の .NET オブジェクトをコンストラクターに渡して BrokeredMessage インスタンスを作成することができます。
2026 年 9 月 30 日に、Azure SDK ガイドラインに準拠していない Azure Service Bus SDK ライブラリ WindowsAzure.ServiceBus、Microsoft.Azure.ServiceBus、および com.microsoft.azure.servicebus は廃止されます。 SBMP プロトコルのサポートも終了するため、2026 年 9 月 30 日以降はこのプロトコルを使用できなくなります。 この日付より前に、重要なセキュリティ更新プログラムと強化された機能が提供される、最新の Azure SDK ライブラリに移行してください。
古いライブラリは 2026 年 9 月 30 日以降も引き続き使用できますが、Microsoft から公式のサポートと更新プログラムは提供されなくなります。 詳細については、サポート廃止のお知らせに関するページを参照してください。
レガシ SBMP プロトコルを使用する場合、これらのオブジェクトは、既定のバイナリ シリアライザーまたは外部から提供されたシリアライザーを使用してシリアル化されます。 オブジェクトは AMQP オブジェクトにシリアル化されます。 受信側は、必要な型を指定し、GetBody\<T>() メソッドを使用してこれらのオブジェクトを取得できます。 AMQP の場合、オブジェクトは ArrayList および IDictionary<string,object> の各オブジェクトの AMQP グラフにシリアル化され、どの AMQP クライアントでも復号化できます。
2026 年 9 月 30 日に Azure Service Bus 用の SBMP プロトコルのサポートは終了するため、2026 年 9 月 30 日以降はこのプロトコルを使用できなくなります。 その日付より前に、(重要なセキュリティ更新プログラムと強化された機能が提供される) AMQP プロトコルを使った最新の Azure Service Bus SDK ライブラリに移行してください。
詳細については、サポート廃止のお知らせに関するページを参照してください。
この見えないシリアル化のマジックは便利ですが、アプリケーションはオブジェクトのシリアル化を明示的に制御して、オブジェクト グラフをメッセージに含める前にストリームに変換し、受信側ではその逆の操作を行う必要があります。 これは相互運用可能な結果を生成します。 AMQP には強力なバイナリ エンコード モデルがありますが、それは AMQP メッセージング エコシステムに関連付けられており、HTTP クライアントがそのようなペイロードをデコードすると問題が発生します。
.NET Standard および Java バージョンの API はバイト配列しか受け入れません。つまり、アプリケーションはオブジェクトのシリアル化制御を処理する必要があります。
メッセージ ペイロードからのオブジェクトの逆シリアル化を処理する場合、異なるシリアル化メソッドを使用して複数のソースからメッセージが到着する可能性があることを、開発者は考慮する必要があります。 これは、古いバージョンが新しいバージョンと共に実行され続ける可能性がある、単一のアプリケーションを進化させるときにも発生することがあります。 このようなケースでは、逆シリアル化の最初の試行が失敗した場合に備え、追加の逆シリアル化メソッドを用意することをお勧めします。 これに対応するライブラリの 1 つが NServiceBus です。 すべての逆シリアル化メソッドが失敗する場合は、メッセージを配信不能にすることをお勧めします。
次のステップ
Service Bus メッセージングの詳細については、次のトピックをご覧ください。