[發(fā)明專利]一種壓力測(cè)試的方法、裝置及計(jì)算機(jī)系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201911087910.7
• 申請(qǐng)日: 2019-11-08
• 公開（公告）號(hào): CN110971483B
• 公開（公告）日: 2021-11-09
• 發(fā)明（設(shè)計(jì)）人: 邱園元;吳健;賈晨浩;施斌;孫遷
• 申請(qǐng)（專利權(quán)）人: 蘇寧云計(jì)算有限公司
• 主分類號(hào): H04L12/26
• 分類號(hào): H04L12/26;H04L12/24
• 代理公司: 北京市萬慧達(dá)律師事務(wù)所 11111
• 代理人: 段曉玲

1.一種壓力測(cè)試的方法，其特征在于，所述方法包括：

啟動(dòng)待測(cè)試實(shí)時(shí)流處理系統(tǒng)以便所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)讀取測(cè)試流數(shù)據(jù)進(jìn)行處理；

讀取預(yù)先配置的任務(wù)參數(shù)，根據(jù)所述任務(wù)參數(shù)自動(dòng)收集所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)處理所述測(cè)試流數(shù)據(jù)過程產(chǎn)生的性能參數(shù)；

對(duì)所述性能參數(shù)進(jìn)行分析處理，獲得所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)的性能分析結(jié)果并進(jìn)行可視化顯示，

其中，所述讀取預(yù)先配置的任務(wù)參數(shù)，根據(jù)所述任務(wù)參數(shù)自動(dòng)收集所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)處理所述測(cè)試流數(shù)據(jù)過程產(chǎn)生的性能參數(shù)包括：

讀取預(yù)先配置的任務(wù)參數(shù)，獲得預(yù)設(shè)的打點(diǎn)周期及打點(diǎn)次數(shù)；

按照所述打點(diǎn)周期和打點(diǎn)次數(shù)在每一個(gè)打點(diǎn)時(shí)刻對(duì)所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)已處理的數(shù)據(jù)量進(jìn)行打點(diǎn)收集；

所述收集所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)處理所述測(cè)試流數(shù)據(jù)過程產(chǎn)生的性能參數(shù)，對(duì)所述性能參數(shù)進(jìn)行分析處理包括：

根據(jù)收集的所述已處理的數(shù)據(jù)量計(jì)算獲得所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)每個(gè)打點(diǎn)周期內(nèi)的數(shù)據(jù)處理量；

根據(jù)所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)每個(gè)打點(diǎn)周期內(nèi)的數(shù)據(jù)處理量及預(yù)設(shè)的打點(diǎn)周期的時(shí)長(zhǎng)，計(jì)算獲得所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)每個(gè)打點(diǎn)周期的數(shù)據(jù)處理速度。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述測(cè)試流數(shù)據(jù)為測(cè)試過程中實(shí)時(shí)配置的實(shí)時(shí)流數(shù)據(jù)。

3.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)為分布式實(shí)時(shí)流處理系統(tǒng)。

4.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，所述啟動(dòng)待測(cè)試實(shí)時(shí)流系統(tǒng)以便所述待測(cè)試實(shí)時(shí)流系統(tǒng)讀取測(cè)試流數(shù)據(jù)進(jìn)行處理包括：

啟動(dòng)Storm實(shí)時(shí)流處理系統(tǒng)以便所述Storm實(shí)時(shí)流處理系統(tǒng)從Kafka消息隊(duì)列中讀取測(cè)試流數(shù)據(jù)進(jìn)行分布式實(shí)時(shí)流處理。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述對(duì)所述性能參數(shù)進(jìn)行分析處理，獲得所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)的性能分析結(jié)果還包括：

計(jì)算所有所述打點(diǎn)周期的數(shù)據(jù)處理速度的平均值，獲得所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)的平均數(shù)據(jù)處理速度。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，在獲得所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)的平均數(shù)據(jù)處理速度后，所述方法還包括：

計(jì)算所述每個(gè)打點(diǎn)周期的數(shù)據(jù)處理速度與所述平均數(shù)據(jù)處理速度的差值的絕對(duì)值，

當(dāng)任一打點(diǎn)周期的數(shù)據(jù)處理速度與所述平均數(shù)據(jù)處理速度的差值的絕對(duì)值超過預(yù)設(shè)閾值時(shí)，

發(fā)出異常指示信號(hào)并將所述異常指示信號(hào)進(jìn)行可視化顯示。

7.一種壓力測(cè)試裝置，其特征在于，所述裝置包括：

