C#心跳机制的服务器(完整)

控制台应用项目

心跳机制：心跳机制出现在tcp长连接中，客户端和服务器之间定时发送一种特殊的数据包，通知对方还在线，以确保tcp连接的可靠性。有可能tcp连接由于某些原因(例如网线被拔了，突然断电)导致客户端断了，但是服务器不知道客户端断了，服务器还保持与客户端连接的状态，所以不浪费资源，需要知道客户端非正常中断，服务器把断开客户端断开连接。需要加入心跳包机制

tcp心跳：需要心跳机制,tcp本身内置了keepalive心跳机制,但是这种内置心跳机制不足以满足所有网络的情况，所以有必要自己写心跳机制

网络情况满足keepalive心跳机制：1.tcp属于keepalive心跳机制 有些设备不会处理keepalive心跳包2.keepalive心跳机制只能说明连接是活的，应用实现心跳机制，可以保证连接是活的并且应用正常工作

心跳检测步骤：1.客户端每隔一个时间间隔发生一个探测包给服务器2.客户端发包时启动一个超时定时器3.服务器端接收到检测包，应该回应一个包4.如果客户机收到服务器的应答包，则说明服务器正常，删除超时定时器5.如果客户端的超时定时器超时，依然没有收到应答包，则说明服务器挂了

心跳机制服务器

Program类：

namespace _01_心跳机制服务器
{
    internal class Program
    {
        static Server server;
        static void Main(string[] args)
        {
             server = new Server(IPAddress.Any,3333);
            server.Start();
            server.有客户端连入的事件 += 有客户端连入服务器方法;// 绑定事件
            server.客户端断开事件 += f2;
            server.接受到消息的事件 += f3;
            Console.ReadKey();
        }
        public static void 有客户端连入服务器方法(object obj)
        {
            TcpClient t1 = obj as TcpClient;
            Console.WriteLine(t1.Client.RemoteEndPoint+"连接到服务器");
        }
        public static void f2(object obj)
        {
            Console.WriteLine(obj.ToString()+"断开连接");
        }
        public static void f3(TcpClient t1, byte[] b1)
        {
            string content = Encoding.UTF8.GetString(b1);
            server.Send(content);
        }
    }
}

创建Server类：

namespace _01_心跳机制服务器
{
    internal class Program
    {
        static Server server;
        static void Main(string[] args)
        {
            server = new Server(IPAddress.Any,3333);
            server.Start();
            server.有客户端连入的事件 += 有客户端连入服务器方法;
            server.客户端断开事件 += f2;
            server.接受到消息的事件 += f3;
            Console.ReadKey();
        }
        public static void 有客户端连入服务器方法(object obj)
        {
            TcpClient t1 = obj as TcpClient;
            Console.WriteLine(t1.Client.RemoteEndPoint+"连接到服务器");
        }
        public static void f2(object obj)
        {
            Console.WriteLine(obj.ToString()+"断开连接");
        }
        public static void f3(TcpClient t1, byte[] b1)
        {
            string content = Encoding.UTF8.GetString(b1);
            server.Send(content);
        }
    }
}