[發明專利]實現全局流控的方法及裝置

有效

• 申請號: 202010165359.X
• 申請日: 2020-03-11
• 公開（公告）號: CN111404828B
• 公開（公告）日: 2023-04-28
• 發明（設計）人: 劉雪晶;翁曉俊;袁一
• 申請（專利權）人: 中國工商銀行股份有限公司
• 主分類號: H04L47/125
• 分類號: H04L47/125;H04L67/1008;H04L41/0803;G06F16/22;G06F16/27
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 王濤;湯在彥

本發明公開了一種實現全局流控的方法及裝置，該方法包括：接收上層應用發送的請求；獲取通過Apollo配置中心配置的所述上層應用的所述請求的全局限額閾值；若本地配額庫存小于所述請求的記錄數，訪問HBase數據庫獲取配額批次；若本地配額庫存與所述配額批次之和小于等于所述全局限額閾值且大于或等于所述請求的記錄數，響應所述請求。本發明提供了一種靈活部署的全局流控方案，使分布式系統中可以同時保障服務穩定性和服務高可用，緩解了通過橫向增加設備量帶來的成本問題。

技術領域

本發明涉及互聯網大數據技術領域，具體而言，涉及一種實現全局流控的方法及裝置。

背景技術

隨著信息技術的高速發展，包括文字、圖像、視頻等結構化、半結構化數據實現指數級增長。傳統數據庫很難存儲、分析這些數據的內容，所以業界一般使用Hadoop生態系統等大數據技術進行業務處理。基于Hadoop生態系統搭建一個在線業務平臺時，需考慮滿足大流量、高并發、低成本等要求。同時，為了整個在線業務平臺的穩定，防止單租戶的大流量壓垮平臺，我們需要通過增加硬件設備的方法增大系統容量，降低系統風險。但隨著業務量的進一步增大，這種方式顯著地增加了運行成本，為了避免無止境膨脹的物理機器，對接入平臺的子系統或者子應用進行限流和服務降級則十分必要。

在分布式系統中實現全局流控，即需要保障限流服務的原子化。每個提供服務的應用服務器都可以進行限流，但由于負載均衡，各應用節點壓力不同，限流的程度無法控制，無法達到全局流控的理想效果。如何在保障對外界提供服務的前提下實現一種靈活配置的全局流控是目前亟需解決的問題。

發明內容

本發明為了解決上述背景技術中的至少一個技術問題，提出了一種實現全局流控的方法及裝置。

為了實現上述目的，根據本發明的一個方面，提供了一種實現全局流控的方法，該方法包括：

接收上層應用發送的請求；

獲取通過Apollo配置中心配置的所述上層應用的所述請求的全局限額閾值；

若本地配額庫存小于所述請求的記錄數，訪問HBase數據庫獲取配額批次；

若本地配額庫存與所述配額批次之和小于等于所述全局限額閾值且大于或等于所述請求的記錄數，響應所述請求。

可選的，該實現全局流控的方法還包括：

若本地配額庫存與所述配額批次之和大于所述全局限額閾值，休眠到下一個限額時間點重新處理所述請求。

可選的，該實現全局流控的方法還包括：

在每個限額時間點將本地配額庫存清零。

可選的，該實現全局流控的方法還包括：

若本地配額庫存大于或等于所述請求的記錄數，響應所述請求并從所述本地配額庫存中扣除所述請求的記錄數。

可選的，該實現全局流控的方法還包括：

通過所述Apollo配置中心配置各上層應用的各請求類型的全局限額閾值，并通過熱發布的方法將所述全局限額閾值發送到本地。

可選的，該實現全局流控的方法還包括：

實時記錄所述上層應用的請求數據，并將所述請求數據發送到所述HBase數據庫中預設的全局流控表中進行存儲。

可選的，所述Apollo配置中心根據所述全局流控表配置各上層應用的各請求類型的全局限額閾值。

為了實現上述目的，根據本發明的另一方面，提供了一種實現全局流控的裝置，該裝置包括：

請求接收單元，用于接收上層應用發送的請求；