[發(fā)明專利]隊(duì)列消息存儲(chǔ)轉(zhuǎn)發(fā)方法、系統(tǒng)及具操作系統(tǒng)的計(jì)算機(jī)裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 202010186264.6
• 申請(qǐng)日: 2020-03-17
• 公開（公告）號(hào): CN111459686B
• 公開（公告）日: 2023-06-27
• 發(fā)明（設(shè)計(jì)）人: 萬前;蔡志陽;楊波
• 申請(qǐng)（專利權(quán)）人: 華云數(shù)據(jù)控股集團(tuán)有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54;G06F16/22;G06F16/2458;G06F16/25
• 代理公司: 蘇州友佳知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 32351
• 代理人: 儲(chǔ)振

本發(fā)明提供了一種隊(duì)列消息存儲(chǔ)轉(zhuǎn)發(fā)方法、系統(tǒng)及具操作系統(tǒng)的計(jì)算機(jī)裝置，該隊(duì)列消息存儲(chǔ)轉(zhuǎn)發(fā)方法，由計(jì)算機(jī)或者軟件執(zhí)行，包括接收對(duì)指定內(nèi)容的訪問請(qǐng)求，并將訪問請(qǐng)求所攜帶的Topic保存至用戶訪問信息表；用戶訪問信息表對(duì)用戶Topic優(yōu)先級(jí)表中對(duì)指定內(nèi)容的Topic的優(yōu)先級(jí)修改，使用內(nèi)存隊(duì)列從存儲(chǔ)指定內(nèi)容的第三存儲(chǔ)裝置中抓取與訪問請(qǐng)求所對(duì)應(yīng)的指定內(nèi)容向發(fā)起對(duì)指定內(nèi)容的訪問請(qǐng)求的主體進(jìn)行響應(yīng)。通過本申請(qǐng)所揭示的隊(duì)列消息存儲(chǔ)轉(zhuǎn)發(fā)方法、系統(tǒng)及具操作系統(tǒng)的計(jì)算機(jī)裝置，滿足了用戶對(duì)海量的實(shí)體數(shù)據(jù)的高并發(fā)響應(yīng)，消除了海量Topic消息在存儲(chǔ)與轉(zhuǎn)發(fā)過程中所存在的延遲現(xiàn)象，并降低了對(duì)物理設(shè)備的計(jì)算開銷。

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

本發(fā)明涉及計(jì)算機(jī)數(shù)據(jù)處理技術(shù)領(lǐng)域，尤其涉及一種隊(duì)列消息存儲(chǔ)轉(zhuǎn)發(fā)方法、系統(tǒng)及具操作系統(tǒng)的計(jì)算機(jī)裝置。

背景技術(shù)

表格存儲(chǔ)(Tablestore)是一種NoSQL多模型數(shù)據(jù)庫，其能夠提供海量結(jié)構(gòu)化數(shù)據(jù)存儲(chǔ)以及快速的查詢和分析服務(wù)。表格存儲(chǔ)的分布式存儲(chǔ)和強(qiáng)大的索引引擎能夠支持PB級(jí)存儲(chǔ)、千萬TPS以及毫秒級(jí)延遲的服務(wù)能力。在大數(shù)據(jù)時(shí)代，基于傳統(tǒng)的生產(chǎn)者消費(fèi)者隊(duì)列模式中的Topic數(shù)量會(huì)變成海量級(jí)。彈窗、流媒體文件推送、推薦商品網(wǎng)頁推送、計(jì)算機(jī)硬件裝置/軟件系統(tǒng)中產(chǎn)生類、函數(shù)、線程或者進(jìn)程等場景中，每一種消息類型都會(huì)成為一個(gè)Topic，而每一個(gè)Topic內(nèi)部都會(huì)存在多個(gè)子分類與孫分類，甚至更深層次的分類。

