[發(fā)明專利]基于分布式令牌桶的削峰系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201811015371.1
• 申請(qǐng)日: 2018-08-31
• 公開（公告）號(hào): CN109286573B
• 公開（公告）日: 2022-07-08
• 發(fā)明（設(shè)計(jì)）人: 胡昇
• 申請(qǐng)（專利權(quán)）人: 重慶富民銀行股份有限公司
• 主分類號(hào): H04L47/215
• 分類號(hào): H04L47/215;H04L47/50;H04L43/00
• 代理公司: 重慶強(qiáng)大凱創(chuàng)專利代理事務(wù)所(普通合伙) 50217
• 代理人: 黃書凱

1.基于分布式令牌桶的削峰系統(tǒng)，其特征在于：包括請(qǐng)求接收模塊、流量判斷模塊、異步消息隊(duì)列模塊和消費(fèi)組件，請(qǐng)求接收模塊接收到上層系統(tǒng)發(fā)送來的業(yè)務(wù)請(qǐng)求后，流量判斷模塊采用令牌桶算法進(jìn)行判斷，流量判斷模塊判斷業(yè)務(wù)請(qǐng)求的流量是否超過預(yù)設(shè)的流量峰值，若業(yè)務(wù)請(qǐng)求的流量超過流量峰值，將該業(yè)務(wù)請(qǐng)求發(fā)送到異步消息隊(duì)列模塊中進(jìn)行排隊(duì)等待，若業(yè)務(wù)請(qǐng)求的流量不超過流量峰值，將該業(yè)務(wù)請(qǐng)求發(fā)送到下層系統(tǒng)，下層系統(tǒng)處理業(yè)務(wù)請(qǐng)求；

在下層系統(tǒng)處理完業(yè)務(wù)請(qǐng)求后，消費(fèi)組件對(duì)排隊(duì)等待的業(yè)務(wù)請(qǐng)求進(jìn)行消費(fèi)，流量判斷模塊判斷消費(fèi)后的業(yè)務(wù)請(qǐng)求的流量是否超過流量峰值，若判斷不超過流量峰值，將該業(yè)務(wù)請(qǐng)求發(fā)送到下層系統(tǒng)進(jìn)行處理，若超過，消費(fèi)組件繼續(xù)消費(fèi)該業(yè)務(wù)請(qǐng)求，直到業(yè)務(wù)請(qǐng)求的流量不超過流量峰值后，將該業(yè)務(wù)請(qǐng)求發(fā)送到下層系統(tǒng)進(jìn)行處理。

2.根據(jù)權(quán)利要求1所述的基于分布式令牌桶的削峰系統(tǒng)，其特征在于：所述令牌桶的最大的令牌數(shù)與下層系統(tǒng)的處理能力相匹配。

3.根據(jù)權(quán)利要求2所述的基于分布式令牌桶的削峰系統(tǒng)，其特征在于：所述令牌桶的最大令牌數(shù)可動(dòng)態(tài)調(diào)整。

4.根據(jù)權(quán)利要求1所述的基于分布式令牌桶的削峰系統(tǒng)，其特征在于：所述流量判斷模塊基于分布式協(xié)調(diào)組件zookeeper實(shí)現(xiàn)分布式令牌桶算法。

5.根據(jù)權(quán)利要求4所述的基于分布式令牌桶的削峰系統(tǒng)，其特征在于：所述消費(fèi)組件為Kafka消費(fèi)組件。