1.はじめに

本記事は、毎年恒例のMicrosoft Azureアドベントカレンダーの参加記事です。 11月のCDP勉強会にてご紹介したデモのコード解説とともにお送りしてきた「Service Busメッセージングを使ってみよう」のTopicとSubscriptionのパートを今回ご紹介していきたいと思います。 前回までのQueueの取り扱いと基本的には同様ですが、TopicとSubscriptionではそれぞれ役割が分かれているため、Topicで設定すべき項目とSubscriptionで設定すべき項目に分かれます。 すなわち、ある機能をメッセージングに持たせようとした場合、Topic側の設定だけで完結する場合とSubscription側の設定で完結する場合、そして双方の設定がすべて完結していないと利用できない場合とがあります。 それぞれについて触れていきましょう。

 

2.Topicで設定すべきこととSubscriptionで設定すべきこと

それでは早速、TopicおよびSubscriptionの属性であるTopicDescriptionとSubscriptionDescriptionの設定項目を見てみましょう。 まずはTopicDescriptionです。主なプロパティを以下に示します。

 

 

出典：MSDNライブラリ「TopicDescription クラス」リファレンス

出典：MSDNライブラリ「SubscriptionDescription」リファレンス

たとえば、エクスプレスエンティティを有効にする場合にはTopic側で設定が必要です。また、セッションはSubscription側で設定します。また、メッセージの有効期限を設定するDefaultMessageTimeToLiveはTopicおよびSubscriptionの双方で指定可能ですが、より短い有効期限が適用されます。ただしメッセージ自身に有効期限が設定されている場合は、メッセージの設定値が優先されます。 また、バッチ送受信サポート状態を設定するEnableBatchedOperationsはTopic側で有効すると送信時のバッチ送信が可能となり、Subscriptionで有効にすると受信時のバッチ受信が有効となります。

 

 

3.フィルタリングの実現

TopicおよびSubscriptionでは特定の条件に従ってメッセージをフィルタリングすることができます。 たとえば、特定のタグを持つメッセージのみを受信したい場合、各Subscriptionでフィルタリングルールを設定することで、メッセージの選択受信ができます。フィルタリングを実現するには、TopicのEnableFilteringMessagesBeforePublishingをTrueに設定しておき、ルールを指定することで、メッセージングフィルタリングを有効にします。ルールを設定するには、RuleDescriptionオブジェクトをSubscriptionの作成時に引数として設定します。 RuleDescriptionのFilterプロパティにフィルタリング条件を指定することで、Subscriptionはフィルタリング条件を満たすメッセージのみ受信することができます。 フィルタリングの種類には以下のものがあります。

 

出典：MSDNライブラリ「Microsoft.ServiceBus.Messaging 名前空間」リファレンス

特定のタグ(文字列)を含むメッセージを受信したい場合、CorrelationFilterを指定します。 以下に、コードの例を掲載します。以下のコードは送信側のコード例です。

 

 

TopicClient TClient = TopicClient.CreateFromConnectionString(“接続文字列を指定”, “mytopic”);

NamespaceManager namespaceManager

　　= NamespaceManager.CreateFromConnectionString(“接続文字列を指定”);

TopicDescription topicDescription = new TopicDescription(“mytopic”);

//配信前のフィルタリングの有効化

topicDescription.EnableFilteringMessagesBeforePublishing

　　= (bool)chkEnableFilterBeforePublish.IsChecked;

//トピックの作成

namespaceManager.CreateTopic(topicDescription);

SubscriptionDescription subdesc

　　= new SubscriptionDescription(“mytopic”, “mysubscription”);

//ルール名を設定

rule.Name = ” Christmas”;

//ルールのフィルター条件を指定(CorrelationFilterを利用し、持つメッセージのみフィルタリング)

rule.Filter = new CorrelationFilter(“Christmas”);

//サブスクリプションの作成

namespaceManager.CreateSubscription(subdesc, rule);

BrokeredMessage message = new BrokeredMessage(body);

//メッセージにCorrelationIdを設定

message.CorrelationId = “Christmas”;

TClient.Send(message);

 

 

受信側は特別なコードを記述することなくメッセージがフィルタリングされます。

 

 

4.最後に

3回にわたって、QueueおよびTopic & Subscriptionの利用法をご紹介してきました。 ほんの一部の機能の紹介でしたが、紹介した機能以外にも様々なものがあります。 それらの機能についても、後日紹介していきたいと思います。