[發(fā)明專利]業(yè)務(wù)處理方法及裝置

有效

• 申請?zhí)枺?/td>: 201611150644.4
• 申請日: 2016-12-14
• 公開（公告）號: CN107741873B
• 公開（公告）日: 2020-06-02
• 發(fā)明（設(shè)計）人: 古樂樂
• 申請（專利權(quán)）人: 騰訊科技（深圳）有限公司
• 主分類號: G06F9/455
• 分類號: G06F9/455
• 代理公司: 深圳翼盛智成知識產(chǎn)權(quán)事務(wù)所(普通合伙) 44300
• 代理人: 黃威

本發(fā)明提供一種業(yè)務(wù)處理方法，其包括：在實(shí)際插槽集群中設(shè)置至少兩個虛擬插槽集群，其中虛擬插槽集群包括實(shí)際插槽集群中的至少一個節(jié)點(diǎn)下的至少一個插槽；接收業(yè)務(wù)邏輯任務(wù)，并根據(jù)業(yè)務(wù)邏輯任務(wù)的數(shù)據(jù)量，確定執(zhí)行業(yè)務(wù)邏輯任務(wù)的虛擬插槽集群；使用虛擬插槽集群執(zhí)行業(yè)務(wù)邏輯任務(wù)。本發(fā)明還提供一種業(yè)務(wù)處理裝置，本發(fā)明的業(yè)務(wù)處理方法及業(yè)務(wù)處理裝置根據(jù)業(yè)務(wù)邏輯任務(wù)的數(shù)據(jù)量，確定執(zhí)行業(yè)務(wù)邏輯任務(wù)的虛擬插槽集群，并可對虛擬插槽集群的插槽進(jìn)行擴(kuò)充處理；因此提升了業(yè)務(wù)處理裝置的插槽集群的擴(kuò)展能力，滿足了不同優(yōu)先級別的流數(shù)據(jù)業(yè)務(wù)的計算要求，且可實(shí)現(xiàn)不同用戶的流數(shù)據(jù)業(yè)務(wù)隔離。

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

本發(fā)明涉及互聯(lián)網(wǎng)領(lǐng)域，特別是涉及一種業(yè)務(wù)處理方法及裝置。

背景技術(shù)

Apache Storm是一種分布式實(shí)時計算系統(tǒng)，其可用于任何編程語言，該計算系統(tǒng)簡化了流數(shù)據(jù)業(yè)務(wù)的可靠處理，可實(shí)現(xiàn)實(shí)時對流數(shù)據(jù)業(yè)務(wù)進(jìn)行批量處理。

由于流數(shù)據(jù)業(yè)務(wù)具有不同的優(yōu)先級別，分布式實(shí)時計算系統(tǒng)一般通過設(shè)定相互隔離的插槽集群來處理不同優(yōu)先級別的流數(shù)據(jù)業(yè)務(wù)，以保證這些插槽集群上的流數(shù)據(jù)業(yè)務(wù)的隔離狀態(tài)。

但是現(xiàn)有的分布式實(shí)時計算系統(tǒng)的插槽集群的擴(kuò)展能力較差，無法根據(jù)流數(shù)據(jù)業(yè)務(wù)的需求資源設(shè)定插槽集群中的插槽數(shù)量。每個插槽集群的調(diào)度策略單一，不能滿足不同優(yōu)先級別的流數(shù)據(jù)業(yè)務(wù)的計算要求。同時如不同的用戶使用同一插槽集群中的插槽資源，無法實(shí)現(xiàn)不同用戶的流數(shù)據(jù)業(yè)務(wù)的隔離。

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

本發(fā)明實(shí)施例提供一種擴(kuò)展能力較強(qiáng)，可滿足不同優(yōu)先級別的流數(shù)據(jù)業(yè)務(wù)的計算要求以及可實(shí)現(xiàn)不同用戶的流數(shù)據(jù)業(yè)務(wù)隔離的業(yè)務(wù)處理方法及業(yè)務(wù)處理裝置；以解決現(xiàn)有的業(yè)務(wù)處理方法及業(yè)務(wù)處理裝置的插槽集群的擴(kuò)展能力較差、無法滿足不同優(yōu)先級別的流數(shù)據(jù)業(yè)務(wù)的計算要求以及無法實(shí)現(xiàn)不同用戶的流數(shù)據(jù)業(yè)務(wù)的隔離的技術(shù)問題。

本發(fā)明實(shí)施例提供一種業(yè)務(wù)處理方法，其包括：

在實(shí)際插槽集群中設(shè)置至少兩個虛擬插槽集群，其中所述虛擬插槽集群包括實(shí)際插槽集群中的至少一個節(jié)點(diǎn)下的至少一個插槽；

接收業(yè)務(wù)邏輯任務(wù)，并根據(jù)所述業(yè)務(wù)邏輯任務(wù)的數(shù)據(jù)量，確定執(zhí)行所述業(yè)務(wù)邏輯任務(wù)的虛擬插槽集群；以及

使用所述虛擬插槽集群執(zhí)行所述業(yè)務(wù)邏輯任務(wù)。

本發(fā)明實(shí)施例提供一種業(yè)務(wù)處理裝置，其包括：

虛擬插槽集群設(shè)置模塊，用于在實(shí)際插槽集群中設(shè)置至少兩個虛擬插槽集群，其中所述虛擬插槽集群包括實(shí)際插槽集群中的至少一個節(jié)點(diǎn)下的至少一個插槽；

虛擬插槽集群確定模塊，用于接收業(yè)務(wù)邏輯任務(wù)，并根據(jù)所述業(yè)務(wù)邏輯任務(wù)的數(shù)據(jù)量，確定執(zhí)行所述業(yè)務(wù)邏輯任務(wù)的虛擬插槽集群；以及

任務(wù)執(zhí)行模塊，用于使用所述虛擬插槽集群執(zhí)行所述業(yè)務(wù)邏輯任務(wù)。

相較于現(xiàn)有技術(shù)，本發(fā)明的業(yè)務(wù)處理方法及業(yè)務(wù)處理裝置根據(jù)業(yè)務(wù)邏輯任務(wù)的數(shù)據(jù)量，確定執(zhí)行業(yè)務(wù)邏輯任務(wù)的虛擬插槽集群，并可對虛擬插槽集群的插槽進(jìn)行擴(kuò)充處理；因此提升了業(yè)務(wù)處理裝置的插槽集群的擴(kuò)展能力，滿足了不同優(yōu)先級別的流數(shù)據(jù)業(yè)務(wù)的計算要求，且可實(shí)現(xiàn)不同用戶的流數(shù)據(jù)業(yè)務(wù)隔離；解決了現(xiàn)有的業(yè)務(wù)處理方法及業(yè)務(wù)處理裝置的插槽集群的擴(kuò)展能力較差、無法滿足不同優(yōu)先級別的流數(shù)據(jù)業(yè)務(wù)的計算要求以及無法實(shí)現(xiàn)不同用戶的流數(shù)據(jù)業(yè)務(wù)的隔離的技術(shù)問題。

附圖說明

圖1為本發(fā)明的業(yè)務(wù)處理方法的第一優(yōu)選實(shí)施例的流程圖；

圖2為本發(fā)明的業(yè)務(wù)處理方法的第二優(yōu)選實(shí)施例的流程圖；

圖3為本發(fā)明的業(yè)務(wù)處理方法的第二優(yōu)選實(shí)施例的步驟203的流程圖；

圖4為本發(fā)明的業(yè)務(wù)處理方法的第二優(yōu)選實(shí)施例的步驟205的流程圖；