基本信息
源码名称:C# socket心跳包测试
源码大小:0.08M
文件格式:.rar
开发语言:C#
更新时间:2015-09-14
   友情提示:(无需注册或充值,赞助后即可获取资源下载链接)

     嘿,亲!知识可是无价之宝呢,但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下,绝对物超所值哦!如有下载和支付问题,请联系我们QQ(微信同号):813200300

本次赞助数额为: 2 元 
   源码介绍


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;
                }
            }
        }
    }
}