基于Redis實現令牌桶算法

基于Redis實現令牌桶算法

  • 令牌桶算法
      • 算法流程圖
      • 優點
      • 缺點
    • 實現
    • 其它限流算法

令牌桶算法

令牌桶是一種用于分組交換和電信網絡的算法。它可用于檢查數據包形式的數據傳輸是否符合定義的帶寬和突發性限制(流量不均勻或變化的衡量標準)。它還可以用作調度算法來確定符合帶寬和突發性限制設置的傳輸時序。

算法流程圖

如圖所示,令牌桶算法可以描述為:

  • 令牌桶初始大小和容量為X
  • 以一定速率Y向令牌桶中添加令牌,如果令牌桶滿了,忽略多余令牌
  • 每次請求令牌桶拿Z個令牌,如果當前令牌桶不足,則拒絕當前請求

令牌桶圖示

優點

  • 平滑流量:
    令牌桶可以通過控制令牌放入速率(Y)平滑流量,防止過高負載導致系統崩潰
  • 可以處理突發流量
    令牌桶可以積累一定量的令牌以應對突發流量
  • 靈活
    通過調整令牌桶的容量和令牌放入速率,可以靈活地控制突發容量和請求的平均處理速率。這種靈活性使得令牌桶算法能夠適應不同應用場景。

缺點

  • 資源占用
    令牌桶算法需要維護當前令牌數和上次放入時間, 這會耗費較高的計算資源。
  • 參數調整復雜
    令牌桶算法需要調整容量(X)、速率(Y)和每次請求令牌數量(Z),不合適的參數有可能導致請求分配不公平乃至饑餓請求(長時間無法獲取到令牌的請求)。
  • 依賴系統時間
    令牌桶算法在計算令牌數量時依賴于系統時間。如果系統時間發生異常(如時間回撥),則可能會導致算法失效或產生不可預測的結果。

實現

本文是使用Redis的Lua腳本來實現的

--- 實現令牌桶算法
-- 以一定的頻率向令牌桶中放入令牌, 其它人使用時獲取令牌, 如果能夠獲取成功
local expire_time = 3600 -- 1個小時失效
local bucket_size = 20 -- 一個桶最多有20張令牌
local bucket_speed = 3.5 -- 每秒增加令牌的個數
local requests_token = 1 -- 請求一次耗費的令牌數local time = redis.call('TIME')
local current_time = time[1] * 1000 + time[2] / 1000 -- TIME返回的是 秒,納秒.  這里轉換成微秒
local token = KEYS[1]-- 獲取當前剩余令牌數
local bucket = redis.call('HGETALL', token)
local ret = 0
if table.maxn(bucket) == 0 then-- 令牌桶已失效或者還沒有設置redis.call('HSET', token, 'lastRefillTime', current_time)redis.call('HSET', token, 'tokensRemain', bucket_size - requests_token)redis.call('PEXPIRE', token, expire_time * 1500)ret = 1
else-- 上次填充時間local lastRefillTime = tonumber(bucket[2])-- 剩余令牌數local tokensRemain = tonumber(bucket[4])-- 距離上次調用時間local cost_time = current_time - lastRefillTimeif cost_time < 0 then-- 發生了時間回撥, 令牌不再增加current_time = lastRefillTimeif tokensRemain >= requests_token thentokensRemain = tokensRemain - requests_tokenret = 1endelseif tokensRemain >= 1 or cost_time * bucket_speed / 1000 >= requests_token thentokensRemain = math.min(tokensRemain + (cost_time * bucket_speed / 1000) - requests_token, bucket_size - requests_token)ret = 1elsetokensRemain = tokensRemain + (cost_time * bucket_speed / 1000)ret = 0endredis.call('HSET', token, 'lastRefillTime', current_time)redis.call('HSET', token, 'tokensRemain', tokensRemain)redis.call('PEXPIRE', token, expire_time * 1500)
end
return ret

其它限流算法

  • 計數器算法
  • 滑動窗口算法
  • 漏桶算法

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/web/62956.shtml
繁體地址,請注明出處:http://hk.pswp.cn/web/62956.shtml
英文地址,請注明出處:http://en.pswp.cn/web/62956.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

