public class RedisLimiterTest {
    private Jedis jedis;

    public RedisLimiterTest(Jedis jedis) {
        this.jedis = jedis;
    }

    /**
     * @param ipAddress Ip地址
     * @param period    特定的時(shí)間內(nèi)，單位秒
     * @param maxCount  最大允許的次數(shù)
     * @return
     */
    public boolean isIpLimit(String ipAddress, int period, int maxCount) {
        String key = String.format("ip:%s", ipAddress);
        // 毫秒時(shí)間戳
        long currentTimeMillis = System.currentTimeMillis();
        Pipeline pipe = jedis.pipelined();
        // redis事務(wù)，保證原子性
        pipe.multi();
        // 存放數(shù)據(jù)，value 和 score 都使用毫秒時(shí)間戳
        pipe.zadd(key, currentTimeMillis, "" + UUID.randomUUID());
        // 移除窗口區(qū)間所有的元素
        pipe.zremrangeByScore(key, 0, currentTimeMillis - period * 1000);
        // 獲取時(shí)間窗口內(nèi)的行為數(shù)量
        Response<Long> count = pipe.zcard(key);
        // 設(shè)置 zset 過(guò)期時(shí)間，避免冷用戶持續(xù)占用內(nèi)存，這里寬限1s
        pipe.expire(key, period + 1);
        // 提交事務(wù)
        pipe.exec();
        pipe.close();
        // 比較數(shù)量是否超標(biāo)
        return count.get() > maxCount;
    }

    public static void main(String[] args) {
        Jedis jedis = new Jedis("localhost", 6379);
        RedisLimiterTest limiter = new RedisLimiterTest(jedis);
        for (int i = 1; i <= 20; i++) {
            // 驗(yàn)證IP  10秒鐘之內(nèi)只能訪問(wèn)5次
            boolean isLimit = limiter.isIpLimit("222.73.55.22", 10, 5);
            System.out.println("訪問(wèn)第" + i + "次, 結(jié)果：" + (isLimit ? "限制訪問(wèn)" : "允許訪問(wèn)"));
        }
    }
}

public class FunnelLimiterTest {

    static class Funnel {
        int capacity; // 漏斗容量
        float leakingRate; // 漏嘴流水速率
        int leftQuota; // 漏斗剩余空間
        long leakingTs; // 上一次漏水時(shí)間

        public Funnel(int capacity, float leakingRate) {
            this.capacity = capacity;
            this.leakingRate = leakingRate;
            this.leftQuota = capacity;
            this.leakingTs = System.currentTimeMillis();
        }

        void makeSpace() {
            long nowTs = System.currentTimeMillis();
            long deltaTs = nowTs - leakingTs; // 距離上一次漏水過(guò)去了多久
            int deltaQuota = (int) (deltaTs * leakingRate); // 騰出的空間 = 時(shí)間*漏水速率
            if (deltaQuota < 0) { // 間隔時(shí)間太長(zhǎng)，整數(shù)數(shù)字過(guò)大溢出
                this.leftQuota = capacity;
                this.leakingTs = nowTs;
                return;
            }
            if (deltaQuota < 1) { // 騰出空間太小 就等下次，最小單位是1
                return;
            }
            this.leftQuota += deltaQuota; // 漏斗剩余空間 = 漏斗剩余空間 + 騰出的空間
            this.leakingTs = nowTs;
            if (this.leftQuota > this.capacity) { // 剩余空間不得高于容量
                this.leftQuota = this.capacity;
            }
        }

        boolean watering(int quota) {
            makeSpace();
            if (this.leftQuota >= quota) { // 判斷剩余空間是否足夠
                this.leftQuota -= quota;
                return true;
            }
            return false;
        }
    }

    // 所有的漏斗
    private Map<String, Funnel> funnels = new HashMap<>();

    /**
     * @param capacity    漏斗容量
     * @param leakingRate 漏嘴流水速率 quota/s
     */
    public boolean isIpLimit(String ipAddress, int capacity, float leakingRate) {
        String key = String.format("ip:%s", ipAddress);
        Funnel funnel = funnels.get(key);
        if (funnel == null) {
            funnel = new Funnel(capacity, leakingRate);
            funnels.put(key, funnel);
        }
        return !funnel.watering(1); // 需要1個(gè)quota
    }

    public static void main(String[] args) throws Exception{
        FunnelLimiterTest limiter = new FunnelLimiterTest();
        for (int i = 1; i <= 50; i++) {
            // 每1s執(zhí)行一次
            Thread.sleep(1000);
            // 漏斗容量是2 ，漏嘴流水速率是0.5每秒，
            boolean isLimit = limiter.isIpLimit("222.73.55.22", 2, (float)0.5/1000);
            System.out.println("訪問(wèn)第" + i + "次, 結(jié)果：" + (isLimit ? "限制訪問(wèn)" : "允許訪問(wèn)"));
        }
    }
}

> cl.throttle key:xxx 15 30 60 1

> cl.throttle laoqian:reply 15 30 60
1) (integer) 0   # 0 表示允許，1表示拒絕
2) (integer) 15  # 漏斗容量capacity
3) (integer) 14  # 漏斗剩余空間left_quota
4) (integer) -1  # 如果拒絕了，需要多長(zhǎng)時(shí)間后再試(漏斗有空間了，單位秒)
5) (integer) 2   # 多長(zhǎng)時(shí)間后，漏斗完全空出來(lái)(left_quota==capacity，單位秒)