WCF совместно использует экземпляр IClientMessageInspector для нескольких клиентов - PullRequest
3 голосов
/ 28 мая 2011

Я управляю общим файлом cookie авторизации при выполнении вызовов службы WCF с помощью этой методики, описанной в заголовке " Централизованное управление файлами cookie ", расположенном здесь: http://megakemp.com/2009/02/06/managing-shared-cookies-in-wcf/

Я настроил кастом IClientMessageInspector, IEndpointBehavior, BehaviorExtensionElement, работает. Мое поведение конечной точки добавляет инспектор сообщений следующим образом:

public class MyEndpointBehavior : IEndpointBehavior
{
    public void AddBindingParameters(ServiceEndpoint endpoint, System.ServiceModel.Channels.BindingParameterCollection bindingParameters)
    {
    }
    public void ApplyClientBehavior(ServiceEndpoint endpoint, System.ServiceModel.Dispatcher.ClientRuntime clientRuntime)
    {
        // yuck.. Wish I had an instance of MyClientMessageInspector
        // (which has the auth cookie already) so I could just inject that
        // instance here instead of creating a new instance
        clientRuntime.MessageInspectors.Add(new MyClientMessageInspector());
    }
    public void ApplyDispatchBehavior(ServiceEndpoint endpoint, System.ServiceModel.Dispatcher.EndpointDispatcher endpointDispatcher)
    {
    }
    public void Validate(ServiceEndpoint endpoint)
    {
    }
}

Все это работает безупречно , но это решение выходит из строя, если вы хотите поделиться файлами cookie с несколькими клиентами . Поскольку метод ApplyDispatchBehavior() создает новый экземпляр, любой другой клиент не получит этот экземпляр инспектора сообщений и, следовательно, запрос на авторизацию.

Итак, я подумал о попытке создать собственный конструктор, в который я мог бы вставить экземпляр, например, так:

MyEndpointBehavior(MyClientMessageInspector msgInspector) { ... }

Но WCF нужны конструкторы без параметров. Проползая через интернет, WCF имеет хуки, позволяющие внедрять зависимости, создавая IInstanceProvider, IServiceBehavior и т. Д. Но я не думаю, что это то, что я ищу здесь.

Может ли кто-нибудь помочь мне в правильном направлении?

Ответы [ 3 ]

5 голосов
/ 28 мая 2011

Вам нужно только расширить концепцию, чтобы сохранить куки-файл вне самого инспектора сообщений, чтобы все экземпляры инспектора сообщений совместно использовали одно и то же хранилище.

Способ бедняка, только для начала,было бы просто использовать статическое поле вместо поля экземпляра.Очевидно, что если у вас несколько потоков, вам потребуется обеспечить параллелизм при обновлении поля.Оттуда вы можете стать еще интереснее, если вы экстраполируете его на концепцию контейнера cookie, а затем просто убедитесь, что вы используете один и тот же контейнер для всех клиентов.Совместное использование контейнера можно получить, получив ChannelParameterCollection для клиентского канала и добавив к нему свойство, а затем ваше поведение ищет это свойство, проверяя сообщение и извлекая из него куки.Это будет выглядеть примерно так:

логика приложения

// Hold onto a static cookie container
public static CookieContainer MyCookieContainer;

// When instantiating the client add the cookie container to the channel parameters
MyClient client = new MyClient();
client.InnerChannel.GetProperty<ChannelParameterCollection>().Add(MyCookieContainer);

логика инспектора сообщений

public void BeforeSendMessage(ref Message, IClientChannel clientChannel)
{
    // Find the cookie container for the current channel
    CookieContainer cookieContainer = clientChannel.GetProperty<ChannelParameterCollection>().Select(p => p as CookieContainer).Where(cc => cc != null).First();

    // ... use the cookie container to set header on outgoing context ...
}
2 голосов
/ 28 мая 2011

Вы правы, IInstanceProvider не поможет в вашем случае - он используется только для предоставления сервисных экземпляров.Вам не нужен конструктор без параметров для вашего поведения.Вам нужен конструктор без параметров для элемента config, и этот класс может использовать некоторый класс внедрения зависимостей (см. Ниже) для создания соответствующего класса инспектора, необходимого для поведения.

