首页 / C# / C# Socket keeplive 心跳检测实例

C# Socket keeplive 心跳检测实例

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了C# Socket keeplive 心跳检测实例，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含5379字，纯文字阅读大概需要8分钟。

内容图文

Socket本身无法很好的捕获连接断开事件，或者说根本没这功能。总不能每次发生数据通讯时，通过异常来判断吧。

所以经过了各种测试及查询（这里还是要感谢国外的友人们，鄙视一下国人），总算找到一种相对稳定的方法。

该方法利用了tcp/ip协议本省的keep-alive规则。

keep-alive简单来说，就是tcp协议中制定的心跳检测，用来判断连接是否存活。默认是不启动的，需要进行设置。

serverFullAddr = new IPEndPoint(IPAddress.Any, portNo);//设置IP，端口
server = new TcpListener(serverFullAddr);
server.Start();
// 启用keep-alive
server.Server.IOControl(IOControlCode.KeepAliveValues, GetKeepAliveData(), null);
server.Server.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.KeepAlive, true);

上面是server端演示代码，用的是tcplistener，毕竟比较方便。而且用来和DTU通讯的时候，使用的NetworkStream，这个相对好用

client = server.AcceptTcpClient();
// 启用keep-alive
client.Client.IOControl(IOControlCode.KeepAliveValues, GetKeepAliveData(), null);
client.Client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.KeepAlive, true);

上面是客户端启用的设置。

按照查询到的理论，应该任意一方面设置了就可以，不过我这里都启用了，姑且算保险吧。

然后就是IOControl设置的数据了。

private byte[] GetKeepAliveData()
{
uint dummy = 0;
byte[] inOptionValues = new byte[Marshal.SizeOf(dummy) * 3];
BitConverter.GetBytes((uint)1).CopyTo(inOptionValues, 0);
BitConverter.GetBytes((uint)3000).CopyTo(inOptionValues, Marshal.SizeOf(dummy));//keep-alive间隔
BitConverter.GetBytes((uint)500).CopyTo(inOptionValues, Marshal.SizeOf(dummy) * 2);// 尝试间隔
return inOptionValues;
}

keep-alive如果使用windows默认，可能2个小时才会发送一次心跳，我这里检测设备在线，肯定不能这么长时间，我的读数频率都是以分钟作为单位的，出于各方面考虑
我这里设置的keep-alive每3秒发送一次。如果对方没有响应，每0.5秒后发送一次确认，如果连续3次没有回应，连接会自动变成TcpState.Established。

这里说一下，查询过程中发现很多人使用socket去poll来进行判断，在测试中，发现不好用，响应不及时，后来多方查找资料并测试，发现通过系统本身的连接来进行判断比较准确，方法如下：

/// <summary>
/// THIS FUNCTION WILL CHECK IF CLIENT IS STILL CONNECTED WITH SERVER.
/// </summary>
/// <returns>FALSE IF NOT CONNECTED ELSE TRUE</returns>
public bool isClientConnected(TcpClient ClientSocket)
{
IPGlobalProperties ipProperties = IPGlobalProperties.GetIPGlobalProperties();

TcpConnectionInformation[] tcpConnections = ipProperties.GetActiveTcpConnections();

foreach (TcpConnectionInformation c in tcpConnections)
{
TcpState stateOfConnection = c.State;

if (c.LocalEndPoint.Equals(ClientSocket.Client.LocalEndPoint) && c.RemoteEndPoint.Equals(ClientSocket.Client.RemoteEndPoint))
{
if (stateOfConnection == TcpState.Established)
{
return true;
}
else
{
return false;
}

}

}

return false;
}

这样解决办法就简单了。

单独写一个CheckAlive的线程进行检测，然后抛出事件并移除连接就ok。

public void StartCheckAlive()
{
Thread th = new Thread(new ThreadStart(CheckAlive));
th.IsBackground = true;
th.Start();
TCPLogger.Log("CheckAlive线程已启动");
}

private void CheckAlive()
{
Thread.Sleep(10000);
while(isListen)
{
try
{
lock (ClientList)
{
foreach (ClientItem item in ClientList)
{
//if (item.Client.Client.Poll(500, System.Net.Sockets.SelectMode.SelectRead) && (item.Client.Client.Available == 0))

if (!isClientConnected(item.Client))
{
removeQueue.Enqueue(item);
continue;
}
}
while (removeQueue.Count > 0)
{
ClientItem item = removeQueue.Dequeue();
clientList.Remove(item);
try
{
TCPLogger.Log("关闭客户端连接");
item.Client.Close();

}
catch (Exception ex)
{
TCPLogger.Log("关闭客户端连接", ex);
}
TCPLogger.Log("CheckAlive移除链接：" + item.RegCode);
if (OnClientRemoved != null)
OnClientRemoved(item.RegCode);
}
}

}catch(Exception e)
{
TCPLogger.Log("CheckAlive异常.", e);
}

Thread.Sleep(500);
}
}

