如何检测客户端与我的服务器断开连接？
我在我的 AcceptCallBack 方法中有以下代码
static Socket handler = null;
public static void AcceptCallback(IAsyncResult ar)
{
//Accept incoming connection
Socket listener = (Socket)ar.AsyncState;
handler = listener.EndAccept(ar);
}
由于没有可用的事件来信号socket何时失去连接，因此您将不得不以对您可接受的频率对其进行轮询。
使用这个扩展方法，您可以拥有一个可靠的方法来检测socket是否已经断开连接。
static class SocketExtensions
{
public static bool IsConnected(this Socket socket)
{
try
{
return !(socket.Poll(1, SelectMode.SelectRead) && socket.Available == 0);
}
catch (SocketException) { return false; }
}
}
socket.Available 返回0并且在调用 socket.Poll 之前刚好接收到一个数据包，则 Poll 将返回true并且方法将返回 false，尽管套接字实际上仍然处于正常状态。 - vgru有人提到了TCP套接字的keepAlive功能。以下是对其进行了很好的描述:
http://tldp.org/HOWTO/TCP-Keepalive-HOWTO/overview.html
我是这样使用它的:在套接字连接后，我调用这个函数来设置keepAlive。 keepAliveTime参数指定在没有活动的情况下，直到发送第一个keep-alive数据包的超时时间（以毫秒为单位）。keepAliveInterval参数指定如果没有收到确认，连续发送keep-alive数据包之间的时间间隔（以毫秒为单位）。
void SetKeepAlive(bool on, uint keepAliveTime, uint keepAliveInterval)
{
int size = Marshal.SizeOf(new uint());
var inOptionValues = new byte[size * 3];
BitConverter.GetBytes((uint)(on ? 1 : 0)).CopyTo(inOptionValues, 0);
BitConverter.GetBytes((uint)keepAliveTime).CopyTo(inOptionValues, size);
BitConverter.GetBytes((uint)keepAliveInterval).CopyTo(inOptionValues, size * 2);
socket.IOControl(IOControlCode.KeepAliveValues, inOptionValues, null);
}
我也在使用异步阅读：
socket.BeginReceive(packet.dataBuffer, 0, 128,
SocketFlags.None, new AsyncCallback(OnDataReceived), packet);
在回调函数中，捕获了超时引发的SocketException，当套接字在保持活动数据包后没有收到ACK信号时会出现该异常。
public void OnDataReceived(IAsyncResult asyn)
{
try
{
SocketPacket theSockId = (SocketPacket)asyn.AsyncState;
int iRx = socket.EndReceive(asyn);
}
catch (SocketException ex)
{
SocketExceptionCaught(ex);
}
}
这样，我就能够安全地检测TCP客户端和服务器之间的断开连接。
将心跳机制实现到您的系统中可能是一种解决方案。这仅在客户端和服务器都在您的控制下时才可能实现。您可以使用一个DateTime对象来跟踪从套接字接收到最后一组字节的时间，并假设在一定时间间隔内没有响应的套接字已丢失。这只有在您实现了心跳/自定义保持活动功能时才有效。
我发现另一个解决方法非常有用！
如果您使用异步方法从网络套接字读取数据（我的意思是使用BeginReceive - EndReceive方法），每当连接终止时，就会出现以下情况之一：要么发送了一条没有数据的消息（您可以通过Socket.Available查看 - 即使触发了BeginReceive，其值也将为零），要么在此调用中Socket.Connected的值变为false（然后不要尝试使用EndReceive）。
我发布了我使用的函数，我认为您可以更好地理解我的意思：
private void OnRecieve(IAsyncResult parameter)
{
Socket sock = (Socket)parameter.AsyncState;
if(!sock.Connected || sock.Available == 0)
{
// Connection is terminated, either by force or willingly
return;
}
sock.EndReceive(parameter);
sock.BeginReceive(..., ... , ... , ..., new AsyncCallback(OnRecieve), sock);
// To handle further commands sent by client.
// "..." zones might change in your code.
}
//open or receive a server socket - TODO your code here
socket = new Socket(....);
//enable the keep alive so we can detect closure
socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.KeepAlive, true);
//create a thread that checks every 5 seconds if the socket is still connected. TODO add your thread starting code
void MonitorSocketsForClosureWorker() {
DateTime nextCheckTime = DateTime.Now.AddSeconds(5);
while (!exitSystem) {
if (nextCheckTime < DateTime.Now) {
try {
if (socket!=null) {
if(socket.Poll(5000, SelectMode.SelectRead) && socket.Available == 0) {
//socket not connected, close it if it's still running
socket.Close();
socket = null;
} else {
//socket still connected
}
}
} catch {
socket.Close();
} finally {
nextCheckTime = DateTime.Now.AddSeconds(5);
}
}
Thread.Sleep(1000);
}
}
bool IsConnected(Socket socket)
{
try
{
if (socket == null) return false;
return !((socket.Poll(5000, SelectMode.SelectRead) && socket.Available == 0) || !socket.Connected);
}
catch (SocketException)
{
return false;
}
//the above code is short exp to :
/* try
{
bool state1 = socket.Poll(5000, SelectMode.SelectRead);
bool state2 = (socket.Available == 0);
if ((state1 && state2) || !socket.Connected)
return false;
else
return true;
}
catch (SocketException)
{
return false;
}
*/
}
// This is how you can determine whether a socket is still connected.
bool IsConnected(Socket client)
{
bool blockingState = client.Blocking; //save socket blocking state.
bool isConnected = true;
try
{
byte [] tmp = new byte[1];
client.Blocking = false;
client.Send(tmp, 0, 0); //make a nonblocking, zero-byte Send call (dummy)
//Console.WriteLine("Connected!");
}
catch (SocketException e)
{
// 10035 == WSAEWOULDBLOCK
if (e.NativeErrorCode.Equals(10035))
{
//Console.WriteLine("Still Connected, but the Send would block");
}
else
{
//Console.WriteLine("Disconnected: error code {0}!", e.NativeErrorCode);
isConnected = false;
}
}
finally
{
client.Blocking = blockingState;
}
//Console.WriteLine("Connected: {0}", client.Connected);
return isConnected ;
}
//以下是来自微软文档的评论*
socket.Connected 属性获取 Socket 的连接状态，该状态是最后一次 I/O 操作的状态。当它返回 false 时，Socket 要么从未连接过，要么已经断开连接。Connected 不是线程安全的；当 Socket 从另一个线程断开连接时，它可能会在操作中止后返回 true。Connected 属性的值反映了最近操作的连接状态。在接受的答案中，mbargiel和mycelo的评论得到了扩展，以下内容可与服务器端的非阻塞套接字一起使用，以通知客户端是否已关闭。
这种方法不会受到影响接受的答案中Poll方法所遇到的竞争条件的影响。
// Determines whether the remote end has called Shutdown
public bool HasRemoteEndShutDown
{
get
{
try
{
int bytesRead = socket.Receive(new byte[1], SocketFlags.Peek);
if (bytesRead == 0)
return true;
}
catch
{
// For a non-blocking socket, a SocketException with
// code 10035 (WSAEWOULDBLOCK) indicates no data available.
}
return false;
}
}
Socket.Receive方法会立即返回零。来自Socket.Receive documentation:
第二点解释了需要try-catch的原因。如果远程主机使用Shutdown方法关闭Socket连接，并且所有可用数据都已接收，则Receive方法将立即完成并返回零字节。
如果您处于非阻塞模式，并且协议堆栈缓冲区中没有可用数据，则Receive方法将立即完成并引发SocketException。
SocketFlags.Peek标志会使任何接收到的数据保持不变，以便使用单独的接收机制进行读取。SocketException）。这里的示例代码 http://msdn.microsoft.com/en-us/library/system.net.sockets.socket.connected.aspx 展示了如何在不发送数据的情况下确定Socket是否仍处于连接状态。
如果您在服务器程序中调用了Socket.BeginReceive()，然后客户端“优雅”地关闭了连接，则会调用接收回调函数，并且EndReceive()将返回0字节。这些0字节意味着客户端“可能”已经断开连接。然后，您可以使用MSDN示例代码中展示的技术来确定连接是否已关闭。