[發明專利]負載均衡的裝置和方法

在審

• 申請號: 201610054629.3
• 申請日: 2016-01-26
• 公開（公告）號: CN106997310A
• 公開（公告）日: 2017-08-01
• 發明（設計）人: 劉杰;李旭良;單衛華
• 申請（專利權）人: 杭州華為數字技術有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 北京龍雙利達知識產權代理有限公司11329
• 代理人: 毛威,孫濤

技術領域

本發明涉及信息技術領域，并且更具體地，涉及一種負載均衡的裝置和方法。

背景技術

在計算系統中，對于大量存在的實時數據，例如股票交易數據、交通流量數據等，這類數據的實時性較強、數據量大，導致計算系統中各個節點之間負載經常會出現不均衡的情況。例如，在交通流量監測系統中，上下班高峰期時某個地區的車流量會大量增加，使得負責處理該地區流量計算的節點的負荷急速增加，而別的地區的節點相對比較空閑，從而導致交通流量監測系統中各個節點負載不均衡。

現有技術面對大量的實時數據時，只能通過類似重啟的操作對各個節點的資源進行重新分配和調整，嚴重影響了資源的利用率，效率較低。

發明內容

本發明實施例提供了一種負載均衡的裝置和方法，能夠更加合理的利用資源。

第一方面，提供了一種負載均衡的裝置，包括：檢測模塊，用于檢測處理時間信息和消息隊列信息，其中，該處理時間信息為計算系統中的至少兩個節點中的每個節點處理數據的時間的信息，該消息隊列信息為該至少兩個節點之間進行數據傳輸的消息隊列的信息；處理模塊，用于根據該檢測模塊檢測的該處理時間信息和該消息隊列信息生成該至少兩個節點中的每個節點的數據處理負荷的波動信息；線程管理模塊，用于根據該處理模塊生成的該波動信息調整該至少兩個節點中的每個節點處理數據的線程數目。

本發明實施例的負載均衡的裝置，通過檢測處理時間信息和消息隊列信息，根據該處理時間信息和消息隊列信息生成波動信息，能夠根據該波動信息對節點的線程數目進行動態調整，從而更加合理的利用資源。

結合第一方面，在第一種可能的實現方式中，該裝置還包括：

收集模塊，用于收集該處理模塊生成的該波動信息，得到第一歷史數據。

這里，收集模塊收集的該波動信息，可以是短周期內的波動信息，得到該短周期內的歷史數據。

結合第一方面的第一種可能的實現方式，在第二種可能的實現方式中，該處理模塊具體用于根據該收集模塊收集的該第一歷史數據、該處理時間信息和該消息隊列信息生成該波動信息。

處理模塊根據短周期內的歷史數據以及該處理時間信息和該消息隊列信息生成該波動信息。

結合第一方面的第一種可能的實現方式，在第三種可能的實現方式中，該裝置還包括：優化模塊，用于對該收集模塊收集的該第一歷史數據中的該波動信息按照預定周期進行優化，得到第二歷史數據；

該處理模塊具體用于根據該第二歷史數據、該處理時間信息和該消息隊列信息生成該波動信息。

這里，優化模塊對收集模塊收集的第一歷史數據中的該波動信息按照長周期進行優化，得到長周期內的歷史數據，處理模塊根據長周期內的歷史數據、該處理時間信息和該消息隊列信息生成該波動信息。

結合上述任一種可能的實現方式，在第四種可能的實現方式中，該檢測模塊包括第一檢測子模塊和第二檢測子模塊，該第一檢測子模塊用于檢測該處理時間信息，該第二檢測子模塊用于檢測該消息隊列信息。

檢測子模塊的具體形式可以是探針，第一檢測子模塊為處理時間探針，第二檢測子模塊為消息隊列探針。

第二方面，提供了一種計算系統，包括：至少兩個節點和第一方面或第一方面的任意可能的實現方式中該的負載均衡裝置，其中，該至少兩個節點中的每個節點能夠處理數據，該至少兩個節點之間存在進行數據傳輸的消息隊列。

第三方面，提供了一種負載均衡的裝置，該裝置包括：接收器、發送器、存儲器、處理器和總線系統。其中，該接收器、該發送器、該存儲器和該處理器通過該總線系統相連，該存儲器用于存儲指令，該處理器用于執行該存儲器存儲的指令，以控制接收器接收信號，并控制發送器發送信號，并且當該處理器執行該存儲器存儲的指令時，該執行使得該處理器執行第一方面或 第一方面的任意可能的實現方式中的系統的操作。

第四方面，提供了一種計算機可讀介質，用于存儲計算機程序，該計算機程序包括用于執行第一方面或第一方面的任意可能的實現方式中的指令。

附圖說明

為了更清楚地說明本發明實施例的技術方案，下面將對本發明實施例中所需要使用的附圖作簡單地介紹，顯而易見地，下面所描述的附圖僅僅是本發明的一些實施例，對于本領域普通技術人員來講，在不付出創造性勞動的前提下，還可以根據這些附圖獲得其他的附圖。

圖1是Storm系統的拓撲結構的示意圖。

圖2是根據本發明實施例的負載均衡裝置的示意圖。

圖3是根據本發明另一實施例的負載均衡裝置的示意圖。