[發明專利]實現持久化數據隊列的方法

有效

• 申請號: 200910078355.1
• 申請日: 2009-02-26
• 公開（公告）號: CN101510838A
• 公開（公告）日: 2009-08-19
• 發明（設計）人: 曹東;彭偉;傅樂民
• 申請（專利權）人: 北京北緯點易信息技術有限公司
• 主分類號: H04L12/54
• 分類號: H04L12/54;G06F17/30
• 代理公司: 北京萬慧達知識產權代理有限公司
• 代理人: 葛 強;楊 穎

技術領域

本發明涉及持久化數據隊列的方法，尤其是指一種在通信系統消息傳遞中 采用磁盤文件實現持久化數據隊列的方法。

背景技術

在通信系統中，有大量需要傳遞的消息，而這些被傳遞的信息有些是需要 持久的保存下來，消息持久性對于可靠消息傳遞來說應該是一種比較好的方法， 有了消息持久化，即使發送者和接受者不是同時在線或者消息中心在發送者發 送消息后關機了，在消息中心重新啟動后仍然可以將消息發送出去。目前持久 化消息隊列大多采用數據庫持久化消息，也就是將欲保存的消息隊列存儲在數 據庫或文件中，而這種消息持久性的原理很簡單，就是在發送者將消息發送出 去后，消息中心首先將消息存儲到本地數據文件、內存數據庫或者遠程數據庫 等，然后試圖將消息發送給接收者，發送成功則將消息從存儲中刪除，失敗則 繼續嘗試。消息中心啟動以后首先要檢查制定的存儲位置，如果有未發送成功 的消息，則需要把消息發送出去。

對數據庫持久化來說，需要搭建數據庫，而搭建的數據庫本身是需要開銷 的，對于一個輕量級的應用，要專門為消息持久化搭建數據庫，付出的開銷太 大，另外，數據庫存儲數據本身是不具備先進先出特點的，因此在操作時會導 致效率較低。因此采用現有的持久化消息隊列的方式，盡管功能比較完善，但 是對待大量的消息數據而言，需要的開銷很大，并且效率很低，在處理速度要 求較高的應用中則會很難滿足該應用的需求。

發明內容

本發明目的在于提出實現持久化數據隊列的方法，尤其是指一種采用輕量 級的、基于磁盤文件的、先進先出、端到端的數據隊列來實現的方法。

本發明所述的方法可用于通信系統的消息傳遞，也可直接用于需要持久化 消息的數據轉發以及流量控制中。

本發明的方法在于提供一種實現持久化數據隊列的方法，包括以下步驟：

若指定的磁盤路徑內有控制文件，直接讀取控制文件信息；

若所述指定的磁盤路徑內沒有控制文件時，按照設定的格式創建所述控制文 件信息，并將所述控制文件信息寫入新創建的控制文件中；

根據所述控制文件信息載入先進先出數據隊列；

通過控制模塊管理磁盤路徑中的文件；

其中根據所述控制文件信息載入所述先進先出數據隊列是，根據所述控制文 件信息中描述的隊列頭尾信息，載入所述先進先出數據隊列。

優選地，通過所述控制模塊管理所述的磁盤路徑中的數據文件具體為：

所述控制文件通過所述控制模塊讀取或修改或刪除所述磁盤中的數據文件； 以及

所述控制文件通過所述控制模塊將數據文件寫入所述磁盤中；

其中所述的控制模塊包括GetData、PutData、IsFull、IsEmpty、GetCount的 方法。

優選地，所述控制文件將欲持久化的數據寫入磁盤包括以下步驟：

采用IsFull方式判斷數據文件是否為滿來確定該數據的寫入位置。

優選地，采用IsFull方式時采用GetData用來從隊列頭獲取數據，PutData用 來將數據寫入隊列尾。

優選地，在采用IsEmpty的方式來提供隊列是否空狀態，GetCount用來獲取 隊列當前的數據單元數。

優選地，所述數據隊列的讀寫操作首先在內存中進行，在PutData操作時將 新添加的數據寫入所述磁盤。

本發明是采用文件對數據隊列進行持久化，本發明的方案中在進行數據持 久化的過程中，所基于的磁盤文件分為兩種類型：控制文件和數據文件，所述 控制文件用來對隊列的頭尾進行控制，數據文件用來保存數據單元。

本發明所述的方法是一個基于磁盤文件的輕量級的持久化數據隊列實現方 法，與現有技術相比沒有過多的管理功能，僅僅實現一個先進先出的點對點的 持久化隊列，并不需要額外的設備和軟件的支持，可直接應用于需要持久化先 進先出隊列的應用中，本發明的結構和算法簡單，占用資源小，速度快，可以 被直接嵌入各種應用中，傳輸不同類型的數據，在進程內的隊列應用中，采用 該輕量級的解決方案，較現有技術開銷小，運行速度快，效率高。

附圖說明

圖1是本發明所述的控制文件的數據結構說明；

圖2是本發明所述的數據文件的數據結構說明；

圖3是本發明所述的文件描述區結構說明；