[發(fā)明專利]限流方法、裝置、服務器及服務器集群在審
| 申請?zhí)枺?/td> | 202010611501.9 | 申請日: | 2020-06-29 |
| 公開(公告)號: | CN111988355A | 公開(公告)日: | 2020-11-24 |
| 發(fā)明(設計)人: | 龍金華;李曉丹 | 申請(專利權)人: | 漢海信息技術(上海)有限公司 |
| 主分類號: | H04L29/08 | 分類號: | H04L29/08 |
| 代理公司: | 北京博雅睿泉專利代理事務所(特殊普通合伙) 11442 | 代理人: | 吳秀娥 |
| 地址: | 200335 上海市*** | 國省代碼: | 上海;31 |
| 權利要求書: | 查看更多 | 說明書: | 查看更多 |
| 摘要: | |||
| 搜索關鍵詞: | 限流 方法 裝置 服務器 集群 | ||
1.一種限流方法,應用于服務器集群中的節(jié)點服務器,包括:
接收數(shù)據(jù)訪問請求;
響應于所述數(shù)據(jù)訪問請求,從本地緩存區(qū)中獲取本地限流值,其中,所述本地限流值為總限流值的本地緩存值,所述總限流值為所述服務器集群在預設時間長度內接收到的數(shù)據(jù)訪問請求的累加值;
根據(jù)所述本地限流值,處理所述數(shù)據(jù)訪問請求。
2.根據(jù)權利要求1所述的方法,所述根據(jù)所述本地限流值,處理所述數(shù)據(jù)訪問請求,包括:
在所述本地限流值大于預設的限流閾值的情況下,對所述數(shù)據(jù)訪問請求執(zhí)行限流處理。
3.根據(jù)權利要求1所述的方法,所述方法還包括:
根據(jù)所述數(shù)據(jù)訪問請求,更新所述總限流值;
根據(jù)更新后的總限流值,更新所述本地限流值。
4.根據(jù)權利要求3所述的方法,所述服務器集群還包括與節(jié)點服務器通信的數(shù)據(jù)庫服務器,所述總限流值存儲在所述數(shù)據(jù)庫服務器中,所述更新所述總限流值,包括:
向所述數(shù)據(jù)庫服務器發(fā)送用于更新所述總限流值的數(shù)據(jù)請求消息;
獲取所述數(shù)據(jù)庫服務器返回的、對應于所述數(shù)據(jù)請求消息的回調消息;
從所述回調消息中,獲取所述更新后的總限流值。
5.根據(jù)權利要求4所述的方法,所述更新所述總限流值還包括:
獲取所述數(shù)據(jù)庫服務器的服務狀態(tài);
在所述服務狀態(tài)表征所述數(shù)據(jù)庫服務器處于服務可用狀態(tài)的情況下,執(zhí)行所述向所述數(shù)據(jù)庫服務器發(fā)送用于更新所述總限流值的數(shù)據(jù)請求消息步驟。
6.根據(jù)權利要求5所述的方法,所述更新所述總限流值,還包括:
在所述服務狀態(tài)表征所述數(shù)據(jù)庫服務器處于服務不可用狀態(tài)的情況下,使用預設的單機限流方式更新所述總限流值。
7.根據(jù)權利要求1所述的方法,所述方法還包括:
獲取所述本地限流值的緩存時長;
在所述緩存時長超過預設的有效時長的情況下,獲取最新的總限流值;
根據(jù)所述最新的總限流值,更新所述本地限流值。
8.一種限流裝置,包括:
請求接收模塊,用于接收數(shù)據(jù)訪問請求;
本地限流值獲取模塊,用于從本地緩存區(qū)中獲取本地限流值,其中,所述本地限流值為總限流值的本地緩存值,所述總限流值為所述服務器集群在預設時間長度內接收到的數(shù)據(jù)訪問請求的累加值;
限流處理模塊,用于根據(jù)所述本地限流值,處理所述數(shù)據(jù)訪問請求。
9.一種服務器,包括權利要求8所述的限流裝置;或者,
所述服務器包括:
存儲器,用于存儲可執(zhí)行的指令;
處理器,用于根據(jù)所述指令的控制運行所述服務器執(zhí)行如權利要求1-7任意一項所述的方法。
10.一種服務器集群,包括數(shù)據(jù)庫服務器和至少一個權利要求9所述的服務器,所述服務器作為所述服務器集群的節(jié)點服務器,將所述數(shù)據(jù)庫服務器統(tǒng)計的所述服務器集群的總限流值緩存在本地緩存區(qū)中,得到本地限流值。
該專利技術資料僅供研究查看技術是否侵權等信息,商用須獲得專利權人授權。該專利全部權利屬于漢海信息技術(上海)有限公司,未經(jīng)漢海信息技術(上海)有限公司許可,擅自商用是侵權行為。如果您想購買此專利、獲得商業(yè)授權和技術合作,請聯(lián)系【客服】
本文鏈接:http://www.szxzyx.cn/pat/books/202010611501.9/1.html,轉載請聲明來源鉆瓜專利網(wǎng)。