例如，在流媒體文件推送場景中，用戶在視頻客戶端上進(jìn)行視頻點(diǎn)播時(shí)，視頻客戶端的可視化界面中展示了體育、綜藝兩個(gè)分類，而體育分類中往往又包含籃球、網(wǎng)球等子分類，而籃球子分類中又包含NBA、CBA等孫分類，NBA的孫分類中又可包含NBA集錦、十佳扣籃等多個(gè)更下位的分類。那么每個(gè)層級(jí)的分類所對(duì)應(yīng)的隊(duì)列任務(wù)會(huì)存在特定的生產(chǎn)者與消費(fèi)者。產(chǎn)生數(shù)據(jù)的模塊/主體為生產(chǎn)者(Producer)；而處理數(shù)據(jù)的模塊/主體為消費(fèi)者(Consumer)。訂閱模式是指消息生產(chǎn)者將消息發(fā)布到topic中，同時(shí)有多個(gè)消息消費(fèi)者消費(fèi)該消息，發(fā)布到topic的消息會(huì)被所有訂閱者消費(fèi)。目前，基于消息處理模型的事務(wù)處理系統(tǒng)或者計(jì)算機(jī)程序中，對(duì)隊(duì)列消息進(jìn)行存儲(chǔ)與轉(zhuǎn)發(fā)過程中存在一定的延遲，且對(duì)物理設(shè)備的技術(shù)要求較為苛刻。更為重要的是，現(xiàn)有技術(shù)中的隊(duì)列消息存儲(chǔ)轉(zhuǎn)發(fā)方法無法對(duì)用戶的個(gè)性化需求予以合理且準(zhǔn)確響應(yīng)。

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

本發(fā)明的目的在于揭示一種隊(duì)列消息存儲(chǔ)轉(zhuǎn)發(fā)方法、系統(tǒng)及具操作系統(tǒng)的計(jì)算機(jī)裝置，用以解決現(xiàn)有技術(shù)中對(duì)海量高并發(fā)訪問請(qǐng)求所存在的缺陷，尤其是為了在基于消息處理模型的事務(wù)處理系統(tǒng)或者計(jì)算機(jī)程序中，降低對(duì)海量Topic消息進(jìn)行存儲(chǔ)與轉(zhuǎn)發(fā)過程中所存在的延遲，降低對(duì)物理設(shè)備的計(jì)算開銷，滿足海量用戶對(duì)不同優(yōu)先級(jí)的Topic消息所對(duì)應(yīng)的實(shí)體數(shù)據(jù)的高并發(fā)響應(yīng)。

為實(shí)現(xiàn)上述第一個(gè)發(fā)明目的，本發(fā)明提供了一種隊(duì)列消息存儲(chǔ)轉(zhuǎn)發(fā)方法，

由計(jì)算機(jī)或者軟件執(zhí)行，包括：

接收對(duì)指定內(nèi)容的訪問請(qǐng)求，并將所述訪問請(qǐng)求所攜帶的Topic保存至用戶訪問信息表；

用戶訪問信息表對(duì)用戶Topic優(yōu)先級(jí)表中對(duì)指定內(nèi)容的Topic的優(yōu)先級(jí)修改，使用內(nèi)存隊(duì)列從存儲(chǔ)指定內(nèi)容的第三存儲(chǔ)裝置中抓取與所述訪問請(qǐng)求所對(duì)應(yīng)的指定內(nèi)容向發(fā)起對(duì)指定內(nèi)容的訪問請(qǐng)求的主體進(jìn)行響應(yīng)。

作為本發(fā)明的進(jìn)一步改進(jìn)，所述用戶訪問信息表關(guān)聯(lián)至全量信息表，以通過所述全量信息表和/或用戶訪問信息表根據(jù)訪問請(qǐng)求所攜帶的Topic確定與所述訪問請(qǐng)求所對(duì)應(yīng)的指定內(nèi)容。

作為本發(fā)明的進(jìn)一步改進(jìn)，所述用戶Topic優(yōu)先級(jí)表關(guān)聯(lián)至Topic信息表，以通過所述Topic信息表對(duì)用戶Topic優(yōu)先級(jí)表中具優(yōu)先級(jí)的任務(wù)序列進(jìn)行調(diào)整；

所述用戶訪問信息表和/或全量信息表以表格存儲(chǔ)形式保存于第一存儲(chǔ)裝置。

作為本發(fā)明的進(jìn)一步改進(jìn)，還包括：預(yù)配置推薦內(nèi)容并保存至Topic信息表；