10

我正在处理客户端/服务器关系，该关系旨在在不确定的时间内来回推送数据。

我试图克服的问题是在客户端，因为我无法找到一种方法来检测断开连接。

我对其他人的解决方案进行了几次尝试，从捕获 IO 异常到在所有三个 SelectMode 上轮询套接字。我也尝试过使用轮询的组合，并检查套接字的“可用”字段。

// Something like this
Boolean IsConnected()
{
    try
    {
        bool part1 = this.Connection.Client.Poll(1000, SelectMode.SelectRead);
        bool part2 = (this.Connection.Client.Available == 0);

        if (part1 & part2)
        {
            // Never Occurs
            //connection is closed
            return false;
        }
        return true;
    }
    catch( IOException e )
    {
        // Never Occurs Either
    }
}

在服务器端，尝试向客户端写入“空”字符 (\0) 会强制 IO 异常，并且服务器可以检测到客户端已断开连接（非常容易 gig）。

在客户端，同样的操作不会产生异常。

// Something like this
Boolean IsConnected( )
{
    try
    {

        this.WriteHandle.WriteLine("\0");
        this.WriteHandle.Flush();
        return true;
    }
    catch( IOException e )
    {
        // Never occurs
        this.OnClosed("Yo socket sux");
        return false;
    }
}

我相信我在通过轮询检测断开连接时遇到的一个问题是，如果我的服务器自上次检查以来尚未将任何内容写回客户端，我很容易在 SelectRead 上遇到错误...确定要在这里做什么，我已经找到了每个选项来进行我能找到的检测，但对我来说没有任何事情是 100% 的，最终我的目标是检测服务器（或连接）故障，通知客户端，等待重新连接，等等。所以我相信你可以想象这是一个不可或缺的部分。

欣赏任何人的建议。提前谢谢。

编辑：任何查看这个问题的人都应该注意下面的答案，以及我对它的最终评论。我已经详细说明了我是如何克服这个问题的，但还没有发表“问答”风格的帖子。

4

1 回答 1

13

一种选择是使用 TCP 保持活动数据包。您可以通过调用来打开它们Socket.IOControl()。唯一烦人的一点是它需要一个字节数组作为输入，因此您必须将数据转换为字节数组才能传入。这是一个使用 10000 毫秒保持活动并重试 1000 毫秒的示例：

Socket socket; //Make a good socket before calling the rest of the code.
int size = sizeof(UInt32);
UInt32 on = 1;
UInt32 keepAliveInterval = 10000; //Send a packet once every 10 seconds.
UInt32 retryInterval = 1000; //If no response, resend every second.
byte[] inArray = new byte[size * 3];
Array.Copy(BitConverter.GetBytes(on), 0, inArray, 0, size);
Array.Copy(BitConverter.GetBytes(keepAliveInterval), 0, inArray, size, size);
Array.Copy(BitConverter.GetBytes(retryInterval), 0, inArray, size * 2, size);
socket.IOControl(IOControlCode.KeepAliveValues, inArray, null);

仅当您不发送其他数据时才发送保持活动数据包，因此每次发送数据时，都会重置 10000 毫秒计时器。

于 2012-08-06T18:47:16.727 回答