[發明專利]用于中間件消息的存儲與傳輸方法及系統

有效

• 申請號: 201410022650.6
• 申請日: 2014-01-17
• 公開（公告）號: CN104794119B
• 公開（公告）日: 2018-04-03
• 發明（設計）人: 潘先進
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30;H04L29/08
• 代理公司: 北京國昊天誠知識產權代理有限公司11315
• 代理人: 許志勇

1.一種用于中間件消息的存儲與傳輸方法，應用于文件庫中，其特征在于，包括：

在所述文件庫中創建數據隊列、索引隊列和指針文件，其中，該索引隊列包括對應于不同用戶的索引分區；所述數據隊列用于順序存儲用戶的數據，所述索引分區按照所屬用戶劃分，每個所述索引分區存儲該用戶在所述數據隊列中存儲的數據的索引，所述指針文件中的指針指向被讀取的數據的索引所在的所述索引分區的索引隊列位置；

監測到數據存入所述文件庫時，將該數據存入所述數據隊列中，完成后將該數據對應的索引存儲到與該數據所屬用戶相對應的所述索引隊列中；

監測到讀取所述文件庫中的數據時，從指針文件中獲取當前指針指向的索引所在的所述索引分區的索引隊列位置，并根據該索引隊列位置獲取下一條索引，通過該索引從所述數據隊列中讀取對應的數據投遞完成，并更新所述指針文件中當前指針指向的索引所在的所述索引分區的索引隊列位置。

2.如權利要求1所述的用于中間件消息的存儲與傳輸方法，其特征在于，還包括：

所述索引隊列還包括一恢復分區；

監測到讀取所述文件庫中的數據時，從指針文件中獲取當前指針指向的索引所在的所述索引分區的索引隊列位置，并根據該索引隊列位置獲取下一條索引，通過該索引從所述數據隊列中讀取對應的數據投遞失敗時，將該索引存入所述恢復分區中的索引隊列；

同時，監測到讀取所述文件庫中的數據時，所述恢復分區從所述指針文件中獲取當前恢復指針指向的恢復索引所在的所述恢復分區的索引隊列位置，并根據該索引隊列位置獲取下一條恢復索引，通過該恢復索引從所述數據隊列中讀取對應的數據投遞完成，并更新所述指針文件中當前恢復指針指向的索引所在的所述恢復分區的索引隊列位置。

3.如權利要求2所述的用于中間件消息的存儲與傳輸方法，其特征在于，還包括：

通過該恢復索引從所述數據隊列中讀取對應的數據投遞失敗時，將該恢復索引放入所述恢復分區中的索引隊列的排序執行末端。

4.如權利要求3所述的用于中間件消息的存儲與傳輸方法，其特征在于，還包括：

監控所述恢復分區中的索引隊列中的至少十個恢復索引從所述數據隊列中讀取對應的數據進行投遞的失敗率，若所述失敗率超過20%，則延時至少5秒鐘執行所述恢復分區從所述指針文件中獲取當前恢復指針指向的恢復索引所在的所述恢復分區的索引隊列位置。

5.如權利要求1至4中任一所述的用于中間件消息的存儲與傳輸方法，其特征在于，所述索引分區中的索引，由文件名和文件組成，文件名為從零開始排序，排序在該文件名之后的文件名為該文件名加上該文件名對應的文件的格式大小的數值；其中，所述索引的大小為最多32個字節組成。

6.一種用于中間件消息的存儲與傳輸系統，應用于文件庫中，其特征在于，包括：存儲單元、監測單元、寫入傳輸單元和讀取傳輸單元；其中，

所述存儲單元，用于在所述文件庫中創建數據隊列、索引隊列和指針文件，其中，該索引隊列包括對應于不同用戶的索引分區；所述數據隊列用于順序存儲用戶的數據，所述索引分區按照所屬用戶劃分，每個所述索引分區存儲該用戶在所述數據隊列中存儲的數據的索引，所述指針文件中的指針指向被讀取的數據的索引所在的所述索引分區的索引隊列位置；

所述監測單元，用于監測到數據存入所述文件庫時，指示所述寫入傳輸單元；監測到讀取所述文件庫中的數據時，指示所述讀取傳輸單元；

所述寫入傳輸單元，用于將該數據存入所述存儲單元創建的數據隊列中，完成后將該數據對應的索引存儲到與該數據所屬用戶相對應的所述索引隊列中；

所述讀取傳輸單元，用于從所述存儲單元的指針文件中獲取當前指針指向的索引所在的所述索引分區的索引隊列位置，并根據該索引隊列位置獲取下一條索引，通過該索引從所述數據隊列中讀取對應的數據投遞完成，并更新所述指針文件中當前指針指向的索引所在的所述索引分區的索引隊列位置。