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