[發明專利]一種業務數據處理方法及裝置

有效

• 申請號: 201711205491.3
• 申請日: 2017-11-27
• 公開（公告）號: CN108134814B
• 公開（公告）日: 2020-12-22
• 發明（設計）人: 黨朝欣
• 申請（專利權）人: 海爾優家智能科技（北京）有限公司;青島海爾科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/26
• 代理公司: 工業和信息化部電子專利中心 11010
• 代理人: 羅丹

1.一種業務數據處理方法，其特征在于，包括：

針對消費者端的任一業務處理單元，檢測代理端中與所述業務處理單元對應的訂閱消息隊列中的消息數量，其中，每一個所述業務處理單元都對應一個或多個訂閱消息隊列，所述業務處理單元用于處理所述訂閱消息隊列中的消息；

至少根據檢測到的所述消息數量判斷是否需要調整所述業務處理單元的業務處理能力，若是，則調整所述業務處理單元的業務處理能力；

所述檢測代理端中與所述業務處理單元對應的訂閱消息隊列中的消息數量，包括：

按照設定的檢測周期檢測代理端中與所述業務處理單元對應的訂閱消息隊列中的消息數量；

所述根據檢測到的所述消息數量判斷是否需要調整所述業務處理單元的業務處理能力，包括：

在第一設定時長內，若檢測到的所述消息數量持續大于或者持續小于所述業務處理單元當前所使用的線程數量，則判定需要調整所述業務處理單元的業務處理能力；所述第一設定時長大于所述設定的檢測周期；

所述方法，還包括：在檢測代理端中與所述業務處理單元對應的訂閱消息隊列中的消息數量之前，在本地內存中加載配置文件；所述配置文件中設定有所述業務處理單元使用線程的數量范圍；

所述調整所述業務處理單元的業務處理能力，包括：

若檢測到的所述消息數量持續大于所述業務處理單元當前所使用的線程數量，擴展所述業務處理單元使用的線程數量，直到所述業務處理單元使用的線程數量等于所述消息數量為止，其中，所述業務處理單元使用的線程數量的上限為所述數量范圍的最大值；

若檢測到的所述消息數量持續小于所述業務處理單元當前所使用的線程數量，收縮所述業務處理單元使用的線程數量，直到所述業務處理單元使用的線程數量等于所述消息數量為止，其中，所述業務處理單元使用的線程數量的下限為所述數量范圍的最小值。

2.根據權利要求1所述的業務數據處理方法，其特征在于，設所述業務處理單元使用一臺服務器時在第二設定時長內處理消息數量上限為M，M為正整數；所述配置文件中設定有所述業務處理單元使用的服務器數量上限N，N為正整數；

所述調整所述業務處理單元的業務處理能力，還包括：

若在第一設定時長內檢測到的所述消息數量增長量大于等于n個M，n為正整數，則以N為上限，為所述業務處理單元擴展使用n+1臺服務器；

若在第一設定時長內檢測到的所述消息數量減少量大于等于n個M，則以N為上限，為所述業務處理單元縮減使用n臺服務器。

3.根據權利要求1所述的業務數據處理方法，其特征在于，所述方法，還包括：在至少根據檢測到的所述消息數量判斷是否需要調整所述業務處理單元的業務處理能力之前，檢測所述業務處理單元使用的服務器的負載；

至少根據檢測到的所述消息數量判斷是否需要調整所述業務處理單元的業務處理能力包括：根據檢測到的所述消息數量以及所述業務處理單元使用的服務器的負載判斷是否需要調整所述業務處理單元的業務處理能力，若是，則調整所述業務處理單元的業務處理能力。

4.根據權利要求3所述的業務數據處理方法，其特征在于，所述根據檢測到的所述消息數量以及所述業務處理單元使用的服務器的負載判斷是否需要調整所述業務處理單元的業務處理能力，包括：

步驟A1：按照設定的檢測周期檢測所述消息數量以及所述業務處理單元使用的服務器的負載，若在第一設定時長內檢測到的所述消息數量持續大于所述業務處理單元當前所使用的線程數量或者在第一設定時長內檢測到的所述業務處理單元使用的至少一臺服務器的負載大于設定的高負載閾值，則執行步驟A2；若在第一設定時長內檢測到的所述消息數量持續小于所述業務處理單元當前所使用的線程數量且在第一設定時長內檢測到的所述業務處理單元使用的至少一臺服務器的負載持續小于設定的低負載閾值，則執行步驟A3；若在第一設定時長內的檢測結果不符合前述情況，則重復執行步驟A1；

步驟A2：擴展所述業務處理單元的業務處理能力，跳轉步驟A1；

步驟A3：收縮所述業務處理單元的業務處理能力，跳轉步驟A1。