别再让接口乱跑！SpringBoot实现接口幂等性的4大实战方案，彻底告别重复提交！

package com.icoderoad.order;
import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.core.StringRedisTemplate;import org.springframework.web.bind.annotation.*;import java.time.Duration;import java.util.UUID;
@RestController@RequestMapping("/order")public class OrderController {
    @Autowired    private StringRedisTemplate redis;
    // ① 预生成 Token，供前端使用    @GetMapping("/token")    public String getToken() {        String token = UUID.randomUUID().toString();        redis.opsForValue().set("tk:" + token, "1", Duration.ofMinutes(10));        return token;    }
    // ② 下单接口，Header 中携带令牌    @PostMapping    public Result create(@RequestHeader("Idempotent-Token") String token,                         @RequestBody OrderReq req) {        String key = "tk:" + token;        Boolean first = redis.delete(key);        if (Boolean.FALSE.equals(first)) {            return Result.fail("请勿重复下单");        }        Order order = orderService.create(req);        return Result.ok(order);    }}

package com.icoderoad.payment;
import org.springframework.beans.factory.annotation.Autowired;import org.springframework.dao.DataIntegrityViolationException;import org.springframework.stereotype.Service;
import javax.persistence.*;import java.math.BigDecimal;
@Entity@Table(name = "t_payment", uniqueConstraints = @UniqueConstraint(columnNames = "transaction_id"))class Payment {    @Id    private Long id;
    @Column(name = "transaction_id")    private String txId;
    private BigDecimal amount;    private String status;}
@Servicepublic class PayService {
    @Autowired    private PaymentRepo repo;
    public Result pay(PayReq req) {        try {            Payment p = new Payment();            p.setTxId(req.getTxId());            p.setAmount(req.getAmount());            p.setStatus("SUCCESS");            repo.save(p);            return Result.ok("支付成功");        } catch (DataIntegrityViolationException e) {            Payment exist = repo.findByTxId(req.getTxId());            return Result.ok("已支付", exist.getId());        }    }}

package com.icoderoad.stock;
import org.redisson.api.RLock;import org.redisson.api.RedissonClient;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Service;
import java.util.concurrent.TimeUnit;
@Servicepublic class StockService {
    @Autowired    private RedissonClient redisson;    @Autowired    private StockRepo repo;
    public Result deduct(DeductCmd cmd) {        String lockKey = "lock:stock:" + cmd.getProductId();        RLock lock = redisson.getLock(lockKey);
        try {            if (!lock.tryLock(3, 5, TimeUnit.SECONDS)) {                return Result.fail("处理中，请稍后");            }            if (repo.existsByRequestId(cmd.getRequestId())) {                return Result.ok("已扣减");            }            repo.deductStock(cmd);            return Result.ok("扣减成功");        } catch (InterruptedException e) {            Thread.currentThread().interrupt();            return Result.fail("系统繁忙");        } finally {            if (lock.isHeldByCurrentThread()) {                lock.unlock();            }        }    }}

package com.icoderoad.common.aop;
import org.aspectj.lang.ProceedingJoinPoint;import org.aspectj.lang.annotation.*;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.core.StringRedisTemplate;import org.springframework.stereotype.Component;import org.springframework.util.DigestUtils;import org.apache.commons.io.IOUtils;
import javax.servlet.http.HttpServletRequest;import java.nio.charset.StandardCharsets;import java.time.Duration;
@Target(ElementType.METHOD)@Retention(RetentionPolicy.RUNTIME)public @interface Idempotent {    int expire() default 3600; // 秒}
@Aspect@Componentpublic class IdempotentAspect {
    @Autowired    private StringRedisTemplate redis;
    @Around("@annotation(idem)")    public Object around(ProceedingJoinPoint pjp, Idempotent idem) throws Throwable {        HttpServletRequest req = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();        String body = IOUtils.toString(req.getReader());        String digest = DigestUtils.md5DigestAsHex(body.getBytes(StandardCharsets.UTF_8));        String key = "idem:digest:" + digest;
        Boolean absent = redis.opsForValue().setIfAbsent(key, "1", Duration.ofSeconds(idem.expire()));        if (Boolean.FALSE.equals(absent)) {            return Result.fail("重复请求");        }
        try {            return pjp.proceed();        } catch (Exception e) {            redis.delete(key);            throw e;        }    }}

@RestController@RequestMapping("/transfer")public class TransferController {
    @PostMapping    @Idempotent(expire = 7200)    public Result transfer(@RequestBody TransferCmd cmd) {        return Result.ok(transferSvc.doTransfer(cmd));    }}