C# TCPclient 服务器保持长连接的一种办法（变相的心跳包功能）

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace ALARMIP
{
public partial class Form1 : Form
{

//客户端定时向服务器发送查询指令

//服务器内置时钟计数，收到查询指令清零，计数超过则跳出循环，重新产生线程，线程内运行阻塞等待新的连接

//这样如果客户端连接一次就可以持续查询服务器设备，如果出现网络异常或者链接中断，只需客户端重新建立连接

//这个实例的好处是避免采用异步方法造成的非阻塞连接（要求客户端也用非阻塞方式，很多第三方工具无法调试）

byte[] pollingCommand = new byte[12] { 0x00, 0x00, 0x00, 0x00, 0x00, 0x06, 0x01, 0x04, 0x00, 0x01, 0x00, 0x30 };
// 客户端轮询指令,事务处理标识2字节，协议标识2字节，长度标识2字节，单元标识00，功能标识0A,起始处理器号，总处理器数
//00 00 00 00 00 06 01 04 00 01 00 30

byte[] infoTCP = new byte[57] {0x00, 0x00, 0x00, 0x00, 0x00, 0x33,0x61, 0x04, 0x30,

0x00,0x00,0x00, //0
0x00,0x00,0x00 , //pm1
0x00,0x00,0x00, //2
0x00,0x00,0x00, //3
0x00,0x00,0x00, //4
0x00,0x00,0x00, //5
0x00,0x00,0x00, //6
0x00,0x00,0x00, //7
0x00,0x00,0x00, //8
0x00,0x00,0x00, //9
0x00,0x00,0x00, //10
0x00,0x00,0x00, //11
0x00,0x00,0x00, //12
0x00,0x00,0x00, //13
0x00,0x00,0x00, //14
0x00,0x00,0x00 //15
};

bool isAlarmIPReady = true ; //服务器数据汇总是否完成，由时钟确定，默认500ms，接收到轮询指令且该值为1时答复，否则不做应答；应答后修改为0

bool isPolling=true ; //是否收到轮询指令
private bool isListening; //控制连接传输循环
private TcpListener listener;
private Thread aThread;
private bool isTcpConnected; //存在连接线程的标志，控制线程
private int pollingLost; //无客户端查询次数，网络断开也可用，定时器自动加1，通讯成功则清零

public Form1()
{
InitializeComponent();
}

private void Form1_Load(object sender, EventArgs e)
{

timer1.Start();

Thread.Sleep(500);

listener = new TcpListener(IPAddress.Any, 502); //新建socket，允许局域网所有终端访问
listener.Start();

aThread = new Thread(Queue1Thread); //连接线程
isTcpConnected = true; //连接状态标志

aThread.Start();

}

private void timer1_Tick(object sender, EventArgs e)
{
isAlarmIPReady = true; //每500ms标志一次

if(!isListening)
{
if (!isTcpConnected)
{
aThread = new Thread(Queue1Thread);
isTcpConnected = true; //立即标识启动连接，避免开多个线程

aThread.Start();
}

}
else
{
if(++pollingLost>10)
{
pollingLost = 10;// 简易的心跳包，根据
isListening = false; //让TCP线程跳出循环
}
}

}

private void Queue1Thread(object state)
{

TcpClient client = new TcpClient();

client = listener.AcceptTcpClient(); //阻塞，等待新的连接

isListening = true; //该值应该在子线程赋值，如果在主线程，有可能是上一个线程的值false，直接跳出下面的循环而断开连接
pollingLost = 0; //同上

while (isListening)
{
if (client != null)
{
NetworkStream stream = client.GetStream(); //这个对象有系统回收

byte[] buffer = new byte[256];
int ki = client.ReceiveBufferSize;

this.Invoke((EventHandler)(delegate
{

//this.Text = ki.ToString()+DateTime.Now .ToLongTimeString();

}));

stream.Read(buffer, 0, 256);
if (ki > 11)
{

isPolling = true;
for (int i = 2; i < 11; i++)
{
if (pollingCommand[i] != buffer[i])
{
isPolling = false; //对客户端请求验证，避免错码
}
}

if (isAlarmIPReady & isPolling)
{

isAlarmIPReady = false;
pollingLost = 0; //连接失败数清零

infoTCP[0] = buffer[0];
infoTCP[1] = buffer[1];
stream.Write(infoTCP, 0, 57);
// MessageBox.Show(infoTCP [5].ToString());
}

}

}
}

client.Close(); //加此处理，则5秒超时后，客户端不重连而发送查询后连接将关闭；如果不做处理，系统将自动回收，客户端不重连发送查询后连接显示保持但是实际上已经断开了连接
isTcpConnected = false;

}

}
}