java滑动窗口流量控制

滑动窗口是一种常用的流量控制机制，可以用于限制数据流经过某个节点的速率。在Java中，我们可以通过使用计时器和队列来实现滑动窗口流量控制。

以下是一个简单的示例代码，演示了如何使用滑动窗口来控制流量：

import java.util.ArrayDeque;
import java.util.Queue;
import java.util.Timer;
import java.util.TimerTask;

public class SlidingWindow {
    private final int windowSize;
    private final int maxRequestsPerSecond;
    private final Queue<Long> requests;

    public SlidingWindow(int windowSize, int maxRequestsPerSecond) {
        this.windowSize = windowSize;
        this.maxRequestsPerSecond = maxRequestsPerSecond;
        this.requests = new ArrayDeque<>();
    }

    public boolean isAllowed() {
        long currentTime = System.currentTimeMillis();
        requests.add(currentTime);

        if (requests.size() > maxRequestsPerSecond) {
            long oldestRequestTime = requests.poll();
            if (currentTime - oldestRequestTime <= windowSize) {
                return false;
            }
        }

        return true;
    }

    public static void main(String[] args) {
        SlidingWindow slidingWindow = new SlidingWindow(1000, 10);  // 设置窗口大小为1秒，最大每秒请求数为10

        Timer timer = new Timer();
        timer.schedule(new TimerTask() {
            @Override
            public void run() {
                if (slidingWindow.isAllowed()) {
                    System.out.println("Request allowed");
                } else {
                    System.out.println("Request blocked");
                }
            }
        }, 0, 100);  // 每100毫秒发送一个请求

        try {
            Thread.sleep(5000);  // 运行5秒钟
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        timer.cancel();
    }
}

在上面的示例代码中，`SlidingWindow` 类代表滑动窗口流量控制器。构造函数中的 `windowSize` 参数表示窗口的时间大小（以毫秒为单位），`maxRequestsPerSecond` 参数表示窗口内允许通过的最大请求数。

`isAllowed()` 方法用于检查当前请求是否被允许。它会记录当前请求的时间戳，并将其加入到请求队列中。如果队列长度超过了最大请求数，那么就会取出队列中最旧的请求时间戳，并检查当前时间与最旧请求时间的差值是否小于窗口大小。如果小于窗口大小，说明窗口内请求数已经达到了最大限制，请求会被拒绝；否则，请求会被允许。

在 `main` 方法中，我们创建了一个 `SlidingWindow` 对象，并使用定时器每100毫秒发送一个请求。运行5秒钟后，我们取消定时器。

这只是一个简单的演示示例，实际应用中可能需要根据具体需求进行适当的调整和优化。