Реализация службы async WCF

Ответ 1

Реализация асинхронных операций на стороне сервера довольно проста. Убедитесь, что имена методов совпадают, и они начинаются с начала и конца. GetImageAsyncResult - это обычная реализация IAsyncResult (множество примеров в Интернете).

    public class MapProvider : IMapProvider //implementation - belongs to server
    {
         public IAsyncResult BeginGetImage(int level, int x, int y, string[] layers, AsyncCallback callback, object state)
         {
              GetImageAsyncResult asyncResult = new GetImageAsyncResult(level, x, y, layers, callback, state);
              ThreadPool.QueueUserWorkItem(Callback, asyncResult);
              return asyncResult;
         }

         private void Callback(object state)
         {

              GetImageAsyncResult asyncResult = state as GetImageAsyncResult;
              asyncResult.Image = TileProvider.GetImage(asyncResult.Level, asyncResult.X, asyncResult.Y, asyncResult.Layers);
              asyncResult.Complete();
         }

         public System.Drawing.Bitmap EndGetImage(IAsyncResult result)
         {
              using (GetImageAsyncResult asyncResult = result as GetImageAsyncResult)
              {
                   asyncResult.AsyncWait.WaitOne();
                   return asyncResult.Image;
              }
         }
    }

    public class MapProviderProxy : ClientBase<IMapProvider>, IMapProvider, IDisposable
    {
         public IAsyncResult BeginGetImage(int level, int x, int y, string[] layers, AsyncCallback callback, object state)
         {
              return Channel.BeginGetImage(level, x, y, layers, callback, state);
         }

         public System.Drawing.Bitmap EndGetImage(IAsyncResult result)
         {
              return Channel.EndGetImage(result);
         }

         public void Dispose()
         {
              if (State == CommunicationState.Faulted)
              {
                   Abort();
              }
              else
              {
                   try
                   {
                        Close();
                   }
                   catch
                   {
                        Abort();
                   }
              }
         }
    }

Ответ 2

Когда вы выбираете "Сгенерировать асинхронные операции", как вы отметили, магия не задействована: Begin... запустит ваше общение, сервер начнет обрабатывать материал, но вы не сможете ничего использовать, пока не назовете End....

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

Вероятно, вы думаете, что это должно быть сложным, но это не так;)

EDIT: Приведем пример:

using (Service.SampleClient client = new Service.SampleClient())
{
    client.AddCompleted += 
        (object sender, Service.AddCompletedEventArgs e)
            {
                Console.WriteLine(e.Result); // 2
            };
    client.AddAsync(1, 1);

    // wait for async callback
    Console.ReadLine();
}

[ServiceContract]
public interface ISample
{
    [OperationContract]
    int Add(int a, int b);
}

Вы также можете явно запрограммировать свою службу для работы async, как описано здесь: Синхронные и асинхронные операции, используя [OperationContract(AsyncPattern=true)]

Ответ 3

Альтернативный способ выполнения асинхронных операций на стороне клиента без использования svcutil - это настроить интерфейс (ServiceContract) локально на стороне клиента, который реализует операцию async.

Контракт на стороне сервера:

[ServiceContract]
public interface IServerContract
{
    [OperationContract]
    string GetData(int value);
 }

Асинхронный контракт на стороне клиента

[ServiceContract(Namespace = "http://tempuri.org/", Name = "IServerContract")]
 public interface IClientContractAsync
 {
      [OperationContract] 
      Task<string> GetDataAsync(int value);
 }

Обратите внимание, что имя и пространство имен по умолчанию должны быть установлены в клиентском контракте, чтобы соответствовать пространству имен контрактных серверов. Итак, теперь у вас есть асинхронная операция (без новых новых потоков). Таким образом, вам не нужно выполнять какую-либо конкретную реализацию на стороне сервера. Конечно, это похоже на то, что делает SvcUtil, но SvcUtil генерирует много дополнительного кода, и иногда я нахожу svcutil, вызывающий проблемы, например. с повторным использованием классов.

Клиентский прокси

public class ClientProxy : ClientBase<IClientContractAsync>
{
    public IClientContractAsync ChannelOut
    {
        get
        {
            return Channel;
        }
    }
}

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

static void Main(string[] args)
{
    var client = new ClientProxy();
    client.Open();
    var asyncReadValue = client.ChannelOut.GetDataAsync(45).Result;
    Console.WriteLine(asyncReadValue);
    Console.ReadLine();
}

Класс сервера

public class ServerService : IServerContract
{
    public string GetData(int value)
    {
        return string.Format("You entered: {0}", value);
    }
}

Хост сервера

static void Main(string[] args)
{
    var server = new ServiceHost(typeof(ServerService));
    server.Open();
    Console.WriteLine("started");
    Console.ReadLine();
}