操作系統(8)死鎖

一、概念 死鎖是指在一個進程集合中的每個進程都在等待只能由該集合中的其他進程才能引起的事件&#xff0c;而無限期地僵持下去的局面。在多任務環境中&#xff0c;由于資源分配不當&#xff0c;導致兩個或多個進程在等待對方釋放資源時陷入無限等待的狀態&#xff0c;這就是死…

Micropython 擴展C模塊<HelloWorld>

開發環境 MCU&#xff1a;Pico1&#xff08;無wifi版&#xff09;使用固件&#xff1a;自編譯版本開發環境&#xff1a;MacBook Pro Sonoma 14.5開發工具&#xff1a;Thonny 4.1.6開發語言&#xff1a;MicroPython 1.24 執行示例 在github上獲取micropython&#xff0c;我使…

并查集基礎

abstract 并查集&#xff08;Union-Find Set&#xff09;是一種數據結構&#xff0c;主要用于處理動態連通性問題&#xff08;Dynamic Connectivity Problem&#xff09;&#xff0c;例如在圖論中判斷兩點是否屬于同一個連通分量&#xff0c;以及動態地合并集合。 它廣泛應用…

CloudberryDB(一)安裝部署多節點分布式數據庫集群

CloudberryDB&#xff1a; 一個 Greenplum Database 分布式數據庫開源版本的衍生項目&#xff0c; 針對開源 Greenplum Database 優化的地方&#xff0c; CloudberryDB制定了路線圖&#xff08;https://github.com/orgs/cloudberrydb/discussions/369&#xff09;并在逐步改…

解決Logitech G hub 無法進入一直轉圈的方案(2024.12)

如果你不是最新版本無法加載嘗試以下方案&#xff1a;刪除AppData 文件夾下的logihub文件夾 具體路徑&#xff1a;用戶名根據實際你的請情況修改 C:\Users\Administrator\AppData\Local 如果你有通過lua編譯腳本&#xff0c;記得備份&#xff01;&#xff01; ↓如果你是最新…

數據庫范式與反范式化:如何權衡性能與數據一致性

目錄 1. 什么是數據庫范式&#xff08;Normalization&#xff09;&#xff1f;第一范式&#xff08;1NF&#xff09;第二范式&#xff08;2NF&#xff09;第三范式&#xff08;3NF&#xff09; 2. 什么是反范式化&#xff08;Denormalization&#xff09;&#xff1f;3. 反范式…

Nmap使用總結

0X00 背景 nmap是測試中常用的網絡探測工具&#xff0c;但是這回簡單的操作&#xff0c;一直了解不深入&#xff0c;現在深入的了解和學習一下。 在文章結構上&#xff0c;我把平時常用的內容提前了&#xff0c;以便再次查閱的時候&#xff0c;比較方便。 0X01 安裝 nmap可…

【記錄49】vue2 vue-office在線預覽 docx、pdf、excel文檔

vue2 在線預覽 docx、pdf、excel文檔 docx npm install vue-office/docx vue-demi0.14.6 指定版本 npm install vue-office/docx vue-demi <template><VueOfficeDocx :src"pdf" style"height: 100vh;" rendere"rendereHandler" error&…

MVC模式的理解和實踐

在軟件開發中&#xff0c;MVC&#xff08;Model-View-Controller&#xff09;模式是一種經典的設計模式&#xff0c;特別適用于構建用戶界面復雜的Web應用程序。MVC通過將應用程序的業務邏輯、數據顯示和用戶交互分離&#xff0c;使代碼結構更加清晰&#xff0c;易于維護和擴展…

[A-22]ARMv8/v9-SMMU多級頁表架構

ver0.1 [看前序文章有驚喜,關注W\X\G=Z+H=“浩瀚架構師”,可以解鎖全部文章] 前言 前文我們對SMMU的系統架構和基本功能做了簡要的介紹,現在大家大致對SMMU在基于ARM體系的系統架構下的總線位置和產品形態有了基本的了解。這里我們還是簡單做個前情回顧,從總線架構角度看…

【UE5 “RuntimeLoadFbx”插件】運行時加載FBX模型

