首先我們給出限流的定義：

1. 限定某個(gè)行為在指定時(shí)間內(nèi)被允許的最大次數(shù)

2. 限定某個(gè)用戶的某個(gè)行為在指定時(shí)間內(nèi)被允許的最大次數(shù)

其實(shí)二者差不多，前面一句是限定所有人，后面的是限定了每個(gè)用戶

?

注意

1. 這里我們討論的是簡單的限流，即“限定某個(gè)行為在指定時(shí)間內(nèi)被允許的最大次數(shù)”中的最大次數(shù)是比較小的

2. 數(shù)量級在幾次，幾十次，或者幾百次級別的。至于上萬級別，甚至百萬級別的，暫不討論，因?yàn)槿绻總€(gè)玩家都保存這么大的量，內(nèi)存膨脹得太嚴(yán)重，那種數(shù)量級需要更復(fù)雜的漏斗限流法

3. 漏斗限流法的介紹請參見這篇博客，等待中

?

簡單限流的實(shí)現(xiàn)原理：（以每個(gè)用戶60秒內(nèi)最多允許10次點(diǎn)贊為例）

1. 利用redis的zset數(shù)據(jù)結(jié)構(gòu)，保存每次行為及對應(yīng)的時(shí)間戳

? ? key:點(diǎn)贊標(biāo)示+用戶ID， score:當(dāng)前毫秒時(shí)間戳， value:當(dāng)前毫秒時(shí)間戳，我們主要使用的是score，所以value無所謂的

2. 檢測時(shí)先移除超過時(shí)間限定的舊記錄，也就是使用函數(shù)??ZREMRANGEBYSCORE() 移除60秒之前的記錄

3. 再使用函數(shù) zcard()?獲得該key的元素個(gè)數(shù)，若少于限定次數(shù)即，少于10次，則可以操作；否則不允許操作

注意：由于是多條

?

代碼如下(這里僅給出偽代碼)

// 是否允許某個(gè)行為 // userid : 玩家id // actionkey : 行為 // limittime : 限定的秒數(shù) // maxcount : 允許的最大次數(shù) bool isActionAllowed(string userid, string actionkey, int limittime, int maxcount) {// zset的keystring key = actionkey + userid;// 當(dāng)前毫秒時(shí)間戳uint64_t nowTime = get_current_time();// 管道Pipeline pipe = pipelined();pipe.multi();// 核心：移除（0 - limittime秒之前）的記錄pipe.zremrangeByScore(key, 0, nowTime - limittime*1000);//超時(shí)時(shí)間（加1秒防時(shí)間差）pipe.expire(key, limittime+1);// 記錄的行為個(gè)數(shù)int count = pipe.zcard(key);return count <= maxcount; }

?

總結(jié)

以上是生活随笔為你收集整理的redis实现简单限流的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。