4

MessageInspector と Web サービス間の情報の共有について質問があります。

AfterReceiveRequest と BeforeSendReply を "バインド" するために使用する識別子 (Guid) があります。それは正常に動作します。しかし、この識別子を Web サービスで使用されるメソッドでも使用できるようにしたいと考えています。これは、ログで問題を追跡する場合などに非常に便利です。

以下は、アイデアを説明するための小さなデモ例です。私の問題は、メソッド AfterReceiveRequest から戻りオブジェクトにアクセスできる解決策を見つけることです。「MagicStuff」と並んで。

namespace Demo.MessageInspector
{
    public class DemoMessageInspector : IDispatchMessageInspector
    {
        public object AfterReceiveRequest(ref Message request, IClientChannel channel, InstanceContext instanceContext)
        {
            Guid activityId = Guid.NewGuid();
            MyLog.Message("AfterReceiveRequest", activityId);
            return activityId;
        }

        public void BeforeSendReply(ref Message reply, object correlationState)
        {
            Guid activityId = (Guid)correlationState;
            MyLog.Message("BeforeSendReply", activityId);
        }
    }
}

namespace Demo.WebServices
{
    [ServiceBehavior]
    [MessageInterceptionServiceBehaviour]
    public class MyWebService : IMyWebService
    {
        public void MyWebServiceMethod()
        {
            Guid activityId = (Guid)MagicStuff; // <-- correlationState from AfterReceiveRequest

            bool success = DoSomthing();

            if (!success)
                MyLog.Message("Error happened in MyWebServiceMethod", activityId);
        }
    }
}

どんな種類の助けやヒントもいただければ幸いです。

4

1 に答える 1

5

OperationContext.IncomingMessageProperties プロパティを使用できます。シナリオでの使用法は次のとおりです。

using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.ServiceModel;
using System.ServiceModel.Channels;
using System.ServiceModel.Description;
using System.ServiceModel.Dispatcher;
using Demo.MessageInspector;
using Demo.Utilities;

namespace Demo.WebServices
{
    public class MyWebService : IMyWebService, IServiceBehavior
    {
        public void MyWebServiceMethod()
        {
            // get the activityId from the incoming message properties
            var activityIdProperty = OperationContext.Current.IncomingMessageProperties
                .FirstOrDefault(property => property.Key == Properties.ActivityId.ToString());

            // create an empty Guid
            Guid activityId = new Guid();
            if (activityIdProperty.Value != null)
            {
                // replace the empty Guid with the activityId
                activityId = (Guid)activityIdProperty.Value;
            }
            bool success = DoSomething();
            if (!success)
                MyLog.Message("Error happened in MyWebServiceMethod", activityId);
        }

        private bool DoSomething()
        {
            // TODO: implement
            return false;
        }

        public void AddBindingParameters(
          ServiceDescription serviceDescription,
          ServiceHostBase serviceHostBase,
          System.Collections.ObjectModel.Collection<ServiceEndpoint> endpoints,
          BindingParameterCollection bindingParameters
        )
        {
            return;
        }

        public void ApplyDispatchBehavior(ServiceDescription serviceDescription,
            ServiceHostBase serviceHostBase)
        {
            foreach (ChannelDispatcher chDisp in serviceHostBase.ChannelDispatchers)
            {
                foreach (EndpointDispatcher epDisp in chDisp.Endpoints)
                {
                    var messageInspector = new DemoMessageInspector();
                    epDisp.DispatchRuntime.MessageInspectors.Add(messageInspector);
                }
            }
        }

        public void Validate(ServiceDescription serviceDescription, 
            ServiceHostBase serviceHostBase)
        {
            // TODO: implement validation
            //throw new NotImplementedException();
        }
    }
}

namespace Demo.MessageInspector
{
    public class DemoMessageInspector : IDispatchMessageInspector
    {
        public object AfterReceiveRequest(ref Message request, 
            IClientChannel channel, InstanceContext instanceContext)
        {
            Guid activityId = Guid.NewGuid();

            // add the activityId to the incoming message properties
            OperationContext.Current.IncomingMessageProperties
                .Add(Properties.ActivityId.ToString(), activityId);

            MyLog.Message("AfterReceiveRequest", activityId);
            return activityId;
        }

        public void BeforeSendReply(ref Message reply, object correlationState)
        {
            Guid activityId = (Guid)correlationState;
            MyLog.Message("BeforeSendReply", activityId);
        }
    }
}

namespace Demo.Utilities
{
    public enum Properties
    {
        ActivityId
    }

    public class MyLog
    {
        internal static void Message(string p, Guid guid)
        {
            File.AppendAllText(@"C:\Temp\log.txt", 
                String.Format("{0} {1} {2}\r\n", DateTime.Now, p, guid));
        }
    }
}

[アップデート]

または、 CorrelationManager.ActivityId プロパティを使用できます。これを行うには、まず構成ファイル (クライアントとサーバーの両方) に以下を追加します。

<system.diagnostics>
  <sources>
    <source name="System.ServiceModel" propagateActivity="true">
      <listeners>
        <add name="ignored" type="System.Diagnostics.DefaultTraceListener" />
      </listeners>
    </source>
  </sources>
</system.diagnostics>

次に、Demo.Utilities.Helperクラスに次のメソッドを追加します。

namespace Demo.Utilities
{
    internal class Helper
    {
        internal static Guid GetCorrelationId()
        {
            var headerPosition = OperationContext.Current.IncomingMessageHeaders.FindHeader("ActivityId",
                "http://schemas.microsoft.com/2004/09/ServiceModel/Diagnostics");
            if (headerPosition > -1)
            {
                var activityIdHeader = OperationContext.Current.IncomingMessageHeaders
                    .GetReaderAtHeader(headerPosition);
                var activityIdAttribute = activityIdHeader.GetAttribute("CorrelationId");
                return Guid.Parse(activityIdAttribute);
            }
            else
            {
                return Guid.Empty;
            }
        }
    }
}

DemoMessageInspectorこれで、次のようなメソッドを で使用できます。

public object AfterReceiveRequest(ref Message request,
    IClientChannel channel, InstanceContext instanceContext)
{
    var correlationId = Helper.GetCorrelationId();
    MyLog.Message("AfterReceiveRequest\tCorrelationId", correlationId);
    // ...
}

サービスのメソッドで次のようにします。

public void MyWebServiceMethod()
{
    var correlationId = Helper.GetCorrelationId();
    MyLog.Message("MyWebServiceMethod\tCorrelationId", correlationId);

    // ...
}
于 2013-03-13T14:07:43.120 に答える