基本信息
源码名称:C# socket心跳包测试
源码大小:0.08M
文件格式:.rar
开发语言:C#
更新时间:2015-09-14
友情提示:(无需注册或充值,赞助后即可获取资源下载链接)
嘿,亲!知识可是无价之宝呢,但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下,绝对物超所值哦!如有下载和支付问题,请联系我们QQ(微信同号):813200300
本次赞助数额为: 2 元×
微信扫码支付:2 元
×
请留下您的邮箱,我们将在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; } } } } }