2

Azure Service Bus キューがあります。REST API を使用してメッセージをキューに投稿したいのですが、netMessagingBinding を使用して IIS がホストする WCF サービスを使用してメッセージを受信したいと考えています。

これを示すリソースへのリンクを持っている人はいますか? または、REST POST を使用してメッセージをキューにプッシュし、netMessagingBinding を使用して受信する方法のコード サンプルを提供できる人はいますか?

これを読んだ後、それは可能だと思います：

REST または .NET マネージ API を使用してサービスとの間でメッセージを送受信し、特定のシナリオでさまざまなプロトコルを使用してクライアントを組み合わせたり、一致させたりできます。たとえば、あるプロトコルを使用してメッセージをキューに送信し、別のプロトコルを使用してメッセージを消費できます。

http://msdn.microsoft.com/en-us/library/windowsazure/hh780717.aspx

netMessagingBinding を使用してメッセージをキューにプッシュし、netMessagingBinding を使用して受信できます。また、REST POST を使用してメッセージをキューにプッシュし、REST DELETE を使用してキューから受信および削除することもできます。メッセージをREST POSTしてnetMessagingBindingで受信することはできません

4

1 に答える 1

3

NetMessagingBindingは、常にBinaryMessageEncodingBindingElement+NetMessagingTransportBindingElementを使用してチャネルスタックを構築します。ServiceBusキュー/サブスクリプションのBrokeredMessagesがプレーンな古い[text]xmlの場合、BinaryMessageEncodingは機能しません。代わりに、TextMessageEncoderとNetMessagingTransportBindingElementでCustomBindingを使用するWCFを使用します。

つまり、TextMessageEncodingBindingElement（MessageVersion = None）とNetMessagingTransportBindingElementでCustomBindingを使用し、Action =” *”であることを確認し、ServiceBehaviorでAddressFilterMode=Anyを設定する必要があります。

NetMessagingTransportBindingElementを使用してプレーンな古いXMLメッセージを読み取る2つの方法を次に示します。

解決策＃1 ServiceContractでSystem.ServiceModel.Channels.Messageを使用し、Message.GetBody（）を呼び出します

namespace MessagingConsole
{
    static class Constants {
        public const string ContractNamespace = "http://contoso";
    }

    [DataContract(Namespace = Constants.ContractNamespace)]
    class Record
    {
        [DataMember]
        public string Id { get; set; }
    }

    [ServiceContract]
    interface ITestContract
    {
        [OperationContract(IsOneWay = true, Action="*")]
        void UpdateRecord(Message message);
    }

    [ServiceBehavior(
        AddressFilterMode = AddressFilterMode.Any)] // This is another way to avoid “The message with To ” cannot be processed at the receiver…”
    class TestService : ITestContract
    {
        [OperationBehavior]
        public void UpdateRecord(Message message)
        {
            Record r = message.GetBody<Record>();
            Console.WriteLine("UpdateRecord called! " + r.Id);
        }
    }

    class ServiceProgram
    {
        static void Main(string[] args)
        {
            string solution = "sb://SOMENS";
            string owner = "owner";
            string key = "XXXXXX=";
            string topicPath = "Topic2";
            string subscriptionName = "Sub0";
            TokenProvider tokenProvider = TokenProvider.CreateSharedSecretTokenProvider(owner, key);

            MessagingFactory factory = MessagingFactory.Create(solution, tokenProvider);
            TopicClient sender = factory.CreateTopicClient(topicPath);
            SubscriptionClient receiver = factory.CreateSubscriptionClient(topicPath, subscriptionName, ReceiveMode.ReceiveAndDelete);

            string interopPayload = "<Record xmlns='" + Constants.ContractNamespace + "'><Id>4</Id></Record>";
            BrokeredMessage interopMessage = new BrokeredMessage(new MemoryStream(Encoding.UTF8.GetBytes(interopPayload)), true);
            sender.Send(interopMessage);

            CustomBinding binding = new CustomBinding(
                new TextMessageEncodingBindingElement { MessageVersion = MessageVersion.None },
                new NetMessagingTransportBindingElement());
            ServiceHost serviceHost = new ServiceHost(typeof(TestService), new Uri(solution));
            ServiceEndpoint endpoint = serviceHost.AddServiceEndpoint(typeof(ITestContract), binding, topicPath + "/Subscriptions/" + subscriptionName);
            endpoint.Behaviors.Add(new TransportClientEndpointBehavior(tokenProvider));
            serviceHost.Open();
            Console.WriteLine("Service is running");
            Console.ReadLine();            
        }
    }
}

解決策＃2 MessageContractデータ型を定義して、予想されるSoapコントラクトが相互運用クライアントが送信しているものと一致するようにします。

namespace MessagingConsole
{
    static class Constants
    {
        public const string ContractNamespace = "http://contoso";
    }

    [DataContract(Namespace = Constants.ContractNamespace)]
    class Record
    {
        [DataMember]
        public string Id { get; set; }
    }

    [MessageContract(IsWrapped=false)]
    class RecordMessageContract
    {
        [MessageBodyMember(Namespace = Constants.ContractNamespace)]
        public Record Record { get; set; }
    }

    [ServiceContract]
    interface ITestContract
    {
        [OperationContract(IsOneWay = true, Action="*")]
        void UpdateRecord(RecordMessageContract recordMessageContract);
    }

    class ServiceProgram
    {
        static void Main(string[] args)
        {
            string solution = "sb://SOMENS";
            string owner = "owner";
            string key = "XXXXXXXXXXXXXX=";
            string topicPath = "Topic2";
            string subscriptionName = "Sub0";
            TokenProvider tokenProvider = TokenProvider.CreateSharedSecretTokenProvider(owner, key);

            MessagingFactory factory = MessagingFactory.Create(solution, tokenProvider);
            TopicClient sender = factory.CreateTopicClient(topicPath);
            SubscriptionClient receiver = factory.CreateSubscriptionClient(topicPath, subscriptionName, ReceiveMode.ReceiveAndDelete);

            string interopPayload = "<Record xmlns='" + Constants.ContractNamespace + "'><Id>5</Id></Record>";
            BrokeredMessage interopMessage = new BrokeredMessage(new MemoryStream(Encoding.UTF8.GetBytes(interopPayload)), true);
            sender.Send(interopMessage);

            CustomBinding binding = new CustomBinding(
                new TextMessageEncodingBindingElement { MessageVersion = MessageVersion.None },
                new NetMessagingTransportBindingElement());
            ServiceHost serviceHost = new ServiceHost(typeof(TestService), new Uri(solution));
            ServiceEndpoint endpoint = serviceHost.AddServiceEndpoint(typeof(ITestContract), binding, topicPath + "/Subscriptions/" + subscriptionName);
            endpoint.Behaviors.Add(new TransportClientEndpointBehavior(tokenProvider));
            serviceHost.Open();
            Console.WriteLine("Service is running");
            Console.ReadLine();
        }
    }

    [ServiceBehavior(
        AddressFilterMode = AddressFilterMode.Any
        )]
    class TestService : ITestContract
    {
        [OperationBehavior]
        public void UpdateRecord(RecordMessageContract recordMessageContract)
        {
            Record r = recordMessageContract.Record;
            Console.WriteLine("UpdateRecord called! " + r.Id);
        }
    }
}
于 2013-03-14T16:32:33.507 に答える