C#中通过LRU实现通用高效的超时连接探测
编写网络通讯都要面对一个问题,就是要把很久不存活的死连接清除,如果不这样做那死连接最终会占用大量内存影响服务运作!在实现过程中一般都会使用ping,pong原理,通过ping,pong来更新连接的时效性,最后通过扫描连接列表来清除掉。虽然这种做法比较简单,但很难抽取出通用性的封装,扫描整个列表复杂度也比较高。以下讲解如何通过LRU算法实现一个通用高效的探测超时连接功能类。
什么是LRU
在这里还是要大概介绍一下LRU,LRU算法的设计原则是:如果一个数据在最近一段时间没有被访问到,那么在将来它被访问的可能性也很小.也就是说,当限定的空间已存满数据时,应当把最久没有被访问到的数据淘汰.当然在这里并不需要使用到自动淘汰机制,只需要把未位到达超时的连接清除即可。
在C#中如何实现LRU
C#并不存在这样的数据结构,不过有一个结构很适合实现LRU,这个结构就是LinkedList双向链表,通过以下结构图就容易理解通过LinkedList实现LRU
通过LinkedList的功能我们可以把活越项先移出来,然后再把项移到头部。在这里需要注意LinkedList的Remove方法,它有两个重载版本,两个版本的复杂度不一样。一个是O(n)一个是O(1)所以使用上一定要注意,否则在数据多的情况下效率差别巨大(这些细节都可以通过源代码来查看)!
代码实现
前面已经大概讲述的原理,接下来要做的就是代码实现了。第一步需要制订一个基础可控测对象规则接口,这样就可以让现有的已经实现的功能实现它并可得到相关功能的支持。
public interface IDetector { double ActiveTime { get; set; } LinkedListNode<IDetector> DetectorNode { get; set; } }
接口定义了两个属性,一个是最近活越时间,另一个就是LinkedListNode<IDetector>
这个属性比交关键,通过LinkedListNode<IDetector>
可以让LinkedList在Remove时复杂度为O(1).接下来就要针对基于LRU算法处理超时制定一个应用规则
public interface ILRUDetector { void Update(IDetector item); void Detection(int timeout); double GetTime(); Action<IList<IDetector>> Timeout { get; set; } }
规则也是比较简单,Update用于更新跟踪对象,一般在处理接受ping或pong包后进行调用;Detection方法是探测超出指定时间的对象,时间当位是毫秒,如果存在有超时的对象则触发Timeout事件;GetTime是获取探测器已经运行的时间单位毫秒!规则定好了那接着要做的事实就是要实现它:
class LRUDetector : ILRUDetector, IDisposable { public LRUDetector() { mTimeWatch = new System.Diagnostics.Stopwatch(); mTimeWatch.Restart(); } private Buffers.XSpinLock xSpinLock = new Buffers.XSpinLock(); private System.Diagnostics.Stopwatch mTimeWatch; private LinkedList<IDetector> mItems = new LinkedList<IDetector>(); public Action<IList<IDetector>> Timeout { get; set; } public void Detection(int timeout) { double time = GetTime(); List<IDetector> result = new List<IDetector>(); using (xSpinLock.Enter()) { LinkedListNode<IDetector> last = mItems.Last; while (last != null && (time - last.Value.ActiveTime) > timeout) { mItems.Remove(last); result.Add(last.Value); last.Value.DetectorNode = null; last = mItems.Last; } } if (Timeout != null && result.Count > 0) Timeout(result); } public void Update(IDetector item) { using (xSpinLock.Enter()) { if (item.DetectorNode == null) item.DetectorNode = new LinkedListNode<IDetector>(item); item.ActiveTime = GetTime(); if (item.DetectorNode.List == mItems) mItems.Remove(item.DetectorNode); mItems.AddFirst(item); } } public void Dispose() { mItems.Clear(); } public double GetTime() { return mTimeWatch.Elapsed.TotalMilliseconds; } }
代码并不复杂,相信不用过多解释也能看懂相关操作原理。
测试
既然功能已经实现,接下来就要对代码进行测试看运行效果。测试代码比较简单首先开启一个Timer定时执行Detection,另外开一个线程去调用Update方法
class Program { public class TestDetector : IDetector { public double ActiveTime { get; set; } public string Name { get; set; } public LinkedListNode<IDetector> DetectorNode { get; set; } } static void Main(string[] args) { LRUDetector lRUDetector = new LRUDetector(); lRUDetector.Timeout = (items) => { foreach (TestDetector item in items) Console.WriteLine($"{(item.Name)} timeout {lRUDetector.GetTime() - item.ActiveTime}ms"); }; System.Threading.Timer timer = null; timer = new System.Threading.Timer(o => { timer.Change(-1, -1); lRUDetector.Detection(5000); timer.Change(5000, 5000); }, null, 5000, 5000); System.Threading.ThreadPool.QueueUserWorkItem(o => { int i = 0; while (true) { System.Threading.Thread.Sleep(500); i++; TestDetector testDetector = new TestDetector(); testDetector.Name = "my name is " + i; lRUDetector.Update(testDetector); } }); Console.Read(); } }
运行效果:
以上所述是小编给大家介绍的C#中通过LRU实现通用高效的超时连接探测,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对猪先飞网站的支持!
相关文章
- 这篇文章主要介绍了解决Java处理HTTP请求超时的问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-03-29
- 这篇文章主要介绍了Nodejs回调加超时限制两种实现方法的相关资料,需要的朋友可以参考下...2017-06-15
- 1.前言 昨天碰到一道关于如何解决有序数组的连接问题,这是一个很常见的问题。但是这里要考虑到代码的效率问题,因为要连接的数组都是有序的,这是一个非常重要的前提条件。2.简单但效率不高的算法 我首先想到的是使用...2013-10-04
- 这篇文章主要介绍了C#连接到sql server2008数据库的实例代码,需要的朋友可以参考下...2020-06-25
- 这篇文章主要给大家介绍了关于C#连接Oracle数据库字符串(引入DLL)的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧...2020-06-25
- A789使用过程中,一般有两种途径满足上网的需求,一是通过手机卡上网,一是通过周边存在的无线网络上网。不论上网的速度、还是从需求的费用看,通过无线网络上网都具有绝对的...2016-09-20
vscode通过Remote SSH远程连接及离线配置的方法
这篇文章主要介绍了vscode通过Remote SSH远程连接及离线配置的方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-03-16- 这篇文章主要为大家详细介绍了MySQL远程连接不上的解决方法,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2017-01-26
- 这篇文章主要介绍了C#百万数据查询出现超时问题的解决方法,是非常实用的技巧,需要的朋友可以参考下...2020-06-25
- 这篇文章主要介绍了golang在GRPC中设置client的超时时间,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-04-27
- 这篇文章主要介绍了阿里云ssh远程连接短时间就会断掉的解决方案,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2020-07-11
- 可能有不少用户会发现自己的ecshop经常会使用关就超时了,这个问题解决办法有很多种,我们可以直接在ecsho中进行修改,具体方法如下 在includescls_session.php中修改...2016-11-25
- 今天教各位小伙伴怎么用Python连接oracle,文中附带非常详细的图文示例,对正在学习的小伙伴们很有帮助哟,需要的朋友可以参考下...2021-05-18
- 这篇文章主要介绍了IIS中保持HTTP连接的设置方法,需要的朋友可以参考下...2016-01-27
- 本文主要介绍了Django项目连接MongoDB的三种方法,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2021-09-27
- 随着adobe的FLEX和ROMTING的开源化又引起一场的RIA风波,我作为传统的WEB开发人员被其深深的吸引,作为web开发人员很关注flash如何和后台连接,在网上苦苦寻找终于...2016-11-25
- 这篇文章主要介绍了解决Redis连接无法正常释放的问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-01-15
- 这篇文章介绍了.net连接oracle的3种实现方法,有需要的朋友可以才可以一下...2021-09-22
- 下面小编就为大家分享一篇C# 字符串的连接实例讲解,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-06-25
Java使用IntelliJ IDEA连接MySQL的详细教程
这篇文章主要给大家介绍了关于Java使用IntelliJ IDEA连接MySQL的相关资料,文中通过图文介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-04-07