Java防重复提交案例怎么开发

wen java案例 2026-06-30 29

Java防重复提交：从原理到实战的完整开发指南（附代码案例）

目录导读

为什么需要防重复提交？
防重复提交的核心原理
5种主流实现方案对比
实战案例：基于Redis+注解的完整实现
常见问题与避坑指南
QA问答：开发者最关心的5个问题

为什么需要防重复提交？

在实际开发中，用户因网络延迟、误操作或恶意攻击，多次点击提交按钮,会导致：

Java防重复提交案例怎么开发

数据库重复插入相同记录（如订单、报名）
接口幂等性被破坏，数据逻辑混乱
服务器资源浪费，甚至引发雪崩

防重复提交是保障系统稳定性和数据一致性的基础能力，尤其在高并发场景（秒杀、表单提交）下尤为重要。

防重复提交的核心原理

所有方案的共同思路：同一请求在限定时间内，仅允许执行一次。
核心机制：

唯一标识生成：基于用户ID、请求参数、时间戳等生成Token或哈希值。
缓存/数据库校验：利用Redis的key过期机制或数据库唯一索引，实现“一次有效”。
请求拦截时机：在Controller层通过拦截器或AOP切面统一处理。

5种主流实现方案对比

方案	适用场景	优点	缺点
前端按钮置灰	简单表单	实现简单	无法防止恶意请求
Token令牌（前后端分离）	需要后端校验	防止重复提交	需要单独获取token
Redis分布式锁	高并发	性能高，跨进程	需考虑锁释放
数据库唯一索引	业务约束	保证最终一致性	依赖数据库性能
AOP+注解+Redis	通用场景	无侵入，灵活	需要引入Redis

推荐方案：结合Redis+AOP+自定义注解，兼顾性能、易用性与可维护性。

实战案例：基于Redis+注解的完整实现

步骤1：引入依赖（Maven/Gradle）

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
    <groupId>org.aspectj</groupId>
    <artifactId>aspectjweaver</artifactId>
</dependency>

步骤2：定义防重复提交注解

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface PreventRepeatSubmit {
    // 防重复提交的时间间隔（秒），默认5秒
    long interval() default 5;
    // 提示信息
    String message() default "请勿重复提交，稍后再试";
}

步骤3：编写AOP切面

@Aspect
@Component
public class RepeatSubmitAspect {
    @Autowired
    private StringRedisTemplate redisTemplate;
    @Around("@annotation(preventRepeatSubmit)")
    public Object around(ProceedingJoinPoint joinPoint, PreventRepeatSubmit prevent) throws Throwable {
        // 生成唯一标识：用户ID + 请求路径 + 参数哈希
        HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
        String userId = request.getHeader("userId");
        String requestURI = request.getRequestURI();
        String paramHash = getParamHash(joinPoint.getArgs());
        String key = "repeat:" + userId + ":" + requestURI + ":" + paramHash;
        // Redis原子操作：SET NX EX
        Boolean success = redisTemplate.opsForValue().setIfAbsent(key, "1", prevent.interval(), TimeUnit.SECONDS);
        if (Boolean.TRUE.equals(success)) {
            return joinPoint.proceed();
        } else {
            throw new RuntimeException(prevent.message());
        }
    }
    private String getParamHash(Object[] args) {
        // 使用Google Guava的Hashing生成固定长度哈希，避免key过长
        return Hashing.murmur3_128().hashString(Arrays.toString(args), Charset.defaultCharset()).toString();
    }
}

步骤4：在Controller中使用注解

@RestController
public class OrderController {
    @PostMapping("/create")
    @PreventRepeatSubmit(interval = 10, message = "订单已提交，请稍后再试")
    public Result createOrder(@RequestBody OrderDTO order) {
        // 业务处理
        return Result.success();
    }
}

步骤5：全局异常处理（捕获重复提交异常）

@ControllerAdvice
public class GlobalExceptionHandler {
    @ExceptionHandler(RuntimeException.class)
    @ResponseBody
    public Result handleRepeatSubmit(RuntimeException e) {
        return Result.error(e.getMessage());
    }
}