[發(fā)明專利]實現(xiàn)全局流控的方法及裝置

有效

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

1.一種實現(xiàn)全局流控的方法，其特征在于，應(yīng)用于應(yīng)用服務(wù)器，所述方法包括：

接收上層應(yīng)用發(fā)送的請求；

獲取通過Apollo配置中心配置的所述上層應(yīng)用的所述請求的全局限額閾值，其中，預(yù)先在所述Apollo配置中心配置各上層應(yīng)用的各請求類型的全局限額閾值，所述Apollo配置中心具體根據(jù)HBase數(shù)據(jù)庫中的全局流控表配置所述全局限額閾值，并通過熱發(fā)布的方法將所述全局限額閾值發(fā)送到所述應(yīng)用服務(wù)器，所述應(yīng)用服務(wù)器每隔固定時間向所述全局流控表中批量寫入未來一段時間內(nèi)每個上層應(yīng)用的所有的請求數(shù)據(jù)記錄；

若本地配額庫存小于所述請求的記錄數(shù)，訪問HBase數(shù)據(jù)庫獲取配額批次，其中，所述應(yīng)用服務(wù)器通過發(fā)送當(dāng)前時間戳加上上層應(yīng)用名稱訪問所述HBase數(shù)據(jù)庫來申請所述配額批次，所述HBase數(shù)據(jù)庫通過申請后向應(yīng)用服務(wù)器發(fā)送通知信息，并將該筆申請記錄在所述全局流控表中；

若本地配額庫存與所述配額批次之和小于等于所述全局限額閾值且大于或等于所述請求的記錄數(shù)，響應(yīng)所述請求，其中，所述應(yīng)用服務(wù)器周期性的初始化所述本地配額庫存，每個周期的開始時間為限額時間點，在每個所述限額時間點所述應(yīng)用服務(wù)器會將所述本地配額庫存清零。

2.根據(jù)權(quán)利要求1所述的實現(xiàn)全局流控的方法，其特征在于，還包括：

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

3.根據(jù)權(quán)利要求1所述的實現(xiàn)全局流控的方法，其特征在于，還包括：

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

4.根據(jù)權(quán)利要求1所述的實現(xiàn)全局流控的方法，其特征在于，還包括：

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

5.根據(jù)權(quán)利要求1所述的實現(xiàn)全局流控的方法，其特征在于，還包括：

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

6.根據(jù)權(quán)利要求1所述的實現(xiàn)全局流控的方法，其特征在于，還包括：

實時記錄所述上層應(yīng)用的請求數(shù)據(jù)，并將所述請求數(shù)據(jù)發(fā)送到所述HBase數(shù)據(jù)庫中預(yù)設(shè)的全局流控表中進(jìn)行存儲。

7.一種實現(xiàn)全局流控的裝置，其特征在于，應(yīng)用于應(yīng)用服務(wù)器，所述裝置包括：

請求接收單元，用于接收上層應(yīng)用發(fā)送的請求；

全局限額閾值獲取單元，用于獲取通過Apollo配置中心配置的所述上層應(yīng)用的所述請求的全局限額閾值，其中，預(yù)先在所述Apollo配置中心配置各上層應(yīng)用的各請求類型的全局限額閾值，所述Apollo配置中心具體根據(jù)HBase數(shù)據(jù)庫中的全局流控表配置所述全局限額閾值，并通過熱發(fā)布的方法將所述全局限額閾值發(fā)送到所述應(yīng)用服務(wù)器，所述應(yīng)用服務(wù)器每隔固定時間向所述全局流控表中批量寫入未來一段時間內(nèi)每個上層應(yīng)用的所有的請求數(shù)據(jù)記錄；

本地配額庫存單元，用于在本地配額庫存小于所述請求的記錄數(shù)時訪問HBase數(shù)據(jù)庫獲取配額批次，其中，所述應(yīng)用服務(wù)器通過發(fā)送當(dāng)前時間戳加上上層應(yīng)用名稱訪問所述HBase數(shù)據(jù)庫來申請所述配額批次，所述HBase數(shù)據(jù)庫通過申請后向應(yīng)用服務(wù)器發(fā)送通知信息，并將該筆申請記錄在所述全局流控表中；

請求響應(yīng)單元，用于在本地配額庫存與所述配額批次之和小于等于所述全局限額閾值且大于或等于所述請求的記錄數(shù)時響應(yīng)所述請求，其中，所述應(yīng)用服務(wù)器周期性的初始化所述本地配額庫存，每個周期的開始時間為限額時間點，在每個所述限額時間點所述應(yīng)用服務(wù)器會將所述本地配額庫存清零。

8.根據(jù)權(quán)利要求7所述的實現(xiàn)全局流控的裝置，其特征在于，還包括：

錯峰處理單元，用于當(dāng)本地配額庫存與所述配額批次之和大于所述全局限額閾值時休眠到下一個限額時間點重新處理所述請求。