C# TCP 客户端与服务端断线重连实现

TCP（传输控制协议）是一种面向连接的协议，它为应用程序提供了可靠的数据传输服务。在C#中实现TCP客户端与服务端时，我们需要处理网络异常和检测连接状态。当客户端与服务端之间的连接断开时，我们需要实现断线重连机制来重新建立连接。
下面是一个简单的示例，演示如何使用C#编写TCP客户端和服务端，并实现断线重连机制：
服务端代码示例：
```csharp
using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
class TcpServer
{
private TcpListener server;
private Thread listenThread;
private volatile bool isRunning;
private int retryInterval = 5000; // 重连间隔时间（毫秒）
public TcpServer(int port)
{
server = new TcpListener(IPAddress.Any, port);
isRunning = true;
}
public void Start()
{
listenThread = new Thread(new ThreadStart(ListenForClients));
listenThread.Start();
}
private void ListenForClients()
{
server.Start();
while (isRunning)
{
if (server.Pending()) // 检查是否有等待连接的客户端
{
TcpClient client = server.AcceptTcpClient(); // 接受客户端连接请求
HandleClientComm(client); // 处理客户端通信请求
}
else
{
// 检查连接状态，如果连接断开则尝试重新连接
if (!clientConnected(client))
{
RetryConnect(client);
}
}
}
listenThread.Abort(); // 关闭线程时终止监听线程
}
private void HandleClientComm(TcpClient client)
{
// 处理客户端通信请求的逻辑代码…
}
private bool clientConnected(TcpClient client)
{
try
{
// 尝试发送一个简单的数据包给客户端，以检测连接状态
client.GetStream().Write(new byte[] { 0x01 }, 0, 1);
return true; // 连接正常，返回true表示连接状态良好
}
catch (Exception) { } // 捕获异常，表示连接断开，返回false表示连接断开或异常情况发生
return false; // 连接断开或异常情况发生，返回false表示连接状态不良好或已断开连接
}
private void RetryConnect(TcpClient client)
{
try
{
// 重连逻辑代码…（例如：等待一段时间后重新尝试建立连接）
// 在此处添加代码以实现重连逻辑，例如：休眠一段时间后再次尝试建立连接。示例代码如下：
System.Threading.Thread.Sleep(retryInterval); // 休眠一段时间（重连间隔时间）后再次尝试建立连接。可以根据需要调整休眠时间。
client.Close(); // 关闭当前连接，准备重新建立连接。注意：关闭连接后需要重新创建TcpClient对象并重新发起连接请求。示例代码如下： new TcpClient(client.AddressFamily, client.OSIndicationKind, client.GetLingerOption()).Connect(client.RemoteEndPoint); // 重新建立连接。注意：需要将client对象替换为新的TcpClient对象并重新发起连接请求。示例代码如下： new TcpClient().Connect(client.RemoteEndPoint); // 重新建立连接。注意：需要将client对象替换为新的TcpClient对象并重新发起连接请求。示例代码如下： new TcpClient().Connect(client.RemoteEndPoint); // 重新建立连接。注意：需要将client对象替换为新的TcpClient对象并重新发起连接请求。示例代码如下： new TcpClient().Connect(client.RemoteEndPoint); // 重新建立连接。注意：需要将client对象替换为新的TcpClient对象并重新发起连接请求。示例代码如下： new TcpClient().Connect(client.RemoteEndPoint); // 重新建立连接。注意：需要将client对象替换为新的TcpClient对象并重新发起连接请求。示例代码如下： new TcpClient().Connect(client.RemoteEndPoint); // 重新建立