[發明專利]一種負載均衡方法、裝置和批處理系統

在審

• 申請號: 202210493569.0
• 申請日: 2022-05-07
• 公開（公告）號: CN114791852A
• 公開（公告）日: 2022-07-26
• 發明（設計）人: 鄭學友;方志悅
• 申請（專利權）人: 中國銀行股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 錢灣灣

本申請公開了一種負載均衡方法、裝置和批處理系統，可應用于分布式領域或金融領域。所述方法包括：獲取各批處理節點的負載信息，所述各批處理節點的負載信息包括：各批處理節點的當前負載量；根據所述各批處理節點的當前負載量，確定所述各批處理節點的當前負載量中的最大值；確定所述各批處理節點中的當前負載量低于所述最大值的至少一個批處理節點為目標節點；將任務分配給所述目標節點。該方法根據各批處理節點的當前負載量合理的進行任務分配，實現了各批處理節點間處理任務量均衡。

技術領域

本申請涉及分布式領域，特別是涉及一種負載均衡方法、裝置和批處理系統。

背景技術

隨著計算機技術的發展，許多繁瑣但單調的工作由計算機取代人工處理，企業在面對成百上千個任務時，可以使用多個批處理節點(如批處理服務器)共同對任務進行批量處理。

對于成百上千個任務，服務器對每個任務進行處理的時長各不相同，且處理時長不固定，無法預測針對每個任務的處理時長。在任務分配給多個批處理節點的情況下，容易出現各批處理節點間處理的任務量(負載)不均衡的情況，例如，某次將批處理任務均勻分配給各個批處理節點，其中一些節點處理任務花費的時間都很長，另一些節點處理任務花費的時間都很短，一段時間后，一些節點的當前負載量(即節點正在處理和等待處理任務量)多，另一些節點的當前負載量少。此時，再一次進行批處理任務分配時仍采用均勻分配給各個批處理節點的方式，那么就會導致各批處理節點間處理任務量不均衡的問題。

因此，上述對任務的處理方式中，容易出現各批處理節點間負載不均衡的情況，無法發揮多個批處理節點共同對任務進行批量的處理的性能優勢。

發明內容

基于上述問題，本申請提供了一種負載均衡方法、裝置和批處理系統，以實現各批處理節點間處理任務量均衡。

本申請公開了如下技術方案：

本申請第一方面提供一種負載均衡方法，包括：

獲取各批處理節點的負載信息，所述各批處理節點的負載信息包括：各批處理節點的當前負載量；

根據所述各批處理節點的當前負載量，確定所述各批處理節點的當前負載量中的最大值；確定所述各批處理節點中的當前負載量低于所述最大值的至少一個批處理節點為目標節點；

將任務分配給所述目標節點。

在一個可能的實現方式中，所述確定所述各批處理節點中的當前負載量低于所述最大值的至少一個批處理節點為目標節點，包括：

將各批處理節點的當前負載量進行排序，得到排序結果；

根據所述排序結果，確定所述各批處理節點中的當前負載量低于所述最大值的至少一個批處理節點為目標節點。

在一個可能的實現方式中，所述各批處理節點的負載信息還包括：各批處理節點的最高負載量；

所述根據所述排序結果，確定所述各批處理節點中的當前負載量低于所述最大值的至少一個批處理節點為目標節點包括：

根據所述排序結果，確定所述各批處理節點中的當前負載量低于所述最大值的、且當前負載量小于對應批處理節點的最高負載量的至少一個批處理節點為目標節點。

在一個可能的實現方式中，所述方法還包括：在所述目標節點接受任務后，更新的當前負載量。

在一個可能的實現方式中，所述方法還包括：在每個批處理節點每次處理完任務后，更新的對應的當前負載量。

在一個可能的實現方式中，所述將任務分配給所述目標節點，包括：

根據所述目標節點的地址，將處理任務分配給所述目標節點。

本申請第二方面提供一種負載均衡裝置，包括：