C#中通過LRU實(shí)現(xiàn)通用高效的超時(shí)連接探測
編寫網(wǎng)絡(luò)通訊都要面對(duì)一個(gè)問題,就是要把很久不存活的死連接清除,如果不這樣做那死連接最終會(huì)占用大量內(nèi)存影響服務(wù)運(yùn)作!在實(shí)現(xiàn)過程中一般都會(huì)使用ping,pong原理,通過ping,pong來更新連接的時(shí)效性,最后通過掃描連接列表來清除掉。雖然這種做法比較簡單,但很難抽取出通用性的封裝,掃描整個(gè)列表復(fù)雜度也比較高。以下講解如何通過LRU算法實(shí)現(xiàn)一個(gè)通用高效的探測超時(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ǔ)可控測對(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ī)則也是比較簡單,Update用于更新跟蹤對(duì)象,一般在處理接受ping或pong包后進(jìn)行調(diào)用;Detection方法是探測超出指定時(shí)間的對(duì)象,時(shí)間當(dāng)位是毫秒,如果存在有超時(shí)的對(duì)象則觸發(fā)Timeout事件;GetTime是獲取探測器已經(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)操作原理。
測試
既然功能已經(jīng)實(shí)現(xiàn),接下來就要對(duì)代碼進(jìn)行測試看運(yù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í)連接探測,希望對(duì)大家有所幫助,如果大家有任何疑問請(qǐng)給我留言,小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)我們網(wǎng)站的支持!
上一篇:C#使用委托的形式調(diào)用線程代碼實(shí)例
欄 目:C#教程
下一篇:C# winform程序?qū)崿F(xiàn)開機(jī)自啟動(dòng)并且識(shí)別是開機(jī)啟動(dòng)還是雙擊啟動(dòng)
本文標(biāo)題:C#中通過LRU實(shí)現(xiàn)通用高效的超時(shí)連接探測
本文地址:http://www.jygsgssxh.com/a1/C_jiaocheng/5016.html
您可能感興趣的文章
- 01-10C#通過反射獲取當(dāng)前工程中所有窗體并打開的方法
 - 01-10C#通過重寫Panel改變邊框顏色與寬度的方法
 - 01-10C#實(shí)現(xiàn)Winform中打開網(wǎng)頁頁面的方法
 - 01-10C#實(shí)現(xiàn)由四周向中心縮小的窗體退出特效
 - 01-10Extjs4如何處理后臺(tái)json數(shù)據(jù)中日期和時(shí)間
 - 01-10C#通過Semaphore類控制線程隊(duì)列的方法
 - 01-10C#中DataGridView常用操作實(shí)例小結(jié)
 - 01-10C#編程獲取資源文件中圖片的方法
 - 01-10asp.net中XML如何做增刪改查操作
 - 01-10C#利用反射技術(shù)實(shí)現(xiàn)去掉按鈕選中時(shí)的邊框效果
 


閱讀排行
本欄相關(guān)
- 01-10C#通過反射獲取當(dāng)前工程中所有窗體并
 - 01-10關(guān)于ASP網(wǎng)頁無法打開的解決方案
 - 01-10WinForm限制窗體不能移到屏幕外的方法
 - 01-10WinForm繪制圓角的方法
 - 01-10C#實(shí)現(xiàn)txt定位指定行完整實(shí)例
 - 01-10WinForm實(shí)現(xiàn)仿視頻播放器左下角滾動(dòng)新
 - 01-10C#停止線程的方法
 - 01-10C#實(shí)現(xiàn)清空回收站的方法
 - 01-10C#通過重寫Panel改變邊框顏色與寬度的
 - 01-10C#實(shí)現(xiàn)讀取注冊(cè)表監(jiān)控當(dāng)前操作系統(tǒng)已
 
隨機(jī)閱讀
- 04-02jquery與jsp,用jquery
 - 01-11ajax實(shí)現(xiàn)頁面的局部加載
 - 08-05織夢dedecms什么時(shí)候用欄目交叉功能?
 - 01-10C#中split用法實(shí)例總結(jié)
 - 01-11Mac OSX 打開原生自帶讀寫NTFS功能(圖文
 - 01-10使用C語言求解撲克牌的順子及n個(gè)骰子
 - 01-10delphi制作wav文件的方法
 - 08-05dedecms(織夢)副欄目數(shù)量限制代碼修改
 - 08-05DEDE織夢data目錄下的sessions文件夾有什
 - 01-10SublimeText編譯C開發(fā)環(huán)境設(shè)置
 