前言 為了解決在Runtime時能夠直接根據FBX模型路徑直接加載FBX的問題&#xff0c;推薦一款名為“RuntimeLoadFBX”的插件。 用法 插件用法如下&#xff0c;只需要指定fbx的地址就可以在場景中生成Actor模型 通過指定輸入參數“Cal Collision”來設置FBX模型的碰撞 還可以通過…

(11)(3.1) ESC接地和接線注意事項

文章目錄 前言 1 歸納 2 電容式 3 電阻 前言 ESC 接地問題由 3 種形式的 ESC 信號/耦合問題組成&#xff0c;即電阻、電容和電感。在制造飛機時&#xff0c;應考慮這三個因素。 1 歸納 這是電流突然變化導致系統中出現大電壓尖峰的趨勢。電源系統中的電感主要是由 ESC 和…

精品基于Python實現的微信小程序校園導航系統-微信小程序

[含文檔PPT源碼等] [包運行成功永久免費答疑輔導] 《django微信小程序校園導航系統》該項目采用技術Python的django框架、mysql數據庫 &#xff0c;項目含有源碼、文檔、PPT、配套開發軟件、軟件安裝教程、項目發布教程、核心代碼介紹視頻等 軟件開發環境及開發工具&#xf…

Rstudio-server的安裝、配置、維護

一、安裝Rstudio-server (1)安裝R語言&#xff1a; sudo apt install r-base # 如果沒有管理員權限無法操作 # 這樣裝上R默認在/usr/bin/R其實基本上的流程都可以參考posit的官網&#xff08;也就是Rstudio的官網&#xff09;&#xff1a; https://posit.co/download/rstudio…

Python序列的應用(八):元組、字典

前言&#xff1a;在Python編程語言中&#xff0c;序列是一種非常重要的數據結構&#xff0c;它允許我們存儲和操作有序的數據集合。在前幾期的內容中&#xff0c;我們已經探討了列表&#xff08;List&#xff09;和集合&#xff08;Set&#xff09;這兩種序列的應用&#xff0c…

OpenCV 功能函數介紹

一&#xff0c; 二值化函數 功能&#xff1a; 用于對圖像進行二值化處理 參數&#xff1a; cv2.threshold(輸入你的圖像所對應的灰度圖&#xff0c; 閾值&#xff1a;是浮點還是整數取決予圖像的數據類型 最大值;高于閾值的像素值&#xff0c; 閾值類型&#xff1a;cv2.THR…

【Python】使用Selenium的find_element模塊獲取網頁上的大段文字和表格的方法(建議收藏!)

發現了一個使用Selenium的find_element模塊&#xff0c;快速獲取文字和表格的方法&#xff0c;很實在&#xff0c;以后爬網的時候&#xff0c;就不用beautifulSoup 和 pandas的read_html 混起來用了&#xff01; 文字部分&#xff1a;實現網絡節點下&#xff0c;某個節點下的其…

APP滲透測試記錄(一、Android應用基本構造)

Android應用基本構造 雷電模擬機進入 adb shell# 如果不是root權限 su一下 su 1.了解APK文件 安卓應用的擴展名為.apk(Android Application Package),它是一個包含多個文件和文件夾的數據存檔文件。 1.1 apk文件解壓后的目錄結構 AndroidManifest.xml:包含應用的大部分…

【AI知識】有監督學習之回歸任務(附線性回歸代碼及可視化)

1. 回歸的基本概念 在機器學習的有監督學習中&#xff0c;回歸&#xff08;Regression&#xff09;是一種常見的任務&#xff0c;它的目標是通過觀察數據來建立一個模型&#xff0c;用一個或多個自變量來預測因變量的值。 回歸分析通常用于&#xff1a; a.預測&#xff0c;基于…

fastadmin批量壓縮下載遠程視頻文件

后端代碼 // 批量下載并壓縮 public function downloadAll(){$ids input(ids);$row $this->model->where(id, in, $ids)->field(id,title,video_url)->select();if (!$row) {$this->error(記錄不存在);}$arr [];$tempFiles []; // 用來存儲臨時下載的視頻文…