快捷導(dǎo)航

SpringBoot接口防抖的5種高效方案

更新時間：2026年01月27日 10:07:26 作者：程序員西西

本文主要介紹了SpringBoot接口防抖的5種高效方案,包括基于緩存、基于Token和基于注解的實現(xiàn)方法,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

前言

接口防抖是一種用于限制用戶重復(fù)提交請求的機制。在Web開發(fā)中，用戶可能會因為網(wǎng)絡(luò)延遲或者多次點擊按鈕而導(dǎo)致多次提交同一個請求，這可能會對系統(tǒng)產(chǎn)生不必要的壓力，或者導(dǎo)致數(shù)據(jù)異常。接口防抖就是為了解決這個問題而設(shè)計的。

接口防抖的基本原理是，在接收到一個請求后，服務(wù)器會在一定的時間內(nèi)暫時忽略后續(xù)相同的請求，直到這段時間過去，才會再次處理新的請求。這樣可以有效地避免重復(fù)提交導(dǎo)致的問題。

常見的接口防抖實現(xiàn)方式包括基于緩存、基于Token、基于攔截器等。在Spring Boot中，我們可以利用攔截器、過濾器或者切面等機制來實現(xiàn)接口防抖功能。

下面我們就來看看在SpringBoot中如何實現(xiàn)這些操作。

基于緩存實現(xiàn)防抖

這里使用了ConcurrentHashMap作為緩存來實現(xiàn)，當然在實際操作的時候還可以使用Redis緩存或者是Memcached來作為緩存操作。

@Component
public class DebounceInterceptor {
 
    private static final ConcurrentHashMap<String, Long> CACHE = 
      new ConcurrentHashMap<>();
    private static final long EXPIRE_TIME = 5000; // 5秒內(nèi)重復(fù)請求會被攔截
 
    public boolean shouldIntercept(HttpServletRequest request) {
        String key = request.getMethod() + ":" + request.getRequestURI() + ":" 
          + request.getParameterMap();
        long now = System.currentTimeMillis();
        if (CACHE.containsKey(key)) {
            long lastRequestTime = CACHE.get(key);
            if (now - lastRequestTime < EXPIRE_TIME) {
                return true; // 請求被攔截
            }
        }
        CACHE.put(key, now);
        return false; // 請求通過
    }
}

在上面的代碼中，我們使用ConcurrentHashMap來存儲請求信息，其中key是請求的方法、URL和參數(shù)，value是請求的時間戳。如果同樣的請求在5秒內(nèi)重復(fù)出現(xiàn)，則會被攔截。然后，我們創(chuàng)建一個攔截器來應(yīng)用這個防抖邏輯，如下所示。

public class DebounceInterceptor implements HandlerInterceptor {
 
    @Autowired
    private DebounceService debounceService;
 
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, 
                             Object handler) throws Exception {
        if (debounceService.shouldIntercept(request)) {
               // 返回429狀態(tài)碼表示請求過多
            response.setStatus(HttpServletResponse.SC_TOO_MANY_REQUESTS); 
            return false;
        }
        return true;
    }
}

最后，在配置類中注冊這個攔截器。如下所示。

@Configuration
public class WebMvcConfig implements WebMvcConfigurer {
 
    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(new DebounceInterceptor()).addPathPatterns("/**");
    }
}

基于Token實現(xiàn)防抖

通過在請求中添加Token，在一定時間內(nèi)禁止相同的Token重復(fù)提交，代碼如下所示。

@Component
public class TokenInterceptor {
 
    private static final ConcurrentHashMap<String, Long> CACHE = 
      new ConcurrentHashMap<>();
    private static final long EXPIRE_TIME = 5000; // 5秒內(nèi)重復(fù)Token會被攔截
 
    public boolean shouldIntercept(HttpServletRequest request) {
        String token = request.getHeader("X-Request-Token");
        if (StringUtils.isEmpty(token)) {
            return false; // 請求通過，沒有Token
        }
        long now = System.currentTimeMillis();
        if (CACHE.containsKey(token)) {
            long lastRequestTime = CACHE.get(token);
            if (now - lastRequestTime < EXPIRE_TIME) {
                return true; // 請求被攔截
            }
        }
        CACHE.put(token, now);
        return false; // 請求通過
    }
}

在這種方法中，我們需要在請求頭中添加一個Token，然后使用ConcurrentHashMap來存儲Token和請求時間的映射關(guān)系。如果相同的Token在5秒內(nèi)重復(fù)出現(xiàn)，則會被攔截。然后，我們創(chuàng)建一個攔截器來應(yīng)用這個防抖邏輯，與上面的方法類似。

基于注解實現(xiàn)防抖

通過自定義注解來實現(xiàn)防抖，使得只需要在需要防抖的接口上添加注解即可。

定義注解類

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Debounce {
    long value() default 5000; // 默認5秒內(nèi)重復(fù)請求會被攔截
}

創(chuàng)建切面類來實現(xiàn)攔截注解的操作。

@Aspect
@Component
public class DebounceAspect {
 
    private static final ConcurrentHashMap<String, Long> CACHE = 
      new ConcurrentHashMap<>();
 
    @Autowired
    private HttpServletRequest request;
 
    @Around("@annotation(debounce)")
    public Object debounce(ProceedingJoinPoint joinPoint, Debounce debounce) 
throws Throwable {
        String key = request.getMethod() + ":" + request.getRequestURI() + ":" 
          + request.getParameterMap();
        long now = System.currentTimeMillis();
        if (CACHE.containsKey(key)) {
            long lastRequestTime = CACHE.get(key);
            if (now - lastRequestTime < debounce.value()) {
                return null; // 請求被攔截
            }
        }
        CACHE.put(key, now);
        return joinPoint.proceed(); // 請求通過
    }
}

最后，在啟動類上添加@EnableAspectJAutoProxy注解，啟用切面代理功能。