在构建高并发Web应用时，接口限流是一种重要的技术手段，用于防止系统因请求过多而导致的资源耗尽、服务质量下降甚至崩溃。在Spring Boot中，我们可以使用Google的Guava库来实现接口限流。本文将详细介绍如何在Spring Boot项目中利用Guava的RateLimiter类来实现接口限流，并提供相应的例子代码。

Guava RateLimiter 简介

Guava是Google提供的一个Java开发库，其中包含了许多实用的工具类和功能。RateLimiter是Guava库中的一个工具类，它基于令牌桶算法来实现流量限制。通过RateLimiter，我们可以控制对某个接口的访问速率，从而保护系统免受过多请求的影响。

实现步骤

1. 引入Guava依赖

首先，我们需要在Spring Boot项目的pom.xml文件中添加Guava库的依赖。以下是一个示例依赖配置：

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

2. 创建RateLimiterService类

接下来，我们创建一个RateLimiterService类，用于实现接口限流的逻辑。在这个类中，我们将使用RateLimiter.create(double permitsPerSecond)方法创建一个RateLimiter对象，并在处理请求之前调用acquire()方法来获取对请求的许可。

import com.google.common.util.concurrent.RateLimiter;
import org.springframework.stereotype.Service;

@Service
public class RateLimiterService {
    private final RateLimiter rateLimiter = RateLimiter.create(10); // 每秒最多处理10个请求

    public void processRequest() {
        rateLimiter.acquire(); // 获取许可
        // 处理请求的逻辑
    }
}

3. 在Controller中使用RateLimiterService

在Spring Boot的Controller层，我们可以通过注入RateLimiterService来使用接口限流功能。以下是一个示例Controller：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MyController {
    @Autowired
    private RateLimiterService rateLimiterService;

    @GetMapping("/my-api")
    public String myApi() {
        rateLimiterService.processRequest(); // 处理接口请求的逻辑
        return "success";
    }
}

例子代码总结

以下是完整的例子代码，包括依赖配置、RateLimiterService类以及Controller类。

1. pom.xml

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

2. RateLimiterService.java

import com.google.common.util.concurrent.RateLimiter;
import org.springframework.stereotype.Service;

@Service
public class RateLimiterService {
    private final RateLimiter rateLimiter = RateLimiter.create(10); // 每秒最多处理10个请求

    public void processRequest() {
        rateLimiter.acquire(); // 获取许可
        // 处理请求的逻辑
    }
}

3. MyController.java

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MyController {
    @Autowired
    private RateLimiterService rateLimiterService;

    @GetMapping("/my-api")
    public String myApi() {
        rateLimiterService.processRequest(); // 处理接口请求的逻辑
        return "success";
    }
}

注意事项

1. 限流速率调整：在实际应用中，可以根据系统的负载和性能需求来调整RateLimiter的创建参数，即每秒发放的令牌数。

2. 异常处理：在processRequest方法中，如果请求量超过限流速率，acquire方法将会阻塞直到有许可可用。在实际应用中，可能需要添加适当的超时处理或异常处理逻辑。

3. 分布式限流：如果应用部署在分布式系统中，需要考虑使用分布式限流方案，如基于Redis的RateLimiter实现。

通过以上步骤，我们可以在Spring Boot项目中利用Guava库方便地实现API限流功能，从而保护系统免受过多请求的影响，提高系统的稳定性和可用性。