java实现单机限流

Java实现单机限流，可以通过限制每秒钟能处理多少次请求、对同一IP的请求进行限制等手段来避免服务被恶意请求压垮。下面是实现单机限流的完整攻略：

步骤一：引入限流工具包

Java实现单机限流可以使用开源限流工具包，比如Guava、Redis等。

以Guava为例，引入Guava限流工具包的步骤如下：

1. 在pom.xml文件中添加以下依赖

<dependency>
    <groupId>com.google.guava</groupId>
    <artifactId>guava</artifactId>
    <version>28.2-jre</version>
</dependency>

1. 在Java代码中引入以下类

import com.google.common.util.concurrent.RateLimiter;

步骤二：使用限流工具

使用Guava实现请求限流的步骤如下：

1. 创建一个RateLimiter实例，使用RateLimiter.create()方法传入每秒钟允许处理的请求数作为参数。例如，RateLimiter.create(10)表示在每秒钟最多处理10个请求。

RateLimiter rateLimiter = RateLimiter.create(10);

1. 在业务代码中使用tryAcquire()方法对请求进行限流。该方法会返回一个boolean值，表示这个请求是否被允许通过。如果返回true，则表示请求未被限流；如果返回false，则表示请求被限流了。

if (rateLimiter.tryAcquire()) {
    // 执行业务逻辑
} else {
   // 返回限流提示信息
}

以限制某个接口一分钟内只能请求10次为例，示例代码如下：

public class RequestLimit {
    private static final RateLimiter rateLimiter = RateLimiter.create(0.16667);

    public static boolean tryAcquire() {
        return rateLimiter.tryAcquire();
    }

    public static void main(String[] args) {
        for (int i = 1; i <= 15; i++) {
            if (tryAcquire()) {
                System.out.println("第" + i + "次请求成功");
            } else {
                System.out.println("第" + i + "次请求失败，限流了");
            }
        }
    }
}

上述代码中，每秒钟允许处理0.16667个请求，相当于一分钟内只允许处理10次请求。执行main()方法后，可以看到输出结果如下：

第1次请求成功
第2次请求失败，限流了
第3次请求失败，限流了
第4次请求失败，限流了
第5次请求成功
第6次请求失败，限流了
第7次请求失败，限流了
第8次请求失败，限流了
第9次请求成功
第10次请求失败，限流了
第11次请求失败，限流了
第12次请求失败，限流了
第13次请求成功
第14次请求失败，限流了
第15次请求失败，限流了

另外，对于同一IP的请求限制，可以通过在RateLimiter.create()方法中传入每秒钟允许处理的IP数量来实现。实现示例代码可参考上述代码，只需将限流粒度由请求改为IP即可。