[發(fā)明專利]RocketMQ內(nèi)存監(jiān)控方法、裝置、電子設(shè)備及存儲介質(zhì)

有效

• 申請?zhí)枺?/td>: 201811537778.0
• 申請日: 2018-12-15
• 公開（公告）號: CN109828885B
• 公開（公告）日: 2023-02-07
• 發(fā)明（設(shè)計）人: 陳東杰
• 申請（專利權(quán)）人: 中國平安人壽保險股份有限公司
• 主分類號: G06F11/30
• 分類號: G06F11/30
• 代理公司: 深圳市賽恩倍吉知識產(chǎn)權(quán)代理有限公司 44334
• 代理人: 周志偉

1.一種RocketMQ內(nèi)存監(jiān)控方法，其特征在于，所述方法包括：

當(dāng)接收到RocketMQ內(nèi)存監(jiān)控指令時，檢測RocketMQ的運行狀態(tài)；

當(dāng)所述運行狀態(tài)為可用狀態(tài)時，采用PS命令，從所有運行的進(jìn)程中調(diào)取所述RocketMQ的所有進(jìn)程信息，結(jié)合第一指定關(guān)鍵字，從所述所有進(jìn)程信息中獲取RocketMQ進(jìn)程的進(jìn)程標(biāo)識符PID；

結(jié)合所述PID，采用JMAP命令調(diào)取具有特定PID的進(jìn)程的堆棧信息；

結(jié)合第二指定關(guān)鍵字，從所述堆棧信息中獲取所述RocketMQ的已使用內(nèi)存及配置內(nèi)存，所述第二指定關(guān)鍵字是所述RocketMQ腳本中的參數(shù)名稱或者后綴；

根據(jù)所述已使用內(nèi)存及所述配置內(nèi)存，確定所述RocketMQ的當(dāng)前內(nèi)存使用率；

保存并展示所述當(dāng)前內(nèi)存使用率；

獲取上一個配置周期的初始內(nèi)存使用率；

計算所述當(dāng)前內(nèi)存使用率與所述初始內(nèi)存使用率的差值；

計算所述差值與所述初始內(nèi)存使用率的比值；

當(dāng)所述比值大于或者等于第二配置值時，發(fā)出警報。

2.如權(quán)利要求1所述的RocketMQ內(nèi)存監(jiān)控方法，其特征在于，所述第一指定關(guān)鍵字為NamesrvStartup和BrokerStartup。

3.如權(quán)利要求1所述的RocketMQ內(nèi)存監(jiān)控方法，其特征在于，所述堆棧信息包括以下一種或者多種的組合：

已使用內(nèi)存、配置內(nèi)存、未使用內(nèi)存、實例個數(shù)、內(nèi)存配置方式。

4.如權(quán)利要求1所述的RocketMQ內(nèi)存監(jiān)控方法，其特征在于，所述結(jié)合第二指定關(guān)鍵字，從所述堆棧信息中獲取已使用內(nèi)存及配置內(nèi)存包括：

結(jié)合所述第二指定關(guān)鍵字中的Space及used，從所述堆棧信息中獲取已使用內(nèi)存；

結(jié)合所述第二指定關(guān)鍵字中的MaxHeapSize，從所述堆棧信息中獲取配置內(nèi)存。

5.如權(quán)利要求1所述的RocketMQ內(nèi)存監(jiān)控方法，其特征在于，所述根據(jù)所述已使用內(nèi)存及所述配置內(nèi)存，確定所述RocketMQ的當(dāng)前內(nèi)存使用率包括：

計算所述已使用內(nèi)存與所述配置內(nèi)存的比值；

根據(jù)所述比值，確定所述RocketMQ的當(dāng)前內(nèi)存使用率。

6.如權(quán)利要求1所述的RocketMQ內(nèi)存監(jiān)控方法，其特征在于，所述方法還包括：

當(dāng)所述當(dāng)前內(nèi)存使用率大于或者等于第一配置值時，發(fā)出警報。

7.一種RocketMQ內(nèi)存監(jiān)控裝置，其特征在于，所述裝置包括：

檢測單元，用于當(dāng)接收到RocketMQ內(nèi)存監(jiān)控指令時，檢測RocketMQ的運行狀態(tài)；

獲取單元，用于當(dāng)所述運行狀態(tài)為可用狀態(tài)時，采用PS命令，從所有運行的進(jìn)程中調(diào)取所述RocketMQ的所有進(jìn)程信息，結(jié)合第一指定關(guān)鍵字，從所述所有進(jìn)程信息中獲取RocketMQ進(jìn)程的進(jìn)程標(biāo)識符PID；

調(diào)出單元，用于結(jié)合所述PID，采用JMAP命令調(diào)取具有特定PID的進(jìn)程的堆棧信息；

所述獲取單元，還用于結(jié)合第二指定關(guān)鍵字，從所述堆棧信息中獲取所述RocketMQ的已使用內(nèi)存及配置內(nèi)存，所述第二指定關(guān)鍵字是所述RocketMQ腳本中的參數(shù)名稱或者后綴；

確定單元，用于根據(jù)所述已使用內(nèi)存及所述配置內(nèi)存，確定所述RocketMQ的當(dāng)前內(nèi)存使用率；

展示單元，用于保存并展示所述當(dāng)前內(nèi)存使用率；

所述獲取單元，還用于獲取上一個配置周期的初始內(nèi)存使用率；

計算單元，用于計算所述當(dāng)前內(nèi)存使用率與所述初始內(nèi)存使用率的差值；

所述計算單元，還用于計算所述差值與所述初始內(nèi)存使用率的比值；

發(fā)出單元，用于當(dāng)所述比值大于或者等于第二配置值時，發(fā)出警報。

8.一種電子設(shè)備，其特征在于，所述電子設(shè)備包括：

存儲器，存儲至少一個指令；及

處理器，執(zhí)行所述存儲器中存儲的指令以實現(xiàn)如權(quán)利要求1至6中任意一項所述的RocketMQ內(nèi)存監(jiān)控方法。

9.一種計算機(jī)可讀存儲介質(zhì)，其特征在于：所述計算機(jī)可讀存儲介質(zhì)中存儲有至少一個指令，所述至少一個指令被電子設(shè)備中的處理器執(zhí)行以實現(xiàn)如權(quán)利要求1至6中任意一項所述的RocketMQ內(nèi)存監(jiān)控方法。