namespace ConsoleApplication4
{
    public class MyEndpointBehavior : IEndpointBehavior
    {
        IClientMessageInspector inspector;
        public MyEndpointBehavior(IClientMessageInspector inspector)
        {
            this.inspector = inspector;
        }

        public void AddBindingParameters(ServiceEndpoint endpoint, BindingParameterCollection bindingParameters)
        {
        }

        public void ApplyClientBehavior(ServiceEndpoint endpoint, ClientRuntime clientRuntime)
        {
            clientRuntime.MessageInspectors.Add(this.inspector);
        }

        public void ApplyDispatchBehavior(ServiceEndpoint endpoint, EndpointDispatcher endpointDispatcher)
        {
        }

        public void Validate(ServiceEndpoint endpoint)
        {
        }
    }
    public class MyEndpointBehaviorElement : BehaviorExtensionElement
    {
        public override Type BehaviorType
        {
            get { return typeof(MyEndpointBehavior); }
        }

        protected override object CreateBehavior()
        {
            return new MyEndpointBehavior(ClientInspectorFactory.GetClientInspector());
        }
    }
    public class MyClientInspector : IClientMessageInspector
    {
        public MyClientInspector()
        {
        }

        public void AfterReceiveReply(ref Message reply, object correlationState)
        {
            Console.WriteLine("AfterReceiveReply");
        }

        public object BeforeSendRequest(ref Message request, IClientChannel channel)
        {
            Console.WriteLine("BeforeSendRequest");
            return null;
        }
    }
    public static class ClientInspectorFactory
    {
        static IClientMessageInspector instance;
        public static IClientMessageInspector GetClientInspector()
        {
            if (instance == null)
            {
                instance = new MyClientInspector();
            }

            return instance;
        }
    }
    [ServiceContract]
    public interface ITest
    {
        [OperationContract]
        int Add(int x, int y);
    }
    public class Service : ITest
    {
        public int Add(int x, int y) { return x + y; }
    }
    class Program
    {
        static void Main(string[] args)
        {
            ServiceHost host = new ServiceHost(typeof(Service));
            host.Open();
            Console.WriteLine("Host opened");

            ChannelFactory<ITest> factory = new ChannelFactory<ITest>("client1");
            ITest proxy = factory.CreateChannel();
            Console.WriteLine(proxy.Add(3, 4));
            ((IClientChannel)proxy).Close();
            factory.Close();

            factory = new ChannelFactory<ITest>("client2");
            proxy = factory.CreateChannel();
            Console.WriteLine(proxy.Add(5, 8));
            ((IClientChannel)proxy).Close();
            factory.Close();

            host.Close();
        }
    }
}
0 голосов
/ 29 мая 2011

Мне понравились ответы, предоставленные @carlosfigueira и @drew, но в итоге я придумал немного другой подход. Я решил настроить свой IEndpointBehavior ПРОГРАММНО, а не через config. Сделано все намного проще. Я изменил свое поведение конечной точки, чтобы сохранить свой инспектор сообщений клиента следующим образом:

public class MyEndpointBehavior : IEndpointBehavior
{
    private MyClientMessageInspector_myClientMessageInspector;

    public MyClientMessageInspector MyClientMessageInspector
    {
        get
        {
            if (_myClientMessageInspector == null)
            {
                _myClientMessageInspector = new MyClientMessageInspector();
            }
            return _myClientMessageInspector;
         }
    }
    public void AddBindingParameters(ServiceEndpoint endpoint, System.ServiceModel.Channels.BindingParameterCollection bindingParameters)
    {
    }
    public void ApplyClientBehavior(ServiceEndpoint endpoint, System.ServiceModel.Dispatcher.ClientRuntime clientRuntime)
    {
        clientRuntime.MessageInspectors.Add(MyClientMessageInspector);
    }
public void ApplyDispatchBehavior(ServiceEndpoint endpoint, System.ServiceModel.Dispatcher.EndpointDispatcher endpointDispatcher)
    {
    }
    public void Validate(ServiceEndpoint endpoint)
    {
    }
}

Тогда я просто поделился этим поведением между клиентами следующим образом:

var behavior = new MyEndpointBehavior();
client1.Endpoint.Behaviors.Add(behavior);
client2.Endpoint.Behaviors.Add(behavior);

Теперь оба клиента будут использовать один и тот же cookie-файл авторизации.

...