0

У меня сервер использует контракты обратного вызова для связи с клиентом. Но как мне на клиенте в обработчике функции этого контракта узнать прокси сервера для ответа ему? Можно ли как то? Я имею ввиду не просто хранить подключенный, а как то динамически узнать, т.к. я хочу сделать чтобы клиент мог быть подключен одновременно к нескольким серверам. Прокси серверов (объекты контрактов) хранятся в списке, но как мне из обработчика контракта обратного вызова узнать с какого сервера пришло сообщение, чтобы отправить ему ответ?

5
  • Неужели никто не знает?
    – Developer
    14 апр 2016 в 6:35
  • Все еще жду ответа!!! :(
    – Developer
    15 апр 2016 в 5:10
  • @Manushin Igor что именно не понятно? Я вроде старался объяснить насколько возможно понятно...
    – Developer
    18 апр 2016 в 11:52
  • извиняюсь, отправилось. Непонятен вопрос... WCF всегда держит горячее tcp соединение. Callback - это просто отправка данных по уже готовому каналу. Если используется proxy (socks, http, https), то во всех случаях всё будет работать без каких-то доработок. Если Вы подписались на кучу сервисов, и вопрос в том, как в методе разделять их, то могу привести пример кода.. 18 апр 2016 в 12:13
  • @Manushin Igor именно так. Последний вариант. Я хочу подписаться на несколько сервисов сразу. Их прокси-объекты хранятся в списке. Но я не знаю какой из них вызвал обработчик.
    – Developer
    18 апр 2016 в 12:16

2 ответа 2

0

Как разделить callback-методы сервисов:

using System;
using System.ServiceModel;
using System.ServiceModel.Channels;

namespace ConsoleApplication1
{
    public interface IMyContractCallback
    {
        [OperationContract]
        void OnCallback();
    }

    [ServiceContract(CallbackContract = typeof(IMyContractCallback))]
    public interface IMyContract
    {
        [OperationContract]
        void DoSomething();
    }

    [ServiceBehavior(ConcurrencyMode = ConcurrencyMode.Reentrant)]
    public class MyService : IMyContract
    {
        public void DoSomething()
        {
            Console.WriteLine("Hi from server!");
            var callback = OperationContext.Current.GetCallbackChannel<IMyContractCallback>();
            callback.OnCallback();
        }
    }

    public class MyContractClient : DuplexClientBase<IMyContract>
    {
        public MyContractClient(object callbackInstance, Binding binding, EndpointAddress remoteAddress)
            : base(callbackInstance, binding, remoteAddress)
        { }
    }

    public class MyCallbackClient : IMyContractCallback
    {
        private readonly string _clientIdentity;

        public MyCallbackClient(string clientIdentity)
        {
            _clientIdentity = clientIdentity;
        }

        public void OnCallback()
        {
            Console.WriteLine("Hi from client {0}!", _clientIdentity);
        }
    }
    internal static class Program
    {
        private static void Main()
        {
            var uri = new Uri("net.tcp://localhost");
            var binding = new NetTcpBinding();
            using (var host = new ServiceHost(typeof (MyService), uri))
            {
                host.AddServiceEndpoint(typeof(IMyContract), binding, "");
                host.Open();

                using (var client = CreateClient(binding, uri, "1"))
                {
                    using (var client2 = CreateClient(binding, uri, "2"))
                    {
                        var proxy2 = client2.ChannelFactory.CreateChannel();
                        proxy2.DoSomething();
                    }

                    var proxy = client.ChannelFactory.CreateChannel();
                    proxy.DoSomething();
                }
            }
        }

        private static MyContractClient CreateClient(NetTcpBinding binding, Uri uri, string clientIdentity)
        {
            var callback = new MyCallbackClient(clientIdentity);
            var client = new MyContractClient(callback, binding, new EndpointAddress(uri));

            return client;
        }
    }
}

Напечатается два ответа от сервиса. К сожалению, для каждого proxy необходим новый client factory (в моем решении).

17
  • 1
    Зачем вы, создав client, тут же берете у него фабрику и создаете канал?.. Client - это ведь уже канал, надо только реализовать в нем нужные методы (или позволить автогенератору кода сделать это). 18 апр 2016 в 12:38
  • 1
    А если хочется использовать фабрику напрямую - так и надо создавать сразу ее, а не клиента. 18 апр 2016 в 12:39
  • 1
    @DarkByte вот тут у него назначение: var callback = new MyCallbackClient(clientIdentity); 18 апр 2016 в 12:45
  • 1
    @DarkByte разумеется, вместо строки можно передать что угодно 18 апр 2016 в 12:45
  • 1
    @DarkByte ну так передавайте его в обработчик событий... 18 апр 2016 в 13:10
0

Вот вариант без создания лишних клиентов и с событиями:

Интерфейсы и сервис (для примера):

[ServiceContract(CallbackContract = typeof(ICallback))]
interface IService
{
    [OperationContract]
    void Hello();
}

interface ICallback
{
    [OperationContract]
    void CallbackHello();
}

[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single, ConcurrencyMode = ConcurrencyMode.Multiple)]
class Service : IService
{
    public async void Hello()
    {
        var callback = OperationContext.Current.GetCallbackChannel<ICallback>();
        await Task.Delay(1000);
        callback.CallbackHello();
    }
}

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

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

class ServiceClient : ClientBase<IService>, ICallback
{
    private readonly DuplexChannelFactory<IService> factory; // Общая для клиентов фабрика

    public EndpointAddress Address { get; private set; } // Информация для подключения (пример)

    public ServiceClient(DuplexChannelFactory<IService> factory, EndpointAddress address)
    {
        this.Address = address;
        this.factory = factory;
    }

    protected override IService CreateChannel()
    {
        return factory.CreateChannel(new InstanceContext(this), Address);
    }

    public new ChannelFactory<IService> ChannelFactory
    {
        get { return factory; }
    }

    // Пример запроса к сервису
    public void Hello()
    {
        base.Channel.Hello();
    }

    // Пример события обратного вызова
    // Как и просили - в нем указывается сам клиент первым параметром.
    public delegate void CallbackHelloDelegate(ServiceClient client);
    public event CallbackHelloDelegate CallbackHello;
    void ICallback.CallbackHello()
    {
        var h = CallbackHello;
        if (h != null) h(this);
    }
}

Использование:

    var factory = new DuplexChannelFactory<IService>(typeof(ServiceClient), "client");

    foreach (var i in new[] { 1, 2, 3 }) // Три клиента - для примера
    {
        var client = new ServiceClient(factory, new EndpointAddress("http://localhost/TestService")); // Адрес забит константой - но вам, наверное, надо его как-то вычислять
        client.CallbackHello += client_CallbackHello;
        client.Hello();

        // Положить клиент в список, я думаю, вы и сами сможете
    }

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.