内容总结

以上是互联网集市为您收集整理的C# Socket keeplive 心跳检测实例全部内容，希望文章能够帮你解决C# Socket keeplive 心跳检测实例所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/704350.html

来源：【匿名】

【上一篇】C# 压缩、解压缩【下一篇】assemblyinfo.csC#Assembly类访问程序集信息

更多 ►

【C# Socket keeplive 心跳检测实例】教程文章相关的互联网学习教程文章

C#利用反射,遍历获得一个类的所有属性名,以及该类的实例的所有属性的值【代码】

转自goldeneyezhang原文 C#利用反射,遍历获得一个类的所有属性名,以及该类的实例的所有属性的值 C#利用反射,遍历获得一个类的所有属性名,以及该类的实例的所有属性的值总结: 对应某个类的实例化的对象tc, 遍历获取所有属性(子成员)的方法(采用反射):Type t = tc.GetType();//获得该类的Type//再用Type.GetProperties获得PropertyInfo[],然后就可以用foreach 遍历了foreach (PropertyInfo pi in t.GetProperties） {object value1 =...

C#控制鼠标代码实例【代码】

1获得当前屏幕中鼠标的位置 int i = MousePosition.X;int j = MousePosition.Y; 这是control类中的方法。2移动鼠标首先引入dll [System.Runtime.InteropServices.DllImport("user32")] private static extern int mouse_event(int dwFlags, int dx, int dy, int cButtons, int dwExtraInfo); const int MOUSEEVENTF_MOVE = 0x0001; const int MOUSEEVENTF_LEFTDOWN = 0x0002; const in...

C# 页面抽奖实例 asp.net【代码】

