c# - 在使用回调关闭连接时收到 WCF 异常

Question

我正在使用 netNamedPipeBinding 执行从 Windows 应用程序到 Windows 服务的进程间 WCF 通信。

现在我的应用程序在所有其他帐户中运行良好(在与我公平分享的 WCF 异常作斗争之后，任何使用过 WCF 的人都会知道......)但这个错误被证明是非常有弹性的。

描绘一下我的场景:我的 windows 服务可以在任何给定时间通过在 windows 应用程序中按下一个按钮来排队做一些工作，然后它通过 netNamedPipeBinding 进行对话，这是一个支持回调(双向通信)的绑定(bind)，如果您不熟悉并发起执行此工作的请求(在本例中为文件上传过程)，它还会每隔几秒抛出回调(事件)，范围从文件进度到传输速度等回到 Windows 应用程序，因此有一些相当紧密的客户端-服务器集成；这就是我将 Windows 服务中运行的进度接收回我的 Windows 应用程序的方式。

现在，一切都很好，除了我每次过早关闭应用程序时都会收到一个令人讨厌的异常(这是一个完全有效的场景)之外，WCF 大神们现在对我比较满意。虽然传输正在进行中，并且回调正在大量触发，但我收到此错误:

System.ServiceModel.ProtocolException:
  The channel received an unexpected input message with Action 
  'http://tempuri.org/ITransferServiceContract/TransferSpeedChangedCallback' 
  while closing. You should only close your channel when you are not expecting 
  any more input messages.

现在我明白了那个错误，但不幸的是我不能保证在再也没有收到任何输入消息后关闭我的 channel ，因为用户可能随时关闭应用程序因此工作仍将在 windows 服务的后台继续(有点像病毒扫描程序的工作方式)。用户应该能够在不受干扰的情况下随心所欲地启动和关闭 win 管理工具应用程序。

现在错误，我在执行我的 Unsubscribe() 调用后立即收到，这是终止应用程序之前的倒数第二个调用，我认为这是断开 WCF 客户端的首选方法。取消订阅在关闭连接之前所做的只是从本地存储在 win 服务 wcf 服务上的数组中删除客户端 id(因为这是 win 服务和 windows 应用程序共享的实例，因为 win 服务可以在以下位置执行工作单独安排的事件)并且在我执行客户端 id 数组删除之后，我希望(感觉)应该是完全断开连接。

这样做的结果是，除了接收到异常之外，我的应用程序挂起，UI 完全锁定，进度条和一切都在中途，所有迹象都表明存在竞争条件或 WCF 死锁 [叹息]，但是我现在非常精通线程，我认为这是一个相对孤立的情况，按原样阅读异常，我不认为这本身是一个“线程”问题，因为它更多地说明了早期断开连接的问题使我所有的线程陷入困惑，可能导致锁定。

我在客户端 上的Unsubscribe() 方法如下所示:

    public void Unsubscribe()
    {
        try
        {
            // Close existing connections
            if (channel != null &&
                channel.State == CommunicationState.Opened)
            {
                proxy.Unsubscribe();
            }
        }
        catch (Exception)
        {
            // This is where we receive the 'System.ServiceModel.ProtocolException'.
        }
        finally
        {
            Dispose();
        }
    }

还有我的 Dispose() 方法，它应该执行干净的断开连接:

    public void Dispose()
    {
        // Dispose object
        if (channel != null)
        {
            try
            {
                // Close existing connections
                Close();
                // Attempt dispose object
                ((IDisposable)channel).Dispose();
            }
            catch (CommunicationException)
            {
                channel.Abort();
            }
            catch (TimeoutException)
            {
                channel.Abort();
            }
            catch (Exception)
            {
                channel.Abort();
                throw;
            }
        }
    }

和 WCF 服务 Subscription() 对应的和类属性(供引用)在 Windows 服务 server 上(这里没有什么棘手的，我的异常发生在客户端):

    [ServiceBehavior(InstanceContextMode = InstanceContextMode.Single, 
    ConcurrencyMode = ConcurrencyMode.Multiple)] 
    public class TransferService : LoggableBase, ITransferServiceContract
    {
        public void Unsubscribe()
        {
            if (clients.ContainsKey(clientName))
            {
                lock (syncObj)
                {
                    clients.Remove(clientName);
                }
            }

#if DEBUG
            Console.WriteLine(" + {0} disconnected.", clientName);
#endif
        }
        ...
    }

接口(interface):

[ServiceContract(
    CallbackContract = typeof(ITransferServiceCallbackContract), 
    SessionMode = SessionMode.Required)]
public interface ITransferServiceContract
{
    [OperationContract(IsInitiating = true)]
    bool Subscribe();

    [OperationContract(IsOneWay = true)]
    void Unsubscribe();
    ...
}

回调合约的接口(interface)，它没有做任何令人兴奋的事情，只是通过委托(delegate)等调用事件。我包含它的原因是为了向您展示我的属性。我确实通过包含 UseSynchronizationContext = false 来缓解一组死锁:

[CallbackBehavior(UseSynchronizationContext = false, 
ConcurrencyMode = ConcurrencyMode.Multiple)]
public class TransferServiceCallback : ITransferServiceCallbackContract
{ ... }

真的希望有人能帮助我!非常感谢 =:)

Answer 1

天哪，我发现了问题。

该异常与底层应用程序挂起无关，这只是一个您可以安全捕获的预防性异常。

你不会相信，我在这个错误上断断续续地花了大约 6 个小时，结果是 channel.Close() 锁定等待挂起的 WCF 请求完成(这在传输完成之前永远不会完成!这违背了目的!)

我只是一行一行地使用强力断点，我的问题是如果我太慢了......它永远不会挂起，因为不知何故 channel 可以关闭(甚至在传输完成之前)所以我必须按 F5 断点，然后快速前进以捕获挂起，这就是它结束的那条线。我现在只需将超时值应用于 Close() 操作并使用 TimeoutException 捕获它，然后如果 channel 无法及时关闭则强制中止 channel !

查看修复代码:

private void Close()
{
    if (channel != null &&
        channel.State == CommunicationState.Opened)
    {
        // If cannot cleanly close down the app in 3 seconds,
        // channel is locked due to channel heavily in use
        // through callbacks or the like.
        // Throw TimeoutException
        channel.Close(new TimeSpan(0, 0, 0, 3));
    }
}

public void Dispose()
{
    // Dispose object
    if (channel != null)
    {
        try
        {
            // Close existing connections
            // *****************************
            // This is the close operation where we perform 
            //the channel close and timeout check and catch the exception.
            Close();

            // Attempt dispose object
            ((IDisposable)channel).Dispose();
        }
        catch (CommunicationException)
        {
            channel.Abort();
        }
        catch (TimeoutException)
        {
            channel.Abort();
        }
        catch (Exception)
        {
            channel.Abort();
            throw;
        }
    }
}

我很高兴终于解决了这个错误!现在，无论当前 WCF 服务状态如何，我的应用程序都会在 3 秒超时后正常关闭，我希望我能帮助发现自己遇到类似问题的其他人。

格雷厄姆