[發(fā)明專利]用于實現(xiàn)消息隊列的系統(tǒng)、方法及消息調(diào)度系統(tǒng)

有效

• 申請?zhí)枺?/td>: 202011559212.5
• 申請日: 2020-12-25
• 公開（公告）號: CN112698965B
• 公開（公告）日: 2021-09-21
• 發(fā)明（設計）人: 張連升;馮健;晏原;吳昭;黎江
• 申請（專利權）人: 百度在線網(wǎng)絡技術（北京）有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F11/14;G06F16/27
• 代理公司: 北京市漢坤律師事務所 11602
• 代理人: 姜浩然;吳麗麗

1.一種用于實現(xiàn)消息隊列的系統(tǒng)，包括：

第一服務器節(jié)點組，被配置為響應于接收到與消息隊列的存取相關聯(lián)的請求信息，生成用于所述消息隊列的存取的路由信息；

第二服務器節(jié)點組，被配置為基于所述路由信息來執(zhí)行針對所述請求信息的所述消息隊列的存取，

其中，所述第一服務器節(jié)點組和所述第二服務器節(jié)點組中的每個被劃分為基于raft協(xié)議的至少一個服務器節(jié)點集合，每個所述服務器節(jié)點集合包括分為主服務器節(jié)點和從服務器節(jié)點的多個服務器節(jié)點。

2.如權利要求1所述的系統(tǒng)，其中，針對所述第一服務器節(jié)點組的所述服務器節(jié)點集合，所述主服務器節(jié)點被配置為管理所述第二服務器節(jié)點組的所述服務器節(jié)點集合的劃分，以增加或減少所述第二服務器節(jié)點組的所述服務器節(jié)點集合的數(shù)量。

3.如權利要求2所述的系統(tǒng)，其中，所述第一服務器節(jié)點組還被配置為存儲所述消息隊列的元信息，所述元信息包括與所述第二服務器節(jié)點組的所述服務器節(jié)點集合的劃分有關的信息。

4.如權利要求1所述的系統(tǒng)，還包括用于存儲所述消息隊列的存儲引擎，其中，所述存儲引擎基于鍵-值的數(shù)據(jù)結(jié)構。

5.如權利要求4所述的系統(tǒng)，其中，所述第一服務器節(jié)點組還被配置為存儲所述消息隊列的元信息，所述元信息包括所述消息隊列的存儲地址，所述存儲地址指示存儲所述消息隊列的特定存儲引擎。

6.如權利要求4所述的系統(tǒng)，其中，所述請求信息包括用于將消息寫入到所述存儲引擎和/或從所述存儲引擎讀取所述消息的請求，所述消息在所述存儲引擎中構成所述消息隊列。

7.如權利要求6所述的系統(tǒng)，其中，通過所述路由信息指示所述第二服務器節(jié)點組之中的特定服務器節(jié)點集合中的主服務器節(jié)點來執(zhí)行所述消息的寫入和/或讀取。

8.如權利要求7所述的系統(tǒng)，其中，所述主服務器節(jié)點根據(jù)所述消息的權重將所述消息分配到相應的權重隊列和/或從所述相應的權重隊列獲取所述消息。

9.如權利要求1所述的系統(tǒng)，其中，所述第一服務器節(jié)點組和所述第二服務器節(jié)點組的所述服務器節(jié)點集合中的所述從服務器節(jié)點被配置為進行熱備，以在所述主服務器節(jié)點故障時替代所述主服務器節(jié)點。

10.一種消息調(diào)度系統(tǒng)，包括：

消息生產(chǎn)單元和/或消息消費單元；以及

如權利要求1-9中任一項所述的用于實現(xiàn)消息隊列的系統(tǒng)，其中，所述用于實現(xiàn)消息隊列的系統(tǒng)與所述消息生產(chǎn)單元和/或消息消費單元交互以實現(xiàn)消息調(diào)度。

11.一種用于實現(xiàn)消息隊列的方法，包括：

構建第一服務器節(jié)點組和第二服務器節(jié)點組，其中，將所述第一服務器節(jié)點組和所述第二服務器節(jié)點組中的每個劃分為基于raft協(xié)議的至少一個服務器節(jié)點集合，每個所述服務器節(jié)點集合包括分為主服務器節(jié)點和從服務器節(jié)點的多個服務器節(jié)點；

將所述第一服務器節(jié)點組配置為響應于接收到與消息隊列的存取相關聯(lián)的請求信息，生成用于所述消息隊列的存取的路由信息；以及

將所述第二服務器節(jié)點組配置為基于所述路由信息來執(zhí)行針對所述請求信息的所述消息隊列的存取。

12.如權利要求11所述的方法，其中，針對所述第一服務器節(jié)點組的所述服務器節(jié)點集合，將所述主服務器節(jié)點配置為管理所述第二服務器節(jié)點組的所述服務器節(jié)點集合的劃分，以增加或減少所述第二服務器節(jié)點組的所述服務器節(jié)點集合的數(shù)量。

13.如權利要求12所述的方法，其中，還將所述第一服務器節(jié)點組配置為存儲所述消息隊列的元信息，所述元信息包括與所述第二服務器節(jié)點組的所述服務器節(jié)點集合的劃分有關的信息。