[發明專利]處理異步消息隊列的方法、系統和異步SOCKET

無效

• 申請號: 200710079396.3
• 申請日: 2007-02-16
• 公開（公告）號: CN101247319A
• 公開（公告）日: 2008-08-20
• 發明（設計）人: 陳霞;倪輝;肖颯;莊順萬
• 申請（專利權）人: 華為技術有限公司
• 主分類號: H04L12/56
• 分類號: H04L12/56;H04L29/06
• 代理公司: 北京集佳知識產權代理有限公司
• 代理人: 逯長明

1.?一種處理異步消息隊列的方法，其特征在于，包括步驟：

A、異步SOCKET將接收到的底層數據放入接收緩存，判斷異步消息隊列中是否有未讀取的異步讀消息，如果異步消息隊列中沒有未讀取的異步讀消息，則向所述異步消息隊列中寫入一異步讀消息，執行步驟B，如果異步消息隊列中有未讀取的異步讀消息，則執行步驟B；

B、上層協議讀取異步消息隊列中的異步讀消息后，從異步SOCKET接收緩存中讀取底層數據。

2.?根據權利要求1所述的方法，其特征在于，所述判斷異步消息隊列中是否有未讀取的異步讀消息的方法為：判斷一合并標志計數器的計數是否為一預設值，若為所述預設值則異步消息隊列中沒有未讀取的異步讀消息；否則，異步消息隊列中有未讀取的異步讀消息；

判斷異步消息隊列中是否有未讀取的異步讀消息之后將所述合并標志計數器的計數值加一或減一。

3.?根據權利要求2所述的方法，其特征在于，所述步驟B中上層協議讀取異步SOCKET接收緩存中的底層數據后所述合并標志計數器將其計數重置為所述預設值。

4.?根據權利要求1所述的方法，其特征在于，所述步驟B包括：

上層協議設置一個內存空間申請緩存；

上層協議讀取所述異步讀消息后，根據上層協議數據緩存的長度從異步SOCKET接收緩存中讀取一次底層數據；

上層協議根據所述異步SOCKET接收緩存中剩余數據長度，向所述內存空間申請緩存申請一段與所述剩余數據長度相等的擴展數據緩存；

上層協議應用所述擴展數據緩存讀盡所述異步SOCKET接收緩存中的剩余底層數據。

5.?根據權利要求1所述的方法，其特征在于，若所述步驟B中上層協議不能一次讀盡異步SOCKET接收緩存中的底層數據，所述方法還包括：

C、異步SOCKET向所述異步消息隊列中自激性寫入一異步讀消息；

D、返回步驟B，直至上層協議將所述異步SOCKET接收緩存中的底層數據讀盡。

6.?根據權利要求5所述的方法，其特征在于，所述上層協議為數據流協議，所述步驟C包括：

上層協議讀取異步SOCKET接收緩存中的底層數據后，該異步SOCKET判斷接收緩存中的底層數據是否被讀盡；若是，

則所述異步SOCKET向異步消息隊列中寫入一異步讀消息；否則，結束異步讀消息的上報。

7.?根據權利要求5所述的方法，其特征在于，所述上層協議為數據報協議，所述步驟C包括：

上層協議讀取異步SOCKET接收緩存中的底層數據后，該異步SOCKET記錄準備向異步消息隊列中寫入的異步讀消息；

當所述異步SOCKET在預制時間內沒有接收到新的底層數據時，該異步SOCKET向異步消息隊列中寫入所述記錄的異步讀消息。

8.?一種處理異步消息隊列的系統，所述系統包括：底層數據模塊、上層協議模塊以及連接底層數據模塊和上層協議模塊的異步SOCKET模塊，其特征在于，

所述異步SOCKET模塊包括：

接收緩存模塊，接收并存放所述底層數據模塊發送的數據；

判斷異步讀消息模塊，用于判斷異步消息隊列中是否有未讀取的異步讀消息；

寫異步讀消息模塊，用于當異步消息隊列中沒有未讀取的異步讀消息時，向所述異步消息隊列中寫入一異步讀消息；

所述上層協議模塊包括：

讀異步讀消息模塊，用于讀取所述異步消息隊列中寫入的異步讀消息；

讀取數據模塊，用于從所述接收緩存模塊中讀取底層數據。

9.?根據權利要求8所述的系統，其特征在于，所述判斷異步讀消息模塊包括：

設置計數器模塊，用于在異步SOCKET中設置合并標志計數器；

判斷計數器模塊，通過所述合并標志計數器的計數判斷異步消息隊列中是否有未讀取的異步讀消息；

操作計數器模塊，用于將所述合并標志計數器的計數值加一或減一；

重置計數器模塊，用于當讀取數據模塊從接收緩存中讀取數據后，將所述合并標志計數器重置為預設值。