[發明專利]一種基于內存數據庫緩存的高速消息隊列溢出的處理方法

無效

• 申請號: 201310310533.5
• 申請日: 2013-07-23
• 公開（公告）號: CN103390049A
• 公開（公告）日: 2013-11-13
• 發明（設計）人: 張金鐘;秦家祥;華國棟;高洋;孫力斌
• 申請（專利權）人: 南京聯創科技集團股份有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30;G06F12/08
• 代理公司: 江蘇圣典律師事務所 32237
• 代理人: 鄧麗

1.一種基于內存數據庫緩存的高速消息隊列溢出的處理方法，其特征在于包括如下內容：將通信數據寫入內存隊列中；如果內存隊列數據達到設定閾值，則將數據存到遠程內存數據庫中；如果在讀數據的過程中，檢測到本地隊列中的數據已經下降到額定閾值，則啟動數據轉移線程，將遠程內存數據庫隊列中的數據轉移到本地隊列。

2.如權利要求1所述的一種基于內存數據庫緩存的高速消息隊列溢出的處理方法，其特征在于所述將數據寫入隊列的操作步驟如下：

（11）接收需入隊列的數據；

（12）在入隊列之前先判斷消息隊列的數據量是否達到隊列的最大閾值，若超過該最大閾值，轉步驟（14），若沒有超過該最大閾值，轉步驟（13）；

（13）判斷內存數據庫隊列計數器的值是否大于0，如果大于0則轉步驟（14），否則將接收的數據壓入本地隊列，然后返回步驟（11）繼續接收數據；

（14）將前述需入隊列的數據存入內存數據庫，發送到遠程內存數據庫隊列中，然后在內存數據庫隊列計數器中加1；然后返回步驟（11）繼續接收數據。

3.如權利要求2所述的一種基于內存數據庫緩存的高速消息隊列溢出的處理方法，其特征在于：所述步驟（12）中，最大閾值是指隊列最大容量的90%。

4.如權利要求1所述的一種基于內存數據庫緩存的高速消息隊列溢出的處理方法，其特征在于所述將數據取出隊列的操作步驟如下：

（21）從隊列中取出數據；

（22）判斷內存數據庫隊列計數器的值是否大于0，如果大于0則轉步驟（23），否則轉步驟（24）；

（23）判斷本地隊列的數據量是否低于最小閾值，小于則啟動隊列轉移線程，把程內存數據庫隊列中的數據轉移到本地隊列中，轉步驟（24）；否則直接轉步驟（24）；

（24）將步驟（21）中從隊列中取出的數據進行處理。

5.如權利要求4所述的一種基于內存數據庫緩存的高速消息隊列溢出的處理方法，其特征在于：所述步驟（23）中，最小閾值是指隊列最大容量的60%。

6.如權利要求1所述的一種基于內存數據庫緩存的高速消息隊列溢出的處理方法，其特征在于所述在數據轉移線程中將數據轉移的操作步驟如下：

（31）線程開始；

（32）從對應的遠程內存數據庫隊列中取出數據，同時將內存數據庫隊列計數器的數據量減1；

（33）將前述取出的數據壓入到本地對應的隊列中；

（34）判斷消息隊列的數據量是否達到隊列的最大閾值，若超過該最大閾值，則退出線程，否則繼續判斷內存數據庫隊列計數器的值是否大于0，如果大于0，返回步驟（32），否則退出線程。