[發明專利]一種隊列消息一致性的實現方法、裝置、計算系統

有效

• 申請號: 201811294150.2
• 申請日: 2018-11-01
• 公開（公告）號: CN109408203B
• 公開（公告）日: 2019-10-18
• 發明（設計）人: 許廣彬;譚瑞忠;濮天暉;王明星
• 申請（專利權）人: 無錫華云數據技術服務有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46;G06F9/54
• 代理公司: 蘇州友佳知識產權代理事務所(普通合伙) 32351
• 代理人: 儲振

1.一種實現隊列消息一致性的裝置，其特征在于，包括：業務邏輯模塊、事務管理模塊及消息管理模塊 ；所述業務邏輯模塊，請求打開消息中間件的本地事務，并在執行事務前調用事務管理模塊開啟本地事務，并獨立地通過消息管理模塊對事務管理模塊所開啟的所述消息中間件的本地事務所產生的提交事件或回滾事件執行監聽，所述事務管理模塊與消息管理模塊基于心跳機制確保彼此處于同一進程；所述消息管理模塊保存并轉發所述消息中間件的指定隊列中的消息至事務管理模塊，并將消息轉發執行結果通知事務管理模塊，事務管理模塊根據所述轉發執行結果執行提交事件或回滾事件，消息中間件的本地事務為所述消息中間件上運行的事務；

還包括與消息管理模塊連接的消息清理模塊；其中，

當所述消息清理模塊在事務管理模塊與消息管理模塊之間處于不同進程的場景、消息管理模塊調用消息失敗或者調用超時的場景時，對符合上述場景的消息，通過消息清理模塊將該消息的索引標識在文件配置表中執行刪除標記操作，將所述消息的簇號在文件配置表中的登記項清零，以釋放消息管理模塊中的消息。

2.根據權利要求1所述的裝置，其特征在于，所述消息管理模塊根據消息頭查找消息中間件的指定隊列中的消息的被執行轉發結果，所述消息頭包含被執行轉發的消息所對應的事務id。

3.根據權利要求1所述的裝置，其特征在于，所述裝置還包括：持久化存儲介質，所述事務管理模塊與消息管理模塊掛載至持久化存儲介質，并僅通過消息管理模塊向持久化存儲介質寫入所述消息中間件的指定隊列中被執行轉發的消息。

4.根據權利要求3所述的裝置，其特征在于，所述持久化存儲介質選自磁盤、閃存或者非易失性內存；其中，所述非易性內存由支持隨機訪問的固態存儲裝置、快閃存儲器、相變存儲器、強介電體存儲器、磁記錄式隨時寫入讀出存儲器、雙向統一存儲器、電阻RAM、NVDIMM或者RAMDISK之一構成。

5.根據權利要求1所述的裝置，其特征在于，所述消息管理模塊與事務管理模塊邏輯上彼此獨立。

6.根據權利要求4所述的裝置，其特征在于，所述NVDIMM包括：若干并列匹配設置且數量相等的NAND(20b)與存儲器控制器(10a)，以及控制電路(30)；所述控制電路(30)包括：設置在所述NAND(20b)和存儲器控制器(10a)之間呈級聯結構的第一選擇器(301)、第二選擇器(302)、旁路切換模塊(303)以及一仲裁器(304)；

存儲器控制器(10a)接收各個NAND(20b)的數據訪問請求并發送至仲裁器(304)，并由仲裁器(304)對各個數據訪問請求的優先級順序進行判斷，第一選擇器(301)根據優先級的順序，依次與存儲器控制器(10a)建立多個連接通道，并通過第二選擇器(302)與多個并列設置的NAND(20b)所建立的正常數據通道(312)進行數據的寫入/讀取；所述存儲器控制器(10a)通過接口總線(305)與系統總線(40)連接，以通過所述系統總線(40)與消息管理模塊建立連接。

7.根據權利要求1至6中任一項所述的裝置，其特征在于，所述消息管理模塊在確認消息轉發執行完畢后，將消息轉發執行情況與事務管理模塊執行同步操作，并由事務管理模塊通知業務邏輯模塊所述本地事務被執行完畢。