时间戳

首页 > 解决方案 > 检测 WCF 中的断开连接

wcf - 检测 WCF 中的断开连接

问题描述

我们正在构建一个 WCF 服务器 (.NET 4.5)。它只会使用 net.pipe 传输。

当客户端关闭 PIPE 连接时，服务器会收到未处理的 CommunicationException，并终止。

Q1。如何处理 CommunicationException 以使服务器不会终止并继续为其他客户端提供服务？

Q2。在处理程序中，如何获取已中止会话的 SessionId？我需要这个来清理一些特定于会话的数据。

提前致谢！

合同

 [ServiceContract(CallbackContract = typeof(IContractCallback))]
 public interface IContractServer
{
[OperationContract(IsOneWay = true)]
void Connect(bool status);

[OperationContract(IsOneWay = false)]
void Disconnect(IContractServer _channelCallback);

[OperationContract(IsOneWay = true)]
void Play(bool status);
}

服务

[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single)]
public class Service : IContractServer
{
public List<IContractCallback> _channeList = new List<IContractCallback>();

public void Connect(bool status)
{
    IContractCallback a = OperationContext.Current.GetCallbackChannel<IContractCallback>();
    int call = 0;
    foreach (var callBack in _channeList)
    {
        if (callBack == a)
        {
            call++;
        }
    }

    if (call == 0)
    {
        _channeList.Add(a);
        a.ConnectCallback(true);
    }
    else
    {
        a.ConnectCallback(false);
    }
}

public void Disconnect(IContractServer _channelCallback)
{
    foreach (var contractCallback in _channeList)
    {
        if (contractCallback == _channelCallback)
        {
            _channeList.Remove(contractCallback);
        }
    }
}

public void Play(bool status)
{
    foreach (var contractCallback in _channeList)
    {
        contractCallback.PlayCallback(status);
    }
}
}

客户

using System.ComponentModel;
using System.ServiceModel;
using System.Windows;
using Host;

namespace VideoPlayer
{
 public partial class MainWindow : Window, IContractCallback
{
private IContractServer Proxy = null;
public MainWindow()
{
    InitializeComponent();
    InstanceContext context = new InstanceContext(this);
    DuplexChannelFactory<IContractServer> factory = new DuplexChannelFactory<IContractServer>(context, new NetNamedPipeBinding(), "net.pipe://localhost");
    Proxy = factory.CreateChannel();
    Proxy.Connect(true);
}

public void ConnectCallback(bool status)
{
    MessageBox.Show(status ? "connected" : "no connected");
}

public void PlayCallback(bool status)
{
    if (status)
    {
        MessageBox.Show("status true");
    }
    else
    {
        MessageBox.Show("status false");
    }
}


private void ButtonPlay(object sender, RoutedEventArgs e)
{
    Proxy.Play(true);
}


private void MainWindow_OnClosing(object sender, CancelEventArgs e)
{
    //хочу отправить сообщение о закрытии
    Proxy.Disconnect(Proxy);
}

标签： wcfpipeduplex

解决方案

我之前在我的双工服务中遇到过这个问题，当从服务器端引发事件时，如果客户端和服务器之间没有活动通道，则会发生异常，因此服务器下降到Fault状态并且所有下一个请求都不会得到响应，

出于这个原因，我得出这个结论来检查通道，如果它还活着，那么让回调方法被提出。

在服务方面，诀窍是 ↓</p> 

bool IsChannelAlive()
{
    Logging logging = new Logging(LogFile);
    try
    {
        if (((ICommunicationObject)_callbackChannel).State == CommunicationState.Opened)
        {
            logging.Log(LoggingMode.Prompt, "Channeld is still alive, can raise events...");
            return true;
        }
    }
    catch (Exception exp)
    {
        logging.Log(LoggingMode.Error, "IsChannelAlive()=> failed, EXP: {0}", exp);
    }
    logging.Log(LoggingMode.Warning, "Channeld is not alive so events won't raised...");
    return false;
}

在我的一个活动中，我像这样使用它：

void stran_OperationTimedOut(object sender, EventArgs e)
{ 
    if (IsChannelAlive())
        _callbackChannel.OnOperationTimedOut(); 
}

但是有一段时间我用这个技巧知道封闭通道做一些事情：

public ImportService()
{
    //Handle ContextClose to Audit all actions made in session
    OperationContext.Current.InstanceContext.Closed += delegate
    {
        //Here         
    };  
}

这是不可靠的。

我仍然IsAliveChannel()在我的服务中使用它。

希望这个答案可以解决您的问题或为您提供线索。

推荐阅读