异步 CTP - 如何使用 async/await 调用 wcf 服务？

Question

如果我调用 WCF 服务方法，我会执行以下操作：

proxy.DoSomethingAsync();
proxy.DoSomethingAsyncCompleted += OnDoSomethingAsyncCompleted;

How can I do the same using the new async ctp? 我想我需要像 proxy.DoSomethingTaskAsync 或 proxy.DoSomethingAsync().ToTask() 之类的东西？ Web 服务调用需要返回一个 Task 才能使用 await 关键字，但是如何呢？

Answer 1

在 CTP 中，有一些工厂方法可以将常规 APM 函数（开始/结束）转换为与新的 async 关键字兼容的函数，例如：

Stream s = new FileStream("C:\test.txt", FileMode.CreateNew);
byte []buffer = new byte[100];
int numBytesRead = await Task<int>.Factory.FromAsync(s.BeginRead, s.EndRead, buffer, 0, buffer.Length, null);

因此，在您的情况下，您可以执行等效操作，然后您就可以像这样称呼它：

async proxy.DoSomethingTaskAsync()

请参阅此线程在 CTP 讨论组上了解更多信息

Answer 2

使用 async-await 的异步服务响应速度非常快，因为它可以交错许多客户端调用并并行执行它们 (2)。
尽管如此，服务可以在一个线程 (3) 上完全线程安全地运行，并且可以是单例服务 (1) 或由框架仅为会话或调用创建的服务对象。

实现服务时，请注意 ServiceBehaviourAttributes (1)...(3) ：

    [ServiceContract( Namespace="X", Name="TheContract" )]
    public interface IAsyncContractForClientAndService
    {
        [OperationContract]
        Task<TResponse> SendReceiveAsync( TRequest req );
    }



    [ServiceBehavior (InstanceContextMode = InstanceContextMode.Single, // (1)
                      // also works with InstanceContextMode.PerSession or PerCall
                      ConcurrencyMode     = ConcurrencyMode.Multiple,   // (2)
                      UseSynchronizationContext = true)]                // (3)

    public MyService : IAsyncContractForClientAndService
    {
        public async Task<TResponse> SendReceiveAsync( TRequest req )
        {
            DoSomethingSynchronous();
            await SomethingAsynchronous(); 
            // await lets other clients call the service here or at any await in
            // subfunctions. Calls from clients execute 'interleaved'.
            return new TResponse( ... );
        }
    }

要在一个线程上运行每个调用，在您 Open() ServiceHost 时必须存在 System.Threading.SynchronizationContext.Current != null 。
使用 SynchronizationContext，您无需关心锁。原子的、不可中断的代码段大致从一个等待延伸到下一个等待。
请注意，共享服务数据在每次等待时都处于一致状态，并注意来自一个客户端的连续请求可能不会按照发送的顺序进行响应。

在客户端，异步服务操作是可等待的：

   var response = await client.Channel.SendReceiveAsync( request );

不可能在操作契约中使用 out 或 ref 参数。所有响应数据必须通过返回值Task(T)传递。
我在 AsyncWcfLib 中使用此接口，它支持 基于 Actor 的编程模型。

Answer 3

异步 CTP 中有一个 WCF 示例，它将向您展示如何在 WCF 中使用异步/等待模型。

关于在WCF中支持该模型的计划，您可以查看以下帖子：

链接

希望这有帮助。

阿马德奥

Answer 4

正如 Matt 提到的，有一个 TaskFactory.FromAsync 方法允许您从 Begin/End 创建一个 Task代码>对。添加 WCF 引用时需要启用异步端点，然后您可以使用扩展方法自行包装它们。

正如 Amadeo 提到的，异步 CTP 中的 (C# WCF) Stock Quotes 目录下有一个示例。

另外，在该目录中，还有一个 TaskWsdlImportExtension 项目。添加对该 dll 的引用并修改您的 .config：

<configuration>
 <system.serviceModel>
  <client>
   <metadata>
    <wsdlImporters>
     <extension type="TaskWsdlImportExtension.TaskAsyncWsdlImportExtension, TaskWsdlImportExtension" />
    </wsdlImporters>
   </metadata>
  </client>
 </system.serviceModel>
</configuration>

然后您根本不必自己进行包装； TaskWsdlImportExtension 将为您完成此操作。

Answer 5

异步客户端调用同步服务是很常见的。
以下客户端和服务契约匹配（在幕后使用的一点魔法）：

    [ServiceContract( Namespace="X", Name="TheContract" )]
    public interface IClientContractAsynchronous
    {
        [OperationContract]
        Task<TResponse> SendReceiveAsync( TRequest req );
    }

    [ServiceContract( Namespace="X", Name="TheContract" )]
    public interface IServiceContractSynchronous
    {
        [OperationContract]
        TResponse SendReceive( TRequest req );
    }

客户端接口是直接可等待的：

   var response = await client.Channel.SendReceiveAsync( request );

不可能在经营合同。所有响应数据都必须在返回值中传递。这对我来说实际上是一个突破性的改变。
我在 AsyncWcfLib 中使用此接口，它支持 基于 Actor 的编程模型。

Answer 6

您正确地指出 async/await 是围绕返回 Task 和 Task 的方法构建的（有关 async/await 工作原理的详细说明，请参阅 此处）。以下是如何为 WCF 服务生成基于任务的方法：

1. Visual Studio 2012 RC 在“配置服务引用”对话框中具有一个附加复选框：“生成基于任务的操作”。虽然我没有在 中看到该选项MSDN，我希望它的存在是专门为了允许 WCF 调用上的无缝异步/等待。

2. 对于早期版本，请查看 这篇文章，描述了一个允许生成任务<>的扩展基于 WCF 的方法，甚至使用 CTP。