异步WCF调用与ChannelFactory和CreateChannel

本文关键字：CreateChannel ChannelFactory WCF 调用异步 | 更新日期: 2023-09-27 18:02:37

我在web服务器上托管的web应用程序调用托管在应用服务器上的WCF服务的项目上工作。WCF调用的代理由ChannelFactory创建，调用通过通道进行，示例:

(省略using block)

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

如果我理解得好，通过通道调用是异步的，web服务器上的线程在请求期间是空闲的，只是等待响应。

我想这样做异步调用:

var users = await channel.GetAllUsersAsync();

是否有一种方法如何使调用与ChannelFactory和渠道异步?我没有找到。我知道我可以通过svcutil/Add服务引用生成异步方法，但我不想这样做。我也不想通过添加异步方法来改变应用服务器(IUserService)上的服务接口。

是否有任何方法如何调用方法async与ChannelFactory?谢谢。

异步WCF调用与ChannelFactory和CreateChannel

您可以使用T4自动生成包含原始接口的异步版本方法的新接口，并在ChannelFactory中使用它，而无需更改服务器端接口。

我使用NRefactory来解析原始的并生成新的c#源代码和AssemblyReferences。在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 ();
    }
}

现在你可以把它放在工厂异步使用通道:

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

遗憾的是，没有。

您从svcutil获得的异步方法是基于您的接口在代理中生成的。在原始的WCF通道中没有这样的内容。

唯一的方法是修改服务引用，使其具有您不想要的本机异步调用，或者在通道周围创建您自己的包装器，并像生成的代理那样自己实现它们。

不幸的是，这是不可能的，并且有一个很好的理由。CreateChannel返回一个实现所提供接口的对象(在您的示例中是IUserService)。这个接口不是异步感知的，所以它不可能返回一个具有正确方法的对象。

有两个可能的解决方案:

svcutil