转载

APIGateway中流控介绍

流控或者叫限流，可以通过控制流量来保护我们的系统不被大流量或者异常流量冲垮，常用的限流算法有：计数器算法、令牌桶算法、漏桶算法。

计数器算法

计数器算法最简单，可以实现在指定的时间段内流量不能超过多少，比如同一个ip在1秒内请求次数不能超过100次这种情形。

需要使用两个map，一个用来记录同一个ip访问的次数，一个用来记录同一个ip上次访问的时间戳。防止map无限制增长，可以单独开启一个线程，用来定时清除超过时间窗口的ip数据。

计数器算法可能会产生突刺，请求集中到达处理后，后面时间就会空闲掉。

示例代码如下：

public class IPCounter {

    /**
     * 保存ip访问的次数
     * key：ip
     * value：访问次数
     */
    private Map<String, AtomicInteger> counterMap = new ConcurrentHashMap<>();

    /**
     * 保存ip访问的时间
     * key：ip
     * value：时间戳
     */
    private Map<String, Long> timeMap = new ConcurrentHashMap<>();

    /**
     * 指定的次数
     */
    private int countRule;

    /**
     * 指定的时间，毫秒
     */
    private long timeRule;

    public IPCounter(int countRule, long timeRule) {
        this.countRule = countRule;
        this.timeRule = timeRule * 1000;
    }

    public boolean allow(String ip) {
        Long time = timeMap.get(ip);
        Long now = System.currentTimeMillis();

        // 不存在或者上一个时间窗口已经过去，重置时间和计数器
        if (time == null || (now - time) > timeRule) {
            timeMap.put(ip, now);
            counterMap.put(ip, new AtomicInteger());
        }

        AtomicInteger count = counterMap.get(ip);
        int temp = 1;
        if (count != null) {
            temp = count.incrementAndGet();
        }

        return temp <= countRule;
    }

    public static void main(String[] args) {
        // 10秒不能超过5次
        IPCounter counter = new IPCounter(5, 10);
        String ip = "192.168.1.1";
        System.out.println(counter.allow(ip));
        System.out.println(counter.allow(ip));
        System.out.println(counter.allow(ip));
        System.out.println(counter.allow(ip));
        System.out.println(counter.allow(ip));
        System.out.println(counter.allow(ip));
    }
}