C# socket心跳包测试

【实例截图】

【核心代码】

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

namespace WindowsFormsApplication3
{
    public partial class Form1 : Form
    {
        DateTime lastConnect = DateTime.Now;
        string strReceived = "";
        public bool IsConnected = false;
        public int MyLostTime = 0;
        Socket socketClient = null;
        public Form1()
        {
            InitializeComponent();
        }

        private void button1_Click(object sender, EventArgs e)
        {
            int port = new Random().Next(20000, 30000);
            //初始化服务器连接的IP及端口
            //调用BeginTheTimer（）与服务器建立连接
            BeginTheTimer();
        }

        private void button2_Click(object sender, EventArgs e)
        {
            if (socketClient != null)
                socketClient.Send(Encoding.ASCII.GetBytes(textBox2.Text.ToString()));
        }
        //启动记时器
        public void BeginTheTimer()
        {
            //建立连接
            try
            {
                socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                socketClient.Connect(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 9070));
                IsConnected = true;
            }
            catch { IsConnected = false; }
            Thread sendEcho = new Thread(new ThreadStart(socketSend));
            sendEcho.Start();
            sendEcho.IsBackground = true;
            Thread receiveThread = new Thread(new ThreadStart(socketReceive));
            receiveThread.Start();
            receiveThread.IsBackground = true;
        }

        //数据接收线程添加变量DateTime lastConnect=DateTime.now;
        //若接收数据为echo，则不作处理，若为其他数据，显示在richTextBox中；
        public void socketReceive()
        {
            while (true)
            {
                try
                {
                    byte[] buff = new byte[1024];
                    int count = socketClient.Receive(buff);
                    if (count > 0)
                    {
                        lastConnect = DateTime.Now;
                        //if (Encoding.UTF8.GetString(buff) != ">wstar:echo")
                        //{
                            strReceived = Encoding.ASCII.GetString(buff);
                            this.BeginInvoke(new MethodInvoker(delegate()
                            {
                                int selectStart = richTextBox1.Text.Length;
                                richTextBox1.AppendText(Environment.NewLine);
                                richTextBox1.AppendText(strReceived);
                                richTextBox1.Select(selectStart, richTextBox1.TextLength - 1);
                                richTextBox1.SelectionColor = Color.Blue;
                            }));
                        //}
                    }
                }
                catch (SocketException)
                {
                    IsConnected = false;
                    Thread.CurrentThread.Abort();
                }
            }
        }

        /// 每隔1秒发送一次数据，如果外发了10次请求暗号后仍不见服务器的回应，则认为客户端已经与服务器断开联系了
        public void socketSend()
        {
            int i = 0;
            while (true)
            {
                Thread.Sleep(1000);
                try
                {
                    socketClient.Send(Encoding.UTF8.GetBytes(">wistar:echo"));
                }
                catch (SocketException)
                {
                    Thread.CurrentThread.Abort();
                    //throw ex;
                }
                //标记我已经发送出去一次数据了
                this.MyLostTime  ;
                //如果外发了10次请求暗号后仍不见服务器的回应，则认为客户端已经与服务器断开联系了
                if (this.MyLostTime >= 10)
                {
                    TimeSpan t = DateTime.Now - lastConnect;
                    if (t.TotalSeconds > 10) IsConnected = true;
                    else IsConnected = false;
                    //每次确定后重置
                    this.MyLostTime = 0;
                }
            }
        }
    }
}