[發(fā)明專利]基于業(yè)務(wù)代理的業(yè)務(wù)消息處理方法、裝置及電子設(shè)備

在審

• 申請(qǐng)?zhí)枺?/td>: 202011496598.X
• 申請(qǐng)日: 2020-12-17
• 公開(kāi)（公告）號(hào): CN112579148A
• 公開(kāi)（公告）日: 2021-03-30
• 發(fā)明（設(shè)計(jì)）人: 張睿
• 申請(qǐng)（專利權(quán)）人: 廣州虎牙科技有限公司
• 主分類號(hào): G06F8/71
• 分類號(hào): G06F8/71;G06F9/50
• 代理公司: 北京市立方律師事務(wù)所 11330
• 代理人: 劉延喜

1.一種基于業(yè)務(wù)代理的業(yè)務(wù)消息處理方法，其特征在于，包括以下步驟：

獲取遠(yuǎn)程配置模塊設(shè)置的業(yè)務(wù)配置信息；

監(jiān)聽(tīng)當(dāng)前消息中間件的業(yè)務(wù)消息的積壓狀態(tài)和流式處理框架的數(shù)據(jù)處理的運(yùn)行負(fù)載；

根據(jù)所述積壓狀態(tài)和所述運(yùn)行負(fù)載構(gòu)建擴(kuò)縮容作業(yè)及其對(duì)應(yīng)的消息中間件的新消息主題；

將新的業(yè)務(wù)消息發(fā)送至所述消息中間件的新消息主題，并利用所述新消息主題對(duì)應(yīng)的擴(kuò)縮容作業(yè)按照所述業(yè)務(wù)配置信息對(duì)所述業(yè)務(wù)消息進(jìn)行聚合處理。

2.根據(jù)權(quán)利要求1所述的基于業(yè)務(wù)代理的業(yè)務(wù)消息處理方法，其特征在于，所述將新的業(yè)務(wù)消息發(fā)送至所述消息中間件的新消息主題的步驟，包括：

在進(jìn)行擴(kuò)縮容作業(yè)處理時(shí)，從鍵值數(shù)據(jù)庫(kù)中讀取預(yù)存的映射關(guān)系；其中，所述映射關(guān)系為預(yù)先建立并保存的所述業(yè)務(wù)消息的業(yè)務(wù)標(biāo)識(shí)、所述新消息主題以及所述擴(kuò)縮容作業(yè)之間的映射關(guān)系；

根據(jù)所述映射關(guān)系將新的業(yè)務(wù)消息發(fā)送至對(duì)應(yīng)的所述消息中間件的新消息主題。

3.根據(jù)權(quán)利要求2所述的基于業(yè)務(wù)代理的業(yè)務(wù)消息處理方法，其特征在于，所述將新的業(yè)務(wù)消息發(fā)送至所述消息中間件的新消息主題，并利用所述新消息主題對(duì)應(yīng)的擴(kuò)縮容作業(yè)按照所述業(yè)務(wù)配置信息對(duì)所述業(yè)務(wù)消息進(jìn)行聚合處理的步驟包括：

在當(dāng)前作業(yè)對(duì)應(yīng)的消息中間件消息主題中的業(yè)務(wù)消息被處理完畢后，將新的業(yè)務(wù)消息發(fā)送至所述消息中間件的新消息主題；

利用所述新消息主題對(duì)應(yīng)的擴(kuò)縮容作業(yè)拉取所述新消息主題的業(yè)務(wù)消息，并按照所述業(yè)務(wù)配置信息對(duì)所述業(yè)務(wù)消息進(jìn)行聚合處理。

4.根據(jù)權(quán)利要求1所述的基于業(yè)務(wù)代理的業(yè)務(wù)消息處理方法，其特征在于，所述根據(jù)所述積壓狀態(tài)和運(yùn)行負(fù)載構(gòu)建擴(kuò)縮容作業(yè)及其對(duì)應(yīng)的消息中間件的新消息主題的步驟包括：

根據(jù)所述積壓狀態(tài)確定待處理的業(yè)務(wù)消息的第一數(shù)量，根據(jù)所述運(yùn)行負(fù)載確定所述流式處理框架的作業(yè)資源；

當(dāng)所述第一數(shù)量大于第一預(yù)設(shè)閾值且所述流式處理框架的作業(yè)資源充足時(shí)，構(gòu)建擴(kuò)容作業(yè)及其對(duì)應(yīng)的消息中間件的擴(kuò)容消息主題；所述新消息主題為所述擴(kuò)容消息主題。

5.根據(jù)權(quán)利要求1所述的基于業(yè)務(wù)代理的業(yè)務(wù)消息處理方法，其特征在于，所述根據(jù)所述積壓狀態(tài)和運(yùn)行負(fù)載構(gòu)建擴(kuò)縮容作業(yè)及其對(duì)應(yīng)的消息中間件的新消息主題的步驟包括：

根據(jù)所述積壓狀態(tài)確定待處理的業(yè)務(wù)消息的第二數(shù)量，以及統(tǒng)計(jì)所述積壓狀態(tài)的持續(xù)時(shí)間；

當(dāng)所述第二數(shù)量小于第二預(yù)設(shè)閾值且持續(xù)時(shí)間達(dá)到預(yù)設(shè)時(shí)間閾值時(shí)，構(gòu)建縮容作業(yè)及其對(duì)應(yīng)的消息中間件的縮容消息主題；所述新消息主題為縮容消息；所述縮容作業(yè)的作業(yè)資源量小于擴(kuò)容作業(yè)的作業(yè)資源量。

6.根據(jù)權(quán)利要求1所述的業(yè)務(wù)消息的處理方法，其特征在于，所述構(gòu)建擴(kuò)縮容作業(yè)及其對(duì)應(yīng)的消息中間件的新消息主題的步驟包括：

獲取待處理的業(yè)務(wù)消息的處理狀態(tài)；

基于所述處理狀態(tài)確定處理所述業(yè)務(wù)消息的資源參數(shù)，根據(jù)所述資源參數(shù)構(gòu)建對(duì)應(yīng)的擴(kuò)縮容作業(yè)及其對(duì)應(yīng)的消息中間件的新消息主題。

7.根據(jù)權(quán)利要求3所述的業(yè)務(wù)消息的處理方法，其特征在于，所述在當(dāng)前作業(yè)對(duì)應(yīng)的消息中間件消息主題中的業(yè)務(wù)消息被處理完畢后的步驟之后，還包括：

釋放當(dāng)前作業(yè)及其對(duì)應(yīng)的消息中間件消息主題。

8.根據(jù)權(quán)利要求1所述的業(yè)務(wù)消息的處理方法，其特征在于，所述獲取遠(yuǎn)程配置模塊設(shè)置的業(yè)務(wù)配置信息的步驟之后，還包括：

解析所述業(yè)務(wù)配置信息，確定待處理的業(yè)務(wù)消息的消息標(biāo)識(shí)及其對(duì)應(yīng)的聚合邏輯；

所述利用所述新消息主題對(duì)應(yīng)的擴(kuò)縮容作業(yè)按照所述業(yè)務(wù)配置信息對(duì)所述業(yè)務(wù)消息進(jìn)行聚合處理的步驟包括：

利用所述新消息主題對(duì)應(yīng)的擴(kuò)縮容作業(yè)按照所述業(yè)務(wù)消息的消息標(biāo)識(shí)及其對(duì)應(yīng)的聚合邏輯進(jìn)行聚合處理。