C# WCF 关闭通道并使用函数 Func

Question

这就是重点，我有一个 WCF 服务，它现在正在工作。所以我开始在客户端工作。当应用程序运行时，出现异常：超时。所以我开始阅读，有很多关于如何保持连接活动的示例，但是，我也发现最好的方法是创建通道，使用它并处置它。老实说，我喜欢这样。因此，现在阅读有关关闭频道的最佳方法的信息，有两个链接可能对任何需要它们的人有用：

1. 清理客户端，正确的方式

2.使用 Func

在第一个链接中，这是示例：

    IIdentityService _identitySvc;
...
if (_identitySvc != null)
 {
     ((IClientChannel)_identitySvc).Close();
     ((IDisposable)_identitySvc).Dispose();
     _identitySvc = null;
 }

因此，如果通道不为 null，则关闭、处置并分配 null。但我有一个小问题。在此示例中，通道有一个 .Close() 方法，但在我的例子中，智能感知未显示 Close() 方法。它只存在于工厂对象中。所以我相信我必须写它。但是，在具有合同或实现它的类的接口中？而且，这个方法应该做什么？？

现在，下一个链接，这是我以前从未尝试过的东西。 Func。读完目标后，这很有趣。它创建了一个函数，使用 lambda 表达式创建通道、使用它、关闭它并处置它。此示例像 Using() 语句一样实现该函数。这真的很好，而且是一个很好的改进。但是，我需要一点帮助，说实话，我无法理解该功能，因此，专家的一些解释将非常有用。这是功能：

TReturn UseService<TChannel, TReturn>(Func<TChannel, TReturn> code)
{
    var chanFactory = GetCachedFactory<TChannel>();
    TChannel channel = chanFactory.CreateChannel();
    bool error = true; 
    try {
        TReturn result = code(channel); 
        ((IClientChannel)channel).Close();
        error = false; 
        return result; 
    }
    finally {
        if (error) {
            ((IClientChannel)channel).Abort();
        }
    }
}

这就是使用方式：

int a = 1; 
int b = 2; 
int sum = UseService((ICalculator calc) => calc.Add(a, b)); 
Console.WriteLine(sum);

是的，我认为真的非常好，我想了解它以便在我的项目中使用它。

和往常一样，我希望这对很多人有帮助。

Answer 1

UseService 方法接受委托，该委托使用通道发送请求。委托有一个参数和一个返回值。您可以将对 WCF 服务的调用放在委托中。

在 UseService 中，它创建通道并将通道传递给委托，该委托应该由您提供。通话结束后，关闭通道。

Answer 2

代理对象不仅仅实现您的合同 - 它还实现 IClientChannel< /a> 允许控制代理生命周期

第一个示例中的代码不可靠 - 如果通道已经损坏（例如，服务在基于会话的交互中已关闭），它将泄漏。正如您在第二个版本中所看到的，如果出现错误，它会在代理上调用 Abort，这仍然会清理客户端

您也可以使用扩展方法来执行此操作，如下所示：

 enum OnError
 {
     Throw,
     DontThrow
 }

 static class ProxyExtensions
 {
     public static void CleanUp(this IClientChannel proxy, OnError errorBehavior)
     {
         try
         {
             proxy.Close();
         }
         catch
         {
             proxy.Abort();

             if (errorBehavior == OnError.Throw)
             {
                 throw;
             }
         }
     }
 }

但是，此方法的使用有点麻烦

 ((IClientChannel)proxy).CleanUp(OnError.DontThrow);

但是，如果您创建自己的代理接口来扩展您的合约和 IClientChannel，则可以使其更加优雅

interface IPingProxy : IPing, IClientChannel
{

}

Answer 3

为了回答 Jason 的回答中评论中留下的问题，GetCachedFactory 的一个简单示例可能如下所示。该示例通过在配置文件中查找“Contract”属性等于工厂要创建的服务的 ConfigurationName 的端点来查找要创建的端点。

ChannelFactory<T> GetCachedFactory<T>()
{
    var endPointName = EndPointNameLookUp<T>();
    return new ChannelFactory<T>(endPointName);
}

// Determines the name of the endpoint the factory will create by finding the endpoint in the config file which is the same as the type of the service the factory is to create
string EndPointNameLookUp<T>()
{
    var contractName = LookUpContractName<T>();
    foreach (ChannelEndpointElement serviceElement in ConfigFileEndPoints)
    {
        if (serviceElement.Contract == contractName) return serviceElement.Name;
    }
    return string.Empty;
}

// Retrieves the list of endpoints in the config file
ChannelEndpointElementCollection ConfigFileEndPoints
{
    get
    {
        return ServiceModelSectionGroup.GetSectionGroup(
            ConfigurationManager.OpenExeConfiguration(
                ConfigurationUserLevel.None)).Client.Endpoints;
    }
}

// Retrieves the ConfigurationName of the service being created by the factory
string LookUpContractName<T>()
{
    var attributeNamedArguments = typeof (T).GetCustomAttributesData()
        .Select(x => x.NamedArguments.SingleOrDefault(ConfigurationNameQuery));

    var contractName = attributeNamedArguments.Single(ConfigurationNameQuery).TypedValue.Value.ToString();
    return contractName;
}

Func<CustomAttributeNamedArgument, bool> ConfigurationNameQuery
{
    get { return x => x.MemberInfo != null && x.MemberInfo.Name == "ConfigurationName"; }
}

不过，更好的解决方案是让 IoC 容器为您管理客户端的创建。例如，使用 autofac 会出现以下情况。首先，您需要像这样注册服务：

var builder = new ContainerBuilder();

builder.Register(c => new ChannelFactory<ICalculator>("WSHttpBinding_ICalculator"))
  .SingleInstance();
builder.Register(c => c.Resolve<ChannelFactory<ICalculator>>().CreateChannel())
  .UseWcfSafeRelease();

container = builder.Build();

其中“WSHttpBinding_ICalculator”是配置文件中端点的名称。然后您可以像这样使用该服务：

using (var lifetime = container.BeginLifetimeScope())
{
    var calc = lifetime.Resolve<IContentService>();
    var sum = calc.Add(a, b);
    Console.WriteLine(sum);
}