限流算法之固定窗口算法

文章目录

原理
- 示例图
优缺点
- 优点
- 缺点
示例代码
- java
适用场景
不推荐
- 原因如下：

原理

固定窗口算法是一种常见的限流算法，它通过在固定长度的时间窗口内限制请求数量来实现限流。这种算法的原理是在每个时间窗口内，对到达的请求进行计数，如果计数达到限制值，则拒绝后续请求，直到窗口结束。

示例图

红色代表被拒绝的请求，绿色代表正常被放行的请求，阈值线为实际设置的窗口大小，仅供理解
在这里插入图片描述

优缺点

优点

易于理解：该实现使用了简单的队列和计数器，易于理解和实现。
高效：该实现使用了文件系统操作来检查文件是否存在和所在的目录是否符合限制，因此效率较高。
可扩展：该实现可以轻松地扩展到处理多个文件类型或目录。
持久化存储：通过使用目录结构，可以将数据持久化存储，以便在程序重启后继续使用。
灵活性：该实现可以根据需要调整窗口大小和目录结构，以适应不同的应用场景。
错误处理：该实现通过检查文件是否存在和目录结构是否正确，可以避免一些常见的错误情况。
并发访问：由于使用了文件系统操作，该实现可以在多线程环境下并发访问。

缺点

文件系统操作可能比较耗时：对于大型文件系统或大量事件的情况下，文件系统操作可能会成为性能瓶颈。这可以通过缓存或优化文件系统访问来解决。
误判风险：如果文件系统中的文件数量超过了窗口大小限制，该实现可能会拒绝一些合法的事件。这可以通过增加额外的检查或调整文件命名规则来减少误判的风险。
数据竞争：由于使用了文件系统操作，该实现可能存在数据竞争的问题。这可以通过使用同步机制或并发控制来解决。

示例代码

java

代码如下（示例）：

/**
 * @Date 2024/1/18 15:42
 * @Author yang
 */
public class FixedWindow {
    private int windowSize;
    private long[] timestamps;
    private int current;

    public FixedWindow(int windowSize) {
        this.windowSize = windowSize;
        this.timestamps = new long[windowSize];
        this.current = 0;
    }

    public void addTimestamp(long timestamp) {
        System.out.println("时间" + timestamp);
        System.out.println("当前" + current);
        timestamps[current] = timestamp;
        current = (current + 1) % windowSize;
    }

    public int getCountWithinWindow(long currentTime, long interval) {
        int count = 0;
        System.out.println("count" + count);
        for (int i = 0; i < windowSize; i++) {
            if (currentTime - timestamps[i] <= interval) {
                count++;
            }
        }
        return count;
    }

    public static void main(String[] args) {
        FixedWindow fixedWindow = new FixedWindow(5);
        fixedWindow.addTimestamp(System.currentTimeMillis() - 10000);
        fixedWindow.addTimestamp(System.currentTimeMillis() - 8000);
        fixedWindow.addTimestamp(System.currentTimeMillis() - 5000);
        fixedWindow.addTimestamp(System.currentTimeMillis() - 2000);
        fixedWindow.addTimestamp(System.currentTimeMillis() - 1000);
        System.out.println("最近5秒内发生的事件: " + fixedWindow.getCountWithinWindow(System.currentTimeMillis(), 5000));
    }
}