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

有效

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

本公開提供了一種用于實(shí)現(xiàn)消息隊(duì)列的系統(tǒng)、方法及消息調(diào)度系統(tǒng)，涉及計(jì)算機(jī)技術(shù)領(lǐng)域，尤其涉及數(shù)據(jù)處理和消息推薦領(lǐng)域。實(shí)現(xiàn)方案為：一種用于實(shí)現(xiàn)消息隊(duì)列的系統(tǒng)，包括：第一服務(wù)器節(jié)點(diǎn)組，被配置為響應(yīng)于接收到與消息隊(duì)列的存取相關(guān)聯(lián)的請求信息，生成用于消息隊(duì)列的存取的路由信息；第二服務(wù)器節(jié)點(diǎn)組，被配置為基于路由信息來執(zhí)行針對請求信息的消息隊(duì)列的存取，其中，第一服務(wù)器節(jié)點(diǎn)組和第二服務(wù)器節(jié)點(diǎn)組中的每個(gè)被劃分為基于raft協(xié)議的至少一個(gè)服務(wù)器節(jié)點(diǎn)集合，每個(gè)服務(wù)器節(jié)點(diǎn)集合包括分為主服務(wù)器節(jié)點(diǎn)和從服務(wù)器節(jié)點(diǎn)的多個(gè)服務(wù)器節(jié)點(diǎn)。

技術(shù)領(lǐng)域

本公開涉及計(jì)算機(jī)技術(shù)領(lǐng)域，尤其涉及數(shù)據(jù)處理和消息推薦領(lǐng)域，具體涉及一種用于實(shí)現(xiàn)消息隊(duì)列的系統(tǒng)、方法、消息調(diào)度系統(tǒng)及消息推薦系統(tǒng)和方法。

背景技術(shù)

消息隊(duì)列在數(shù)據(jù)的實(shí)時(shí)調(diào)度中起到至關(guān)重要的作用。為了滿足不同的業(yè)務(wù)需要，一條數(shù)據(jù)往往需要經(jīng)過幾十種甚至上百種不同的處理模塊，而這些不同的處理模塊之間需要通過消息隊(duì)列進(jìn)行高效可靠的鏈接。

在此部分中描述的方法不一定是之前已經(jīng)設(shè)想到或采用的方法。除非另有指明，否則不應(yīng)假定此部分中描述的任何方法僅因其包括在此部分中就被認(rèn)為是現(xiàn)有技術(shù)。類似地，除非另有指明，否則此部分中提及的問題不應(yīng)認(rèn)為在任何現(xiàn)有技術(shù)中已被公認(rèn)。

發(fā)明內(nèi)容

本公開提供了一種用于實(shí)現(xiàn)消息隊(duì)列的系統(tǒng)、方法、消息調(diào)度系統(tǒng)及消息推薦系統(tǒng)和方法。

根據(jù)本公開的一方面，提供了一種用于實(shí)現(xiàn)消息隊(duì)列的系統(tǒng)，包括：第一服務(wù)器節(jié)點(diǎn)組，被配置為響應(yīng)于接收到與消息隊(duì)列的存取相關(guān)聯(lián)的請求信息，生成用于所述消息隊(duì)列的存取的路由信息；第二服務(wù)器節(jié)點(diǎn)組，被配置為基于所述路由信息來執(zhí)行針對所述請求信息的所述消息隊(duì)列的存取，其中，所述第一服務(wù)器節(jié)點(diǎn)組和所述第二服務(wù)器節(jié)點(diǎn)組中的每個(gè)被劃分為基于raft協(xié)議的至少一個(gè)服務(wù)器節(jié)點(diǎn)集合，每個(gè)所述服務(wù)器節(jié)點(diǎn)集合包括分為主服務(wù)器節(jié)點(diǎn)和從服務(wù)器節(jié)點(diǎn)的多個(gè)服務(wù)器節(jié)點(diǎn)。

根據(jù)本公開的另一方面，提供了一種消息調(diào)度系統(tǒng)，包括：消息生產(chǎn)單元和/或消息消費(fèi)單元；以及如上所述的用于實(shí)現(xiàn)消息隊(duì)列的系統(tǒng)，其中，所述用于實(shí)現(xiàn)消息隊(duì)列的系統(tǒng)與所述消息生產(chǎn)單元和/或消息消費(fèi)單元交互以實(shí)現(xiàn)消息調(diào)度。

根據(jù)本公開的另一方面，提供了一種用于實(shí)現(xiàn)消息隊(duì)列的方法，包括：構(gòu)建第一服務(wù)器節(jié)點(diǎn)組和第二服務(wù)器節(jié)點(diǎn)組，其中，所述第一服務(wù)器節(jié)點(diǎn)組和所述第二服務(wù)器節(jié)點(diǎn)組中的每個(gè)被劃分為基于raft協(xié)議的至少一個(gè)服務(wù)器節(jié)點(diǎn)集合，每個(gè)所述服務(wù)器節(jié)點(diǎn)集合包括分為主服務(wù)器節(jié)點(diǎn)和從服務(wù)器節(jié)點(diǎn)的多個(gè)服務(wù)器節(jié)點(diǎn)；將所述第一服務(wù)器節(jié)點(diǎn)組配置為響應(yīng)于接收到與消息隊(duì)列的存取相關(guān)聯(lián)的請求信息，生成用于所述消息隊(duì)列的存取的路由信息；以及將所述第二服務(wù)器節(jié)點(diǎn)組配置為基于所述路由信息來執(zhí)行針對所述請求信息的所述消息隊(duì)列的存取。

根據(jù)本公開的另一方面，提供了一種消息推薦系統(tǒng)，包括：消息生產(chǎn)單元和消息消費(fèi)單元；以及如上所述的用于實(shí)現(xiàn)消息隊(duì)列的系統(tǒng)，其中，通過所述用于實(shí)現(xiàn)消息隊(duì)列的系統(tǒng)將所述消息生產(chǎn)單元所生產(chǎn)的消息推薦給所述消息消費(fèi)單元。

根據(jù)本公開的另一方面，提供了一種消息推薦方法，包括：通過如上所述的用于實(shí)現(xiàn)消息隊(duì)列的方法將消息生產(chǎn)單元所生產(chǎn)的消息推薦給消息消費(fèi)單元。

根據(jù)本公開的一個(gè)或多個(gè)實(shí)施例，可以拋棄傳統(tǒng)的zookeeper的集中管理模式，解決對zookeeper過度依賴所帶來的穩(wěn)定性和性能瓶頸。同時(shí)，可以確保服務(wù)器節(jié)點(diǎn)的可用性和穩(wěn)定性。

應(yīng)當(dāng)理解，本部分所描述的內(nèi)容并非旨在標(biāo)識本公開的實(shí)施例的關(guān)鍵或重要特征，也不用于限制本公開的范圍。本公開的其它特征將通過以下的說明書而變得容易理解。

附圖說明

附圖示例性地示出了實(shí)施例并且構(gòu)成說明書的一部分，與說明書的文字描述一起用于講解實(shí)施例的示例性實(shí)施方式。所示出的實(shí)施例僅出于例示的目的，并不限制權(quán)利要求的范圍。在所有附圖中，相同的附圖標(biāo)記指代類似但不一定相同的要素。