[發(fā)明專利]一種用于消息隊(duì)列的自動(dòng)擴(kuò)容方法及裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 202110859802.8
• 申請(qǐng)日: 2021-07-28
• 公開（公告）號(hào): CN113609071A
• 公開（公告）日: 2021-11-05
• 發(fā)明（設(shè)計(jì)）人: 劉彬
• 申請(qǐng)（專利權(quán)）人: 北京金山云網(wǎng)絡(luò)技術(shù)有限公司
• 主分類號(hào): G06F16/11
• 分類號(hào): G06F16/11;G06F16/13;G06F16/17;G06F16/182;G06F9/54
• 代理公司: 北京華夏泰和知識(shí)產(chǎn)權(quán)代理有限公司 11662
• 代理人: 曾軍;韓來兵

1.一種用于消息隊(duì)列的自動(dòng)擴(kuò)容方法，其特征在于，包括：

獲取目標(biāo)消息隊(duì)列中每個(gè)候選分區(qū)的負(fù)載；

根據(jù)每個(gè)所述候選分區(qū)的負(fù)載以及目標(biāo)負(fù)載閥值，判斷所述候選分區(qū)中是否存在高負(fù)載分區(qū)，其中，所述高負(fù)載分區(qū)的負(fù)載高于所述目標(biāo)負(fù)載閥值；

在確定存在至少一個(gè)所述高負(fù)載分區(qū)的情況下，生成用于對(duì)所述目標(biāo)消息隊(duì)列進(jìn)行分區(qū)擴(kuò)容的目標(biāo)指令；

按照所述目標(biāo)指令，在所述目標(biāo)消息隊(duì)列中增加至少一個(gè)新增分區(qū)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述根據(jù)每個(gè)所述候選分區(qū)的負(fù)載以及目標(biāo)負(fù)載閥值，判斷所述候選分區(qū)中是否存在高負(fù)載分區(qū)包括：

在所述候選分區(qū)的負(fù)載指示所述候選分區(qū)的數(shù)據(jù)負(fù)載大于或等于目標(biāo)數(shù)據(jù)負(fù)載閥值，或所述候選分區(qū)的計(jì)算資源負(fù)載大于或等于目標(biāo)計(jì)算資源負(fù)載閥值的情況下，將所述候選分區(qū)確定為所述高負(fù)載分區(qū)。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，在所述在確定存在至少一個(gè)所述高負(fù)載分區(qū)的情況下，生成用于對(duì)所述目標(biāo)消息隊(duì)列進(jìn)行分區(qū)擴(kuò)容的目標(biāo)指令之前，所述方法還包括：

在除所述高負(fù)載分區(qū)之外的所有所述候選分區(qū)中，確定出目標(biāo)低負(fù)載分區(qū)；

確定所述目標(biāo)低負(fù)載分區(qū)的目標(biāo)分區(qū)標(biāo)識(shí)。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述按照所述目標(biāo)指令，在所述目標(biāo)消息隊(duì)列中增加至少一個(gè)新增分區(qū)包括：

按照所述目標(biāo)分區(qū)標(biāo)識(shí)，將所述目標(biāo)指令發(fā)送至所述目標(biāo)低負(fù)載分區(qū)；

在所述目標(biāo)低負(fù)載分區(qū)執(zhí)行所述目標(biāo)指令之后，在所述目標(biāo)低負(fù)載分區(qū)所在的目標(biāo)節(jié)點(diǎn)中增加至少一個(gè)所述新增分區(qū)。

5.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述在除所述高負(fù)載分區(qū)之外的所有所述候選分區(qū)中，確定出目標(biāo)低負(fù)載分區(qū)包括：

將除所述高負(fù)載分區(qū)之外的所有所述候選分區(qū)確定為低負(fù)載分區(qū)；

確定每個(gè)所述低負(fù)載分區(qū)的負(fù)載；

在所有所述低負(fù)載分區(qū)中，確定出所述負(fù)載最低的所述目標(biāo)低負(fù)載分區(qū)。

6.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述獲取目標(biāo)消息隊(duì)列中每個(gè)候選分區(qū)的負(fù)載包括：

獲取目標(biāo)集群中每個(gè)候選消息隊(duì)列的負(fù)載信息，其中，每個(gè)所述負(fù)載信息包括對(duì)應(yīng)的所述候選消息隊(duì)列中每個(gè)分區(qū)的負(fù)載；

根據(jù)所述負(fù)載信息在所有所述候選消息隊(duì)列中確定出所述目標(biāo)消息隊(duì)列，并確定所述目標(biāo)消息隊(duì)列每個(gè)所述候選分區(qū)的負(fù)載，其中，所述目標(biāo)消息隊(duì)列中存在至少一個(gè)所述候選分區(qū)的負(fù)載高于目標(biāo)負(fù)載閥值。

7.根據(jù)權(quán)利要求1所述的方法，其特征在于，在所述按照所述目標(biāo)指令，在所述目標(biāo)消息隊(duì)列中增加至少一個(gè)新增分區(qū)之后，所述方法還包括：

獲取所述新增分區(qū)的分區(qū)信息；

根據(jù)所述分區(qū)信息對(duì)所述目標(biāo)消息隊(duì)列的歷史元數(shù)據(jù)信息進(jìn)行更新，得到更新后元數(shù)據(jù)信息；

按照所述更新后元數(shù)據(jù)信息將待寫入數(shù)據(jù)寫入至所述新增分區(qū)中。

8.一種用于消息隊(duì)列的自動(dòng)擴(kuò)容裝置，其特征在于，包括：

獲取模塊，用于獲取目標(biāo)消息隊(duì)列中每個(gè)候選分區(qū)的負(fù)載；

判斷模塊，用于根據(jù)每個(gè)所述候選分區(qū)的負(fù)載以及目標(biāo)負(fù)載閥值，判斷所述候選分區(qū)中是否存在高負(fù)載分區(qū)，其中，所述高負(fù)載分區(qū)的負(fù)載高于所述目標(biāo)負(fù)載閥值；

生成模塊，用于在確定存在至少一個(gè)所述高負(fù)載分區(qū)的情況下，生成用于對(duì)所述目標(biāo)消息隊(duì)列進(jìn)行分區(qū)擴(kuò)容的目標(biāo)指令；

新增模塊，用于按照所述目標(biāo)指令，在所述目標(biāo)消息隊(duì)列中增加至少一個(gè)新增分區(qū)。

9.一種電子設(shè)備，其特征在于，包括：處理器、通信接口、存儲(chǔ)器和通信總線，其中，所述處理器、通信接口和存儲(chǔ)器通過通信總線完成相互間的通信；

所述存儲(chǔ)器，用于存放計(jì)算機(jī)程序；

所述處理器，用于執(zhí)行所述計(jì)算機(jī)程序時(shí)，實(shí)現(xiàn)權(quán)利要求1至7任一項(xiàng)所述的方法。

10.一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其特征在于，所述存儲(chǔ)介質(zhì)包括存儲(chǔ)的程序，其中，所述程序運(yùn)行時(shí)執(zhí)行上述權(quán)利要求1至7中任一項(xiàng)所述的方法。