Redis+Lua實現分佈式限流器

LastModified: 2019年6月14日10:37:39

主要是依靠 redis + lua 來實現限流器, 使用 lua 的緣由是將多條命令合併在一塊兒做爲一個原子操做, 無需過多考慮併發.

計數器模式

原理

計數器算法是指在一段窗口時間內容許經過的固定數量的請求, 好比10次/秒, 500次/30秒.

若是設置的時間粒度越細, 那麼限流會更平滑.

實現

所使用的 Lua 腳本

-- 計數器限流
-- 此處支持的最小單位時間是秒, 若將 expire 改爲 pexpire 則可支持毫秒粒度.
-- KEYS[1]  string  限流的key
-- ARGV[1]  int     限流數
-- ARGV[2]  int     單位時間(秒)

local cnt = tonumber(redis.call("incr", KEYS[1]))

if (cnt == 1) then
    -- cnt 值爲1說明以前不存在該值, 所以須要設置其過時時間
    redis.call("expire", KEYS[1], tonumber(ARGV[2]))
elseif (cnt > tonumber(ARGV[1])) then
    return -1
end 

return cnt

返回 -1 表示超過限流, 不然返回當前單位時間已經過的請求數

key 能夠但不限於如下的狀況

• ip + 接口
• user_id + 接口

優勢

• 實現簡單

缺點

• 粒度不夠細的狀況下, 會出如今同一個窗口時間內出現雙倍請求數

注意

• 儘可能保持時間粒度精細

場景分析

eg. 1000/3s 的限流

極端狀況1:

第1秒請求數 10

第2秒請求數 10

第3秒請求數 980

第4秒請求數 900

第5秒請求數 100

第6秒請求數 0

此時注意第3~5秒內的總請求數高達 1980

極端狀況2:

第1秒請求數 1000

第2秒請求數 0

第3秒請求數 0

此時後續的第2~3秒會出現大量拒絕請求

令牌桶模式

原理

令牌桶的

1. 桶中保存有令牌, 存在上限, 且一開始是滿的
2. 每次請求都要消耗令牌(可根據不一樣請求消耗不一樣數量的令牌)
3. 每隔一段時間(固定速率)會往桶中放令牌

桶的實現還分爲:

• 可預消費

  提早預支令牌數: 前人挖坑, 後人跳

• 不可預消費

  令牌數不夠直接拒絕

實現

此處實現的不可預消費的令牌桶, 具體Lua代碼:

-- 令牌桶限流: 不支持預消費, 初始桶是滿的
-- KEYS[1]  string  限流的key

-- ARGV[1]  int     桶最大容量
-- ARGV[2]  int     每次添加令牌數
-- ARGV[3]  int     令牌添加間隔(秒)
-- ARGV[4]  int     當前時間戳

local bucket_capacity = tonumber(ARGV[1])
local add_token = tonumber(ARGV[2])
local add_interval = tonumber(ARGV[3])
local now = tonumber(ARGV[4])

-- 保存上一次更新桶的時間的key
local LAST_TIME_KEY = KEYS[1].."_time";         
-- 獲取當前桶中令牌數
local token_cnt = redis.call("get", KEYS[1])    
-- 桶徹底恢復須要的最大時長
local reset_time = math.ceil(bucket_capacity / add_token) * add_interval;

if token_cnt then   -- 令牌桶存在
    -- 上一次更新桶的時間
    local last_time = redis.call('get', LAST_TIME_KEY)
    -- 恢復倍數
    local multiple = math.floor((now - last_time) / add_interval)
    -- 恢復令牌數
    local recovery_cnt = multiple * add_token
    -- 確保不超過桶容量
    local token_cnt = math.min(bucket_capacity, token_cnt + recovery_cnt) - 1
    
    if token_cnt < 0 then
        return -1;
    end
    
    -- 從新設置過時時間, 避免key過時
    redis.call('set', KEYS[1], token_cnt, 'EX', reset_time)                     
    redis.call('set', LAST_TIME_KEY, last_time + multiple * add_interval, 'EX', reset_time)
    return token_cnt
    
else    -- 令牌桶不存在
    token_cnt = bucket_capacity - 1
    -- 設置過時時間避免key一直存在
    redis.call('set', KEYS[1], token_cnt, 'EX', reset_time);
    redis.call('set', LAST_TIME_KEY, now, 'EX', reset_time + 1);    
    return token_cnt    
end

令牌桶的關鍵是如下幾個參數:

• 桶最大容量
• 每次放入的令牌數
• 放入令牌的間隔時間

令牌桶的實現不會出現計數器模式中單位時間內雙倍流量的問題.