[發明專利]業務監控方法、裝置和計算機設備

在審

• 申請號: 201611266539.7
• 申請日: 2016-12-31
• 公開（公告）號: CN106656863A
• 公開（公告）日: 2017-05-10
• 發明（設計）人: 曾江
• 申請（專利權）人: 廣東歐珀移動通信有限公司
• 主分類號: H04L12/863
• 分類號: H04L12/863;H04L29/08
• 代理公司: 廣州華進聯合專利商標代理有限公司44224
• 代理人: 方高明

1.一種業務監控方法，其特征在于，包括：

獲取用戶請求信息；

將所述用戶請求信息封裝為監控數據；

獲取與所述監控數據對應的分布式消息隊列的隊列編號，并將所述監控數據發送給分布式消息隊列集群中與所述隊列編號對應的分布式消息隊列進行存儲；

獲取線程標識對應的隊列編號，從所述分布式消息隊列集群中獲取與所述隊列編號對應的分布式消息隊列中的監控數據；

將與所述隊列編號對應的所述分布式消息隊列中的監控數據分配給所述線程標識對應的線程處理。

2.根據權利要求1所述的業務監控方法，其特征在于，所述用戶請求信息中包括用戶請求接收時刻，所述獲取與所述監控數據對應的分布式消息隊列的隊列編號包括：

獲取所述監控數據對應的用戶請求接收時刻和所述分布式消息隊列集群中分布式消息隊列的隊列數；

將所述用戶請求接收時刻轉換為時間戳；

根據所述時間戳和分布式消息隊列的隊列數獲取與所述監控數據對應的分布式消息隊列的隊列編號。

3.根據權利要求1所述的業務監控方法，其特征在于，所述從所述分布式消息隊列集群中獲取與所述隊列編號對應的分布式消息隊列中的監控數據包括：

根據預設的時間間隔從所述分布式消息隊列集群中獲取與所述隊列編號對應的分布式消息隊列中的監控數據。

4.根據權利要求1所述的業務監控方法，其特征在于，所述線程標識對應的線程中包括子線程；

所述將與所述隊列編號對應的所述分布式消息隊列中的監控數據分配給所述線程標識對應的線程處理包括：

獲取子線程標識對應的隊列編號；

將與所述子線程標識對應的隊列編號所對應的分布式消息隊列中的監控數據分配給所述子線程標識對應的子線程處理。

5.根據權利要求1所述的業務監控方法，其特征在于，所述方法還包括：

若檢測到新增分布式消息隊列和新增線程；

建立新增分布式消息隊列的隊列編號與新增線程的線程標識之間的對應關系。

6.一種業務監控裝置，其特征在于，包括：

獲取模塊，用于獲取用戶請求信息；

封裝模塊，用于將所述用戶請求信息封裝為監控數據；

數據存儲模塊，用于獲取與所述監控數據對應的分布式消息隊列的隊列編號，并將所述監控數據發送給分布式消息隊列集群中與所述隊列編號對應的分布式消息隊列進行存儲；

數據獲取模塊，用于獲取線程標識對應的隊列編號，從所述分布式消息隊列集群中獲取與所述隊列編號對應的分布式消息隊列中的監控數據；

分配模塊，用于將與所述隊列編號對應的所述分布式消息隊列中的監控數據分配給所述線程標識對應的線程處理。

7.根據權利要求6所述的業務監控裝置，其特征在于，所述用戶請求信息中包括用戶請求接收時刻；所述數據存儲模塊包括：

獲取單元，用于獲取所述監控數據對應的用戶請求接收時刻和所述分布式消息隊列集群中分布式消息隊列的隊列數；

轉換單元，用于將所述用戶請求接收時刻轉換為時間戳；

計算單元，用于根據所述時間戳和分布式消息隊列的隊列數獲取與所述監控數據對應的分布式消息隊列的隊列編號；

存儲單元，用于將所述監控數據發送給分布式消息隊列集群中與所述隊列編號對應的分布式消息隊列進行存儲。

8.根據權利要求6所述的業務監控裝置，其特征在于，所述數據獲取模塊還用于獲取線程標識對應的隊列編號，根據預設的時間間隔從所述分布式消息隊列集群中獲取與所述隊列編號對應的分布式消息隊列中的監控數據。

9.根據權利要求6所述的業務監控裝置，其特征在于，所述線程標識對應的線程中包括子線程；

所述分配模塊還用于獲取子線程標識對應的隊列編號；將與所述子線程標識對應的隊列編號所對應的分布式消息隊列中的監控數據分配給所述子線程標識對應的子線程處理。

10.根據權利要求6所述的業務監控裝置，其特征在于，所述裝置還包括：

對應模塊，用于若檢測到新增分布式消息隊列和新增線程；建立新增分布式消息隊列的隊列編號與新增線程的線程標識之間的對應關系。

11.一種計算機設備，包括存儲器，處理器及存儲在存儲器上并可在處理器上運行的計算機程序，其特征在于，所述處理器執行所述程序時實現以下步驟：

獲取用戶請求信息；

將所述用戶請求信息封裝為監控數據；

獲取與所述監控數據對應的分布式消息隊列的隊列編號，并將所述監控數據發送給分布式消息隊列集群中與所述隊列編號對應的分布式消息隊列進行存儲；

獲取線程標識對應的隊列編號，從所述分布式消息隊列集群中獲取與所述隊列編號對應的分布式消息隊列中的監控數據；

將與所述隊列編號對應的所述分布式消息隊列中的監控數據分配給所述線程標識對應的線程處理。