[發明專利]一種交易接口的限流方法及裝置

在審

• 申請號: 201710874614.6
• 申請日: 2017-09-25
• 公開（公告）號: CN107609976A
• 公開（公告）日: 2018-01-19
• 發明（設計）人: 馮健誠;張軍杰
• 申請（專利權）人: 中國銀行股份有限公司
• 主分類號: G06Q40/04
• 分類號: G06Q40/04;G06F17/30;H04L12/801
• 代理公司: 北京集佳知識產權代理有限公司11227
• 代理人: 侯珊,王寶筠

技術領域

本發明涉及數據處理技術領域，具體涉及一種交易接口的限流方法及裝置。

背景技術

中銀開放平臺的交易處理系統及配套的服務器負責對用戶向交易接口發送的交易請求進行處理，并將處理后的交易數據通過交易接口返回至用戶。

隨著用戶數量的增加，用戶向交易接口發送的交易請求量也呈現激增的趨勢，鑒于服務器的物理和軟件資源的限制，激增的交易請求量會對交易處理系統帶來交易不可用，性能降低，甚至引發連鎖反應導致相關系統的整體崩潰，而帶來損失。通過給交易處理系統增加限流措施，可以將超出系統處理能力部分的交易請求拒之門外。

目前，有Google開源項目Guava提供基于令牌桶算法的限流工具類RateLimiter來實現限流功能。令牌桶算法的原理是系統以恒定的速度往桶里放入令牌，而如果請求需要被處理，則需要先從桶里獲取一個令牌，當桶里沒有令牌可取時，則拒絕服務。

但是，Google開源項目Guava提供的限流工具類Rate Limiter實現的功能太過單一，而且缺乏靈活性。

發明內容

有鑒于此，本發明實施例提供一種交易接口的限流方法及裝置，能夠保證交易處理系統在一定適量的交易請求并發處理量時的處理性能，保證交易處理的高效性。

為實現上述目的，本發明實施例提供如下技術方案：

一種交易接口的限流方法，包括：

接收用戶發送給交易接口的交易請求；

對交易處理系統當前正在處理的來自所述交易接口的交易請求進行計數，獲取交易處理系統當前正在處理的來自所述交易接口的交易請求的數量；

判斷所述交易處理系統當前正在處理的來自所述交易接口的交易請求的數量是否超過所述交易接口的最大處理閾值；

如果所述交易處理系統當前正在處理的來自所述交易接口的交易請求的數量未超過所述交易接口的最大處理閾值，則將所述用戶發送給交易接口的交易請求發送至交易處理系統。

可選的，在所述接收用戶發送給交易接口的交易請求之前，所述方法還包括：

在數據庫中對交易接口的最大處理閾值進行配置。

可選的，在所述判斷所述交易處理系統當前正在處理的來自所述交易接口的交易請求的數量是否超過所述交易接口的最大處理閾值之前，所述方法還包括：

通過工具類將在數據庫中配置的各個交易接口的最大處理閾值讀取到內存中，并緩存；

從內存中獲取所述交易接口的最大處理閾值。

可選的，所述方法還包括：

對交易處理系統處理交易請求時的性能進行監測，獲取交易處理系統在滿足預設的性能要求時處理交易請求的最大數目；

根據交易處理系統在滿足預設的性能要求時處理交易請求的最大數目優化數據庫中對交易接口的最大處理閾值的配置。

可選的，所述對交易處理系統當前正在處理的來自所述交易接口的交易請求進行計數，獲取交易處理系統當前正在處理的來自所述交易接口的交易請求的數量，包括：

采用Redis數據庫的原子性自增或自減操作對交易處理系統當前正在處理的來自所述交易接口的交易請求進行計數，獲取交易處理系統當前正在處理的來自所述交易接口的交易請求的數量。

一種交易接口的限流裝置，包括：

接收模塊，用于接收用戶發送給交易接口的交易請求；

計數器模塊，用于對交易處理系統當前正在處理的來自所述交易接口的交易請求進行計數，獲取交易處理系統當前正在處理的來自所述交易接口的交易請求的數量；

判斷模塊，用于判斷所述交易處理系統當前正在處理的來自所述交易接口的交易請求的數量是否超過所述交易接口的最大處理閾值；

發送模塊，用于如果所述交易處理系統當前正在處理的來自所述交易接口的交易請求的數量未超過所述交易接口的最大處理閾值，則將所述用戶發送給交易接口的交易請求發送至交易處理系統。

可選的，所述裝置還包括：

最大處理閾值配置模塊，用于在所述接收用戶發送給交易接口的交易請求之前，在數據庫中對交易接口的最大處理閾值進行配置。

可選的，所述裝置還包括：

最大處理閾值獲取模塊，用于在所述判斷所述交易處理系統當前正在處理的來自所述交易接口的交易請求的數量是否超過所述交易接口的最大處理閾值之前，通過工具類將在數據庫中配置的各個交易接口的最大處理閾值讀取到內存中，并緩存；從內存中獲取所述交易接口的最大處理閾值。

可選的，所述裝置還包括：