<!DOCTYPE html><html xmlns="http://www.w3.org/1999/xhtml"> <head runat="server"><meta http-equiv="Content-Type" content="text/html; charset=utf-8" /><script src="Scripts/jquery-1.10.2.min.js"></script><title>LuckyDraw</title><style>/*reset css*/body {font-size: 0.8em;letter-spacing: 1px;font-family: "微软雅黑";line-height: 1.8em;}div, h2, p, ul, li {margin: 0;padding: 0;}h1 {font-size: 1em;font-we...

LZMA C# SDK 子线程压缩与解压缩 Unity3d实例

参考雨松的LZMA SDK使用方法：http://www.xuanyusong.com/archives/3095转自http://blog.csdn.net/huutu http://www.thisisgame.com.cn计划在项目中使用不压缩的Assetbundle ，所以需要对Assetbundle 进行手动压缩打包，因为之前有对十万个冷笑话的打包分析，所以这次坚定选择 LZMA压缩算法来压缩Assetbundle。转自http://blog.csdn.net/huutu http://www.thisisgame.com.cnNote：因为暂时不知道LZMA如何压缩与解压文件夹，所以目...

C#测量程序运行时间及cpu使用时间实例方法【代码】

privatevoid ShowRunTime(){TimeSpan ts1 = Process.GetCurrentProcess().TotalProcessorTime;Stopwatch stw = new Stopwatch();stw.Start();int Circles = 1000;for (int i = 0; i < Circles; ++i){}double Msecs = Process.GetCurrentProcess().TotalProcessorTime.Subtract(ts1).TotalMilliseconds;stw.Stop();Console.WriteLine(string.Format("循环次数:{0} CPU时间(毫秒)={1} 实际时间(毫秒)={2}", Circles, Msecs, stw.Elap...

C#中Predicate<T>与Func<T, bool>泛型委托的用法实例

本文以实例形式分析了C#中Predicate<T>与Func<T, bool>泛型委托的用法，分享给大家供大家参考之用。具体如下：先来看看下面的例子：12345678910111213141516staticvoidMain(string[] args) { List<string> l = newList<string>(); l.Add("a"); l.Add("b"); l.Add("s"); l.Add("t"); if(l.Exists(s => s.Equals("s"))) { stringstr = l.First(s => s.Equals("s")); Console.WriteLine(str); } elseConsole.WriteLine("Not found");...

Ubuntu中使用C++创建Socket实例（使用C#连接客户端测试）【代码】【图】

需求背景,目前需要学习C++, 并且在C++的基础下, 进行第三方的硬件做嵌入式开发, 需要用到C++开发子系统进行外部进行通信。目前在Ubuntu中进行测试C++搭建Socket服务端, 然后外部进行连接, 客户端以C#进行测试。第一步 > 创建C++的Socket服务端代码可以使用g++进行编译测试, 以下例子是使用vs code 进行编译以及调试。首先, 创建一个cpp的函数文件, 并且引用以下内容:#include<stdio.h> #include<stdlib.h> #include<string.h> #inc...

C#实现Web文件上传的两种方法实例代码

1. C＃实现Web文件的上传　　使用C#如何实现文件上传的功能呢?下面笔者简要介绍一下。　　首先,在你的Visual C# web project 中增加一个上传用的Web Form,为了要上传文件,需要在ToolBox中选择HTML类的File Field控件,将此控件加入到Web Form中,然而此时该控件还不是服务端控件,我们需要为它加上如下一段代码:<input id=PreviousFile1 type=file size=49 runat="server">，这样它就成为服务端控件了,如果需要同时上传数个文件时,我们...

阿里云-Redis-Help-连接实例-Redis客户端连接：C#客户端StackExchange.Redis【代码】【图】

ylbtech-阿里云-Redis-Help-连接实例-Redis客户端连接：C#客户端StackExchange.Redis 1.返回顶部1、C#客户端StackExchange.Redis操作步骤如下所示：下载并安装StackExchange.Redis。添加引用。 using StackExchange.Redis;初始化ConnectionMultiplexer。 ConnectionMultiplexer是StackExchange.Redis的核心，它被整个应用程序共享和重用，应该设置为单例，它的初始化如下： // redis configprivatestatic ConfigurationOptions co...

C# 根据对象类完整名称，创建对象实例【代码】

转自：http://blog.csdn.net/mm33211/article/details/8143890C# 根据对象类完整名称，创建对象实例 ///<summary>/// 根据指定的类全名，返回对象实例///</summary>///<param name="objFullName">对象完整名称（包名和类名），如：com.xxx.Test</param>publicobject createObjectInstance(string objFullName){//获取当前目录string currentDir = Assembly.GetExecutingAssembly().Location;currentDir = currentDir.Substring(0, ...

C# XML,XmlDocument简单操作实例【代码】

privatestaticstring _Store = LocalPathHelper.CurrentSolutionPath + "/data/bookstore.xml";1.添加节点///<summary>/// 向根节点中插入一个节点 ///</summary>publicstaticvoid AddOne() {XmlDocument xmlDoc = new XmlDocument();xmlDoc.Load(_Store);//1.查找booksotre节点XmlNode root = xmlDoc.SelectSingleNode("bookstore");//2.创建book 节点XmlElement book = xmlDoc.CreateElement("book");book.SetAttribute("genre",...

《C#并发编程经典实例》学习笔记-第一章并发编程概述

并发编程的术语并发同时做多件事情多线程并发的一种形式，它采用多个线程来执行程序。多线程是并发的一种形式，但不是唯一的形式。并行处理把正在执行的大量的任务分割成小块，分配给多个同时运行的线程。并行处理是多线程的一种，而多线程是并发的一种。异步编程并发的一种形式，它采用future模式或回调（callback）机制，以避免产生不必要的线程。一个 future（或 promise）类型代表一些即将完成的操作。在 .NET 中，新版...

C#中Windows Media Player控件使用实例|方法【代码】【图】

Windows Media Player控件Windows Media Player是一种媒体播放器，可以播放当前最流行的音频、视频文件和大多数混合型的多媒体文件。为了便于程序的开发，Visual Studio 2005集成开发环境提供了Windows Media Player控件，并且提供了相关的属性、方法，开发者根据提供的属性、方法完全可以实现Windows Media Player播放器的所有功能。在使用Windows Media Player控件进行程序开发前，必须将Windows Media Player控件添加到工具箱中...

阿里云消息队列的C#使用http接口发送消息实例【代码】

app.config<appSettings><clear/><add key="Ons_Topic" value="XXX_FinishOrder"/><add key="Ons_AccessKey" value="jmXXXXXBov"/><add key="Ons_SecretKey" value="VXXXXXjRD7pxYCpjtnJDDbsH"/><add key="Ons_ConsumerId" value="CID_xxxxxxxx"/><add key="Ons_ProducerID" value="PID_xxxxxxxxxxx"/></appSettings> program.csusing System; using System.Collections.Generic; using System.Configuration; using System.Linq; ...

c# 限制同时启动多个实例程序运行【代码】

using System; using System.Collections.Generic; using System.Text; using System.Diagnostics; using System.Reflection; using System.Runtime.InteropServices; using System.Windows.Forms;namespace WindowsFormsApplication4 {public class MultiRunChecker{public static bool hasMultiRun(){Process[] ps = Process.GetProcessesByName(Assembly.GetExecutingAssembly().GetName().Name);if (ps != null && ps.Leng...

首页 / C# / C# Socket keeplive 心跳检测实例

C# Socket keeplive 心跳检测实例

内容导读

内容图文

内容总结

内容备注

内容手机端

【C# Socket keeplive 心跳检测实例】教程文章相关的互联网学习教程文章

实例 - 相关标签

C# - 技术教程分类

C# - 最新教程

C# - 最热教程