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

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

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

前言

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

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

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

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

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

這里使用了ConcurrentHashMap作為緩存來實(shí)現(xiàn)，當(dāng)然在實(shí)際操作的時(shí)候還可以使用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ù)請(qǐng)求會(huì)被攔截
 
    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; // 請(qǐng)求被攔截
            }
        }
        CACHE.put(key, now);
        return false; // 請(qǐng)求通過
    }
}

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

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)碼表示請(qǐng)求過多
            response.setStatus(HttpServletResponse.SC_TOO_MANY_REQUESTS); 
            return false;
        }
        return true;
    }
}

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

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

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

通過在請(qǐng)求中添加Token，在一定時(shí)間內(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會(huì)被攔截
 
    public boolean shouldIntercept(HttpServletRequest request) {
        String token = request.getHeader("X-Request-Token");
        if (StringUtils.isEmpty(token)) {
            return false; // 請(qǐng)求通過，沒有Token
        }
        long now = System.currentTimeMillis();
        if (CACHE.containsKey(token)) {
            long lastRequestTime = CACHE.get(token);
            if (now - lastRequestTime < EXPIRE_TIME) {
                return true; // 請(qǐng)求被攔截
            }
        }
        CACHE.put(token, now);
        return false; // 請(qǐng)求通過
    }
}

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

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

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

定義注解類

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

創(chuàng)建切面類來實(shí)現(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; // 請(qǐng)求被攔截
            }
        }
        CACHE.put(key, now);
        return joinPoint.proceed(); // 請(qǐng)求通過
    }
}

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