計(jì)算模塊，用于啟動(dòng)待測(cè)試實(shí)時(shí)流處理系統(tǒng)以便所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)讀取測(cè)試流數(shù)據(jù)進(jìn)行處理；

執(zhí)行模塊，用于讀取預(yù)先配置的任務(wù)參數(shù)，根據(jù)所述任務(wù)參數(shù)自動(dòng)收集所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)處理所述測(cè)試流數(shù)據(jù)過程產(chǎn)生的性能參數(shù)；

處理模塊，用于對(duì)所述性能參數(shù)進(jìn)行分析處理，獲得所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)的性能分析結(jié)果并進(jìn)行可視化顯示，

所述執(zhí)行模塊還用于讀取預(yù)先配置的任務(wù)參數(shù)，獲得預(yù)設(shè)的打點(diǎn)周期及打點(diǎn)次數(shù)；按照所述打點(diǎn)周期和打點(diǎn)次數(shù)在每一個(gè)打點(diǎn)時(shí)刻對(duì)所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)已處理的數(shù)據(jù)量進(jìn)行打點(diǎn)收集；

所述處理模塊還用于根據(jù)收集的所述已處理的數(shù)據(jù)量計(jì)算獲得所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)每個(gè)打點(diǎn)周期內(nèi)的數(shù)據(jù)處理量；根據(jù)所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)每個(gè)打點(diǎn)周期內(nèi)的數(shù)據(jù)處理量及預(yù)設(shè)的打點(diǎn)周期的時(shí)長(zhǎng)，計(jì)算獲得所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)每個(gè)打點(diǎn)周期的數(shù)據(jù)處理速度。

8.根據(jù)權(quán)利要求7所述的壓力測(cè)試裝置，其特征在于，所述裝置還包括：

報(bào)警模塊，用于當(dāng)任一打點(diǎn)周期的數(shù)據(jù)處理速度與平均數(shù)據(jù)處理速度的差值的絕對(duì)值超過預(yù)設(shè)閾值時(shí)，發(fā)出異常指示信號(hào)并將所述異常指示信號(hào)進(jìn)行可視化顯示。

9.一種計(jì)算機(jī)系統(tǒng)，其特征在于，所述系統(tǒng)包括：

一個(gè)或多個(gè)處理器；

以及與所述一個(gè)或多個(gè)處理器關(guān)聯(lián)的存儲(chǔ)器，所述存儲(chǔ)器用于存儲(chǔ)程序指令,所述程序指令在被所述一個(gè)或多個(gè)處理器讀取執(zhí)行時(shí)，執(zhí)行如下操作：

啟動(dòng)待測(cè)試實(shí)時(shí)流處理系統(tǒng)以便所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)讀取測(cè)試流數(shù)據(jù)進(jìn)行處理；

讀取預(yù)先配置的任務(wù)參數(shù)，根據(jù)所述任務(wù)參數(shù)自動(dòng)收集所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)處理所述測(cè)試流數(shù)據(jù)過程產(chǎn)生的性能參數(shù)；

對(duì)所述性能參數(shù)進(jìn)行分析處理，獲得所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)的性能分析結(jié)果并進(jìn)行可視化顯示，

其中，所述讀取預(yù)先配置的任務(wù)參數(shù)，根據(jù)所述任務(wù)參數(shù)自動(dòng)收集所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)處理所述測(cè)試流數(shù)據(jù)過程產(chǎn)生的性能參數(shù)包括：

讀取預(yù)先配置的任務(wù)參數(shù)，獲得預(yù)設(shè)的打點(diǎn)周期及打點(diǎn)次數(shù)；

按照所述打點(diǎn)周期和打點(diǎn)次數(shù)在每一個(gè)打點(diǎn)時(shí)刻對(duì)所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)已處理的數(shù)據(jù)量進(jìn)行打點(diǎn)收集；

所述收集所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)處理所述測(cè)試流數(shù)據(jù)過程產(chǎn)生的性能參數(shù)，對(duì)所述性能參數(shù)進(jìn)行分析處理包括：

根據(jù)收集的所述已處理的數(shù)據(jù)量計(jì)算獲得所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)每個(gè)打點(diǎn)周期內(nèi)的數(shù)據(jù)處理量；

根據(jù)所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)每個(gè)打點(diǎn)周期內(nèi)的數(shù)據(jù)處理量及預(yù)設(shè)的打點(diǎn)周期的時(shí)長(zhǎng)，計(jì)算獲得所述待測(cè)試實(shí)時(shí)流處理系統(tǒng)每個(gè)打點(diǎn)周期的數(shù)據(jù)處理速度。