[發明專利]基于雙向鏈表的消息多線程消費順序確認的方法及裝置

有效

• 申請號: 202110612637.6
• 申請日: 2021-06-02
• 公開（公告）號: CN113312187B
• 公開（公告）日: 2023-06-16
• 發明（設計）人: 劉德建;鄭彬;岳萬恕;陳宏展
• 申請（專利權）人: 福建天晴數碼有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/52
• 代理公司: 福州旭辰知識產權代理事務所(普通合伙) 35233
• 代理人: 程勇

1.基于雙向鏈表的消息多線程消費順序確認的方法，其特征在于，所述方法包括以下步驟：

步驟S1、創建雙向鏈表，隊列節點維護自身處理狀態和對應消息的偏移量；

步驟S2、主服務從消息中心中拉取消息；

步驟S3、取得消息后，先入雙向鏈表尾部，再將消息提交至本地線程中執行；

步驟S4、本地業務邏輯將消息處理完成后，通知雙向鏈表對應節點，更新狀態；

步驟S5、雙向鏈表的隊列頭部被更新后出隊列，提交offset，并判斷新的隊列頭部的狀態；直至遇到state是未完成的head時阻塞。

2.根據權利要求1所述的基于雙向鏈表的消息多線程消費順序確認的方法，其特征在于：所述步驟S4進一步具體為：待處理業務服務完成消息消費后，異步通知雙向鏈表，雙向鏈表更新狀態，狀態為完成消費。

3.根據權利要求1所述的基于雙向鏈表的消息多線程消費順序確認的方法，其特征在于：所述步驟S5進一步具體為：雙向鏈表等待節點接受處理完成通知變更狀態，并判斷當前節點是否頭部節點及其狀態，決定是否出隊；是，則同時完成消息應答確認，否，則未完成消息應答確認。

4.基于雙向鏈表的消息多線程消費順序確認的裝置，其特征在于：包括創建模塊、拉取消息模塊、執行模塊、通知模塊和提交模塊，所述創建模塊，即創建雙向鏈表，隊列節點維護自身處理狀態和對應消息的偏移量；所述拉取消息模塊，即主服務從消息中心中拉取消息；所述執行模塊，即取得消息后，先入雙向鏈表尾部，再將消息提交至本地線程中執行；所述通知模塊，即本地業務邏輯將消息處理完成后，通知雙向鏈表對應節點，更新狀態；所述提交模塊，即雙向鏈表的隊列頭部被更新后出隊列，提交offset，并判斷新的隊列頭部的狀態；直至遇到state是未完成的head時阻塞。

5.根據權利要求4所述的基于雙向鏈表的消息多線程消費順序確認的裝置，其特征在于：所述通知模塊進一步具體為：待處理業務服務完成消息消費后，異步通知雙向鏈表，雙向鏈表更新狀態，狀態為完成消費。

6.根據權利要求4所述的基于雙向鏈表的消息多線程消費順序確認的裝置，其特征在于：所述提交模塊進一步具體為：雙向鏈表等待節點接受處理完成通知變更狀態，并判斷當前節點是否頭部節點及其狀態，決定是否出隊；是，則同時完成消息應答確認，否，則未完成消息應答確認。