與ChannelFactory和CreateChannel的異步WCF調用

Question

我負責託管在Web服務器上的Web應用程序調用託管在應用服務器上的WCF服務的項目。代理對WCF呼叫通過的ChannelFactory創建和呼叫經由信道，例如由：如果我的理解以及調用經由信道是異步和線程在web服務器上

（使用塊省略）

var factory = new ChannelFactory<IUserService>(endpointConfigurationName); 
var channel = factory.CreateChannel(); 

var users = channel.GetAllUsers(); 

是在請求期間閒置並等待響應。

我想使異步調用像這樣：

var users = await channel.GetAllUsersAsync(); 

有沒有辦法如何使的ChannelFactory和通道異步調用？我沒有找到任何。我知道我可以通過svcutil/Add service reference生成異步方法，但我不想那樣做。另外，我不想通過添加異步方法來更改應用程序服務器（IUserService）上的服務接口。

有什麼辦法如何與ChannelFactory調用異步方法？謝謝。

Answer 1

不幸的是，沒有。

您從svcutil獲得的異步方法是基於您的接口在代理中生成的。原始的WCF頻道沒有這樣的東西。

唯一的方法是將服務引用改爲擁有您不想要的本機異步調用，或者創建您自己的封裝器並自己像生成的代理一樣實施它們。

Answer 2

不幸的是，這是不可能的，並有一個很好的理由。 CreateChannel返回實現提供的接口的對象（在您的示例中爲IUserService）。這個接口不是異步感知的，所以它不可能用正確的方法返回一個對象。

有兩種可能的解決方案：

1. 創建您自己的代理，能夠調用WCF服務。這意味着你需要編寫自己的代理（或者讓svcutil爲你做）。
2. 確保IUserService是一個返回任務的異步接口。這在WCF 4.5及更高版本中受支持。這是我經常使用的。主要的缺點是它使你的服務有點複雜，你需要調用異步方法（這也可能被認爲是一種優勢）。

Answer 3

您可以自動生成一個包含使用T4從原來的接口中的方法異步版本的新界面和ChannelFactorywithout changing interface on server side使用它。

我用NRefactory解析原始和產生新的C＃源代碼和AssemblyReferences.tt在T4模板中使用的NuGet包：

<#@ template debug="false" hostspecific="true" language="C#" #> 
<#@ include file="AssemblyReferences.tt" #> 
<#@ assembly name="System.Core" #> 
<#@ import namespace="System.Linq" #> 
<#@ import namespace="ICSharpCode.NRefactory.CSharp" #> 
<#@ output extension=".cs"#> 
<# 
var file = System.IO.File.ReadAllText(this.Host.ResolvePath("IUserService.cs")); 
if(!file.Contains("using System.Threading.Tasks;")) 
{ #> 
using System.Threading.Tasks; 
<# } #> 
<# 
CSharpParser parser = new CSharpParser(); 
var syntaxTree = parser.Parse(file); 


foreach (var namespaceDeclaration in syntaxTree.Descendants.OfType<NamespaceDeclaration>()) 
{ 
    namespaceDeclaration.Name += ".Client"; 
} 


foreach (var methodDeclaration in syntaxTree.Descendants.OfType<MethodDeclaration>()) 
{ 
    if (methodDeclaration.Name.Contains("Async")) 
     continue; 

    MethodDeclaration asyncMethod = methodDeclaration.Clone() as MethodDeclaration; 
    asyncMethod.Name += "Async"; 

    if (asyncMethod.ReturnType.ToString() == "void") 
     asyncMethod.ReturnType = new SimpleType("Task"); 
    else 
     asyncMethod.ReturnType = new SimpleType("Task", typeArguments: asyncMethod.ReturnType.Clone()); 

    methodDeclaration.Parent.AddChild(asyncMethod, Roles.TypeMemberRole); 
} 

#> 
<#=syntaxTree.ToString()#>​ 

你通過接口文件名模板：

using System.Collections.Generic; 
using System.ServiceModel; 

namespace MyProject 
{ 
    [ServiceContract] 
    interface IUserService 
    { 
     [OperationContract] 
     List<User> GetAllUsers(); 
    } 
} 

要獲取新的：

using System.Threading.Tasks; 
using System.Collections.Generic; 
using System.ServiceModel; 

namespace MyProject.Client 
{ 
    [ServiceContract] 
    interface IUserService 
    { 
     [OperationContract] 
     List<User> GetAllUsers(); 

     [OperationContract] 
     Task<List<User>> GetAllUsersAsync(); 
    } 
} 

現在你可以把它n工廠使用渠道異步：

var factory = new ChannelFactory<MyProject.Client.IUserService>("*"); 
var channel = factory.CreateChannel(); 
var users = await channel.GetAllUsersAsync();