[發(fā)明專利]基于分布式部署的數(shù)據(jù)推送方法、裝置、設備及存儲介質(zhì)

有效

• 申請?zhí)枺?/td>: 202011333562.X
• 申請日: 2020-11-24
• 公開（公告）號: CN112468573B
• 公開（公告）日: 2023-05-23
• 發(fā)明（設計）人: 費戰(zhàn)波;師文佼;王坤明;魏帥;閆洪明;王海豹;郭瑩
• 申請（專利權）人: 新天科技股份有限公司
• 主分類號: H04L67/12
• 分類號: H04L67/12;H04L67/1008;H04L67/55
• 代理公司: 北京超凡宏宇專利代理事務所(特殊普通合伙) 11463
• 代理人: 曹瑞敏

1.一種數(shù)據(jù)推送方法，其特征在于，應用于分布式系統(tǒng)中的數(shù)據(jù)轉(zhuǎn)發(fā)設備，所述分布式系統(tǒng)還包括：多個服務器，每個服務器與所述數(shù)據(jù)轉(zhuǎn)發(fā)設備通信連接，所述方法包括：

接收物聯(lián)網(wǎng)平臺發(fā)送的待推送數(shù)據(jù)，所述待推送數(shù)據(jù)包括：至少一個物聯(lián)網(wǎng)表的數(shù)據(jù)；

獲取所述多個服務器的運行狀態(tài)，其中，每個服務器的運行狀態(tài)包括：第一狀態(tài)數(shù)據(jù)，和第二狀態(tài)數(shù)據(jù)；其中，所述第一狀態(tài)數(shù)據(jù)包括：所述每個服務器的資源使用數(shù)據(jù)，所述第二狀態(tài)數(shù)據(jù)包括：所述每個服務器中處理操作隊列的長度；

根據(jù)所述多個服務器的所述第一狀態(tài)數(shù)據(jù)，從所述多個服務器中，確定至少一個待推送服務器；

根據(jù)每個待推送服務器的所述處理操作隊列的長度，計算所述每個待推送服務器的負載量；

根據(jù)所述至少一個待推送服務器的負載量，從所述至少一個待推送服務器中選擇負載量最小的服務器作為目標服務器；

將所述待推送數(shù)據(jù)推送至所述目標服務器。

2.根據(jù)權利要求1所述的方法，其特征在于，所述處理操作隊列包括：即時業(yè)務隊列，和，數(shù)據(jù)業(yè)務隊列；其中，所述即時業(yè)務隊列用于對數(shù)據(jù)庫的數(shù)據(jù)執(zhí)行更新操作，所述數(shù)據(jù)業(yè)務隊列用于執(zhí)行將上報數(shù)據(jù)存儲在數(shù)據(jù)庫中的存儲操作；

根據(jù)所述即時業(yè)務隊列的長度和所述數(shù)據(jù)業(yè)務隊列的長度，采用所述即時業(yè)務隊列的預設權值和所述數(shù)據(jù)業(yè)務隊列的預設權值，進行加權運算，得到所述每個服務器的負載量；

其中，所述即時業(yè)務隊列的預設權值和所述數(shù)據(jù)業(yè)務隊列的預設權值均為正值，且，所述即時業(yè)務隊列的預設權值大于所述數(shù)據(jù)業(yè)務隊列的預設權值。

3.根據(jù)權利要求2所述的方法，其特征在于，所述處理操作隊列還包括：待處理命令隊列，所述待處理命令隊列用于執(zhí)行命令響應；

根據(jù)所述即時業(yè)務隊列的長度、所述數(shù)據(jù)業(yè)務隊列的長度和所述待處理命令隊列的長度，采用所述即時業(yè)務隊列的預設權值、所述數(shù)據(jù)業(yè)務隊列的預設權值以及所述待處理命令隊列的預設權值，進行加權運算，得到所述每個服務器的負載量；

其中，所述待處理命令隊列的預設權值小于所述即時業(yè)務隊列的預設權值，但大于所述數(shù)據(jù)業(yè)務隊列的預設權值。

4.根據(jù)權利要求1所述的方法，其特征在于，所述第二狀態(tài)數(shù)據(jù)還包括：所述每個服務器中處理核的數(shù)量；

所述根據(jù)所述處理操作隊列的長度，計算所述每個服務器的負載量，包括：

根據(jù)所述處理操作隊列的長度和所述處理核的數(shù)量，采用所述處理操作隊列的預設權值和所述處理核的預設權值，進行加權運算，得到所述每個服務器的負載量；其中，所述處理核的預設權值為負值，所述處理操作隊列的預設權值為正值。

5.根據(jù)權利要求4所述的方法，其特征在于，所述第二狀態(tài)數(shù)據(jù)還包括：所述每個服務器的預設人工調(diào)配參數(shù)；

所述根據(jù)所述處理操作隊列的長度，計算所述每個服務器的負載量，包括：

根據(jù)所述處理操作隊列的長度、所述處理核的數(shù)量和所述預設人工調(diào)配參數(shù)，采用所述處理操作隊列的預設權值、所述處理核的預設權值和所述預設人工調(diào)配參數(shù)的預設權值，進行加權運算，得到所述每個服務器的負載量；其中，所述預設人工調(diào)配參數(shù)的預設權值為正值。

6.根據(jù)權利要求1所述的方法，其特征在于，所述第一狀態(tài)數(shù)據(jù)為所述每個服務器的處理器使用率；

所述根據(jù)所述多個服務器的所述第一狀態(tài)數(shù)據(jù)，從所述多個服務器中，確定至少一個待推送服務器，包括：

根據(jù)所述多個服務器的處理器使用率，從所述多個服務器中，確定處理器使用率小于或等于預設使用率的服務器為所述至少一個待推送服務器。

7.根據(jù)權利要求1-6中任一所述的方法，其特征在于，所述獲取多個服務器的運行狀態(tài)，包括：

調(diào)用所述每個服務器中負載量的應用程序通訊接口，獲取所述每個服務器的運行狀態(tài)。