Spring Boot防重实战：Redis缓存+哈希锁方案性能测评

首页

科技

热心网友

转载

2025-10-30

本文将介绍一种基于“哈希 + 缓存”双重防护机制的接口防重复提交方案，无需前端配合，不依赖额外 Token，仅通过请求特征动态生成哈希签名即可快速识别重复请求。我们将采用 Spring Boot + AOP + Redis/Caffeine 架构实现这一机制，整体方案轻量高效，具备实战级复用价值。

在高并发业务场景中，接口被重复点击或短时间内多次提交请求，是常见却极具破坏性的隐患。例如在电商系统中，用户多次点击“提交订单”按钮可能导致重复订单生成；支付接口被异常触发可能造成重复扣费；表单接口因网络波动被重复提交，极易产生脏数据。

这类问题虽看似小概率事件，但在真实生产环境中往往引发严重后果。为规避此类“重复提交”带来的混乱，我们需要在服务端层面构建一个高可靠的防重机制。

本方案通过构建全局唯一哈希值，结合动态缓存实现高效防重。当检测到相同哈希值在有效期内重复出现时，系统将自动拦截并返回提示，从源头杜绝数据异常。

防重原理与方案选型

什么是防重复提交

防重复提交（Prevent Duplicate Request）指防止用户在短时间内对同一接口重复触发操作，从而避免数据重复创建、状态异常或业务逻辑错误。

典型场景包括：

下单接口防止同一用户创建两笔相同订单；表单提交避免页面卡顿或多次点击产生重复记录；支付操作防止短时间内重复支付。

常见实现方式

本方案采用第三种方式，通过 URL + 请求方法 + 请求参数构建全局唯一哈希值，并将其存储在缓存中。当系统检测到相同哈希值在有效期内再次出现时，即判定为重复请求。

系统架构与流程设计

目录结构如下

/src 
├── /main
│   └── /java/com/icoderoad/duplicate
│       ├── annotation/PreventDuplicate.java
│       ├── aspect/PreventDuplicateAspect.java
│       ├── storage/DuplicateStorage.java
│       ├── storage/impl/RedisStorage.java
│       ├── storage/impl/CaffeineStorage.java
│       └── util/RequestParameterUtils.java
└── /resources
    └── application.yml

防重复机制核心流程如下：

请求进入控制层；AOP 拦截目标方法；提取 URL、请求方法、参数信息；计算 SHA-256 哈希值作为 Key；查询缓存是否存在该 Key；存在则拒绝请求，不存在则执行方法并写入缓存。

核心实现代码

自定义注解 `@PreventDuplicate`

package com.icoderoad.duplicate.annotation;

import java.lang.annotation.*;
import java.util.concurrent.TimeUnit;

/**
 * 防重复提交注解 
 * 可应用在 Controller 层接口上 
 */
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface PreventDuplicate {
    /** 防重复提交时间（单位：秒） */
    int expire() default 3;
    
    /** 时间单位，默认秒 */
    TimeUnit timeUnit() default TimeUnit.SECONDS;
    
    /** 可指定参与生成哈希的主要字段 */
    String[] field() default {};
    
    /** 提示信息 */
    String message() default "请勿重复提交！";
}

AOP 拦截器 `PreventDuplicateAspect`

package com.icoderoad.duplicate.aspect;

import cn.hutool.crypto.digest.DigestUtil;
import com.icoderoad.duplicate.annotation.PreventDuplicate;
import com.icoderoad.duplicate.storage.DuplicateStorage;
import com.icoderoad.duplicate.storage.DuplicateStorageFactory;
import com.icoderoad.duplicate.util.RequestParameterUtils;
import jakarta.servlet.http.HttpServletRequest;
import lombok.RequiredArgsConstructor;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.stereotype.Component;

@Aspect
@Component
@RequiredArgsConstructor
public class PreventDuplicateAspect {
    private final HttpServletRequest request;
    private final DuplicateStorageFactory storageFactory;
    
    @Around("@annotation(preventDuplicate)")
    public Object handle(ProceedingJoinPoint joinPoint, PreventDuplicate preventDuplicate) throws Throwable {
        String method = request.getMethod();
        String uri = request.getRequestURI();
        String params = RequestParameterUtils.getAllParamsAsString(joinPoint, preventDuplicate.field());
        
        // 拼接唯一签名源
        String signSource = method + ":" + uri + ":" + params;
        long start = System.currentTimeMillis();
        String key = DigestUtil.sha256Hex(signSource);
        long end = System.currentTimeMillis();
        System.out.println("生成哈希耗时：" + (end - start) + "ms");
        
        DuplicateStorage storage = storageFactory.getStorage();
        if (storage.exists(key)) {
            throw new RuntimeException(preventDuplicate.message());
        }
        storage.put(key, preventDuplicate.expire(), preventDuplicate.timeUnit());
        return joinPoint.proceed();
    }
}

控制层示例

package com.icoderoad.duplicate.controller;

import com.icoderoad.duplicate.annotation.PreventDuplicate;
import com.icoderoad.duplicate.model.ArticleDTO;
import com.icoderoad.duplicate.model.UserInfo;
import org.springframework.web.bind.annotation.*;

@RestController
@RequestMapping("/demo")
public class DemoController {
    @GetMapping("/hello")
    @PreventDuplicate
    public String hello(String name, String age, String address) {
        return "防重复测试：" + name + " " + age + " " + address;
    }
    
    @PostMapping("/saveUserInfo")
    @PreventDuplicate(expire = 5)
    public String saveUserInfo(@RequestBody UserInfo userInfo) {
        System.out.println(userInfo);
        return "请求时间：" + DateTime.now() + " 保存成功";
    }
    
    @PostMapping("/saveContent")
    @PreventDuplicate(expire = 10)
    public String saveContent(@RequestBody ArticleDTO articleDTO) {
        System.out.println(articleDTO);
        return "请求时间：" + DateTime.now() + " 内容保存成功";
    }
}