C#中通過LRU實(shí)現(xiàn)通用高效的超時(shí)連接探測(cè)
編寫網(wǎng)絡(luò)通訊都要面對(duì)一個(gè)問題,就是要把很久不存活的死連接清除,如果不這樣做那死連接最終會(huì)占用大量?jī)?nèi)存影響服務(wù)運(yùn)作!在實(shí)現(xiàn)過程中一般都會(huì)使用ping,pong原理,通過ping,pong來更新連接的時(shí)效性,最后通過掃描連接列表來清除掉。雖然這種做法比較簡(jiǎn)單,但很難抽取出通用性的封裝,掃描整個(gè)列表復(fù)雜度也比較高。以下講解如何通過LRU算法實(shí)現(xiàn)一個(gè)通用高效的探測(cè)超時(shí)連接功能類。
什么是LRU
在這里還是要大概介紹一下LRU,LRU算法的設(shè)計(jì)原則是:如果一個(gè)數(shù)據(jù)在最近一段時(shí)間沒有被訪問到,那么在將來它被訪問的可能性也很小.也就是說,當(dāng)限定的空間已存滿數(shù)據(jù)時(shí),應(yīng)當(dāng)把最久沒有被訪問到的數(shù)據(jù)淘汰.當(dāng)然在這里并不需要使用到自動(dòng)淘汰機(jī)制,只需要把未位到達(dá)超時(shí)的連接清除即可。
在C#中如何實(shí)現(xiàn)LRU
C#并不存在這樣的數(shù)據(jù)結(jié)構(gòu),不過有一個(gè)結(jié)構(gòu)很適合實(shí)現(xiàn)LRU,這個(gè)結(jié)構(gòu)就是LinkedList雙向鏈表,通過以下結(jié)構(gòu)圖就容易理解通過LinkedList實(shí)現(xiàn)LRU
通過LinkedList的功能我們可以把活越項(xiàng)先移出來,然后再把項(xiàng)移到頭部。在這里需要注意LinkedList的Remove方法,它有兩個(gè)重載版本,兩個(gè)版本的復(fù)雜度不一樣。一個(gè)是O(n)一個(gè)是O(1)所以使用上一定要注意,否則在數(shù)據(jù)多的情況下效率差別巨大(這些細(xì)節(jié)都可以通過源代碼來查看)!
代碼實(shí)現(xiàn)
前面已經(jīng)大概講述的原理,接下來要做的就是代碼實(shí)現(xiàn)了。第一步需要制訂一個(gè)基礎(chǔ)可控測(cè)對(duì)象規(guī)則接口,這樣就可以讓現(xiàn)有的已經(jīng)實(shí)現(xiàn)的功能實(shí)現(xiàn)它并可得到相關(guān)功能的支持。
public interface IDetector { double ActiveTime { get; set; } LinkedListNode<IDetector> DetectorNode { get; set; } }
接口定義了兩個(gè)屬性,一個(gè)是最近活越時(shí)間,另一個(gè)就是LinkedListNode<IDetector>
這個(gè)屬性比交關(guān)鍵,通過LinkedListNode<IDetector>
可以讓LinkedList在Remove時(shí)復(fù)雜度為O(1).接下來就要針對(duì)基于LRU算法處理超時(shí)制定一個(gè)應(yīng)用規(guī)則
public interface ILRUDetector { void Update(IDetector item); void Detection(int timeout); double GetTime(); Action<IList<IDetector>> Timeout { get; set; } }
規(guī)則也是比較簡(jiǎn)單,Update用于更新跟蹤對(duì)象,一般在處理接受ping或pong包后進(jìn)行調(diào)用;Detection方法是探測(cè)超出指定時(shí)間的對(duì)象,時(shí)間當(dāng)位是毫秒,如果存在有超時(shí)的對(duì)象則觸發(fā)Timeout事件;GetTime是獲取探測(cè)器已經(jīng)運(yùn)行的時(shí)間單位毫秒!規(guī)則定好了那接著要做的事實(shí)就是要實(shí)現(xiàn)它:
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; } }
代碼并不復(fù)雜,相信不用過多解釋也能看懂相關(guān)操作原理。
測(cè)試
既然功能已經(jīng)實(shí)現(xiàn),接下來就要對(duì)代碼進(jìn)行測(cè)試看運(yùn)行效果。測(cè)試代碼比較簡(jiǎn)單首先開啟一個(gè)Timer定時(shí)執(zhí)行Detection,另外開一個(gè)線程去調(diào)用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(); } }
運(yùn)行效果:
以上所述是小編給大家介紹的C#中通過LRU實(shí)現(xiàn)通用高效的超時(shí)連接探測(cè),希望對(duì)大家有所幫助,如果大家有任何疑問請(qǐng)給我留言,小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持!
相關(guān)文章
WPF設(shè)置窗體可以使用鼠標(biāo)拖動(dòng)大小的方法
這篇文章主要介紹了WPF設(shè)置窗體可以使用鼠標(biāo)拖動(dòng)大小的方法,涉及針對(duì)窗口的操作與設(shè)置技巧,具有很好的借鑒價(jià)值,需要的朋友可以參考下2014-11-11C#中緩存System.Web.Caching用法總結(jié)
本文詳細(xì)講解了C#中緩存System.Web.Caching的用法,文中通過示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2022-04-04C#用正則表達(dá)式Regex.Matches 方法檢查字符串中重復(fù)出現(xiàn)的詞
使用正則表達(dá)式用Regex類的Matches方法,可以檢查字符串中重復(fù)出現(xiàn)的詞,Regex.Matches方法在輸入字符串中搜索正則表達(dá)式的所有匹配項(xiàng)并返回所有匹配,本文給大家分享C#正則表達(dá)式檢查重復(fù)出現(xiàn)的詞,感興趣的朋友一起看看吧2024-02-02C#生成互不相同隨機(jī)數(shù)的實(shí)現(xiàn)方法
這篇文章主要介紹了C#生成互不相同隨機(jī)數(shù)的實(shí)現(xiàn)方法,文中詳細(xì)描述了C#生成互不相同隨機(jī)數(shù)的各個(gè)步驟及所用到的函數(shù),非常具有借鑒價(jià)值,需要的朋友可以參考下2014-09-09C#使用時(shí)序數(shù)據(jù)庫InfluxDB的教程詳解
InfluxDB是一個(gè)開源的時(shí)序數(shù)據(jù)庫,可以自動(dòng)處理時(shí)間序列數(shù)據(jù),這篇文章主要為大家詳細(xì)介紹了C#如何使用InfluxDB,感興趣的小伙伴可以跟隨小編一起了解下2023-11-11