// 1. 生成幂等Token@RestController@RequestMapping("/idempotent")publicclassIdempotentController{@AutowiredprivateStringRedisTemplateredisTemplate;// 获取幂等Token@GetMapping("/getToken")publicRgetToken(){Stringtoken=UUID.randomUUID().toString();// 过期时间10分钟redisTemplate.opsForValue().set("idempotent:token:"+token,"1",10,TimeUnit.MINUTES);returnR.ok(token);}}

自定义注解 + 拦截器

@Target(ElementType.METHOD)@Retention(RetentionPolicy.RUNTIME)public@interfaceIdempotent{}

@ComponentpublicclassIdempotentInterceptorimplementsHandlerInterceptor{@AutowiredprivateStringRedisTemplateredisTemplate;@OverridepublicbooleanpreHandle(HttpServletRequestrequest,HttpServletResponseresponse,Objecthandler){// 非注解方法直接放行if(!(handlerinstanceofHandlerMethod)){returntrue;}HandlerMethodmethod=(HandlerMethod)handler;if(!method.hasMethodAnnotation(Idempotent.class)){returntrue;}// 获取请求头TokenStringtoken=request.getHeader("idempotent-token");if(StringUtils.isEmpty(token)){thrownewRuntimeException("非法请求，缺少幂等令牌");}Stringkey="idempotent:token:"+token;// 原子操作：删除成功=第一次请求；删除失败=重复请求Booleandelete=redisTemplate.delete(key);if(Boolean.FALSE.equals(delete)){thrownewRuntimeException("请求重复提交，禁止重复操作");}returntrue;}}

业务接口使用

@PostMapping("/submit")@IdempotentpublicRsubmitOrder(){// 正常下单业务returnR.ok("下单成功");}

二、限流体系总览

限流3种实现层级

应用层单机限流：Guava RateLimiter（单机、简单）
网关层分布式限流：Nginx+Lua（全局、高性能）
分布式中间件限流：Sentinel/Redis+Lua（微服务常用）

限流核心算法

令牌桶：Guava 默认，突发流量友好
漏桶：固定流出速率，抗突发差
滑动窗口：平滑限流，Sentinel常用

三、Guava 单机限流（令牌桶）

1. 流程图

2. 引入依赖

<dependency><groupId>com.google.guava</groupId><artifactId>guava</artifactId><version>31.1-jre</version></dependency>

3. 完整代码案例

@RestController@RequestMapping("/limit")publicclassGuavaLimitController{// 每秒放行 5 个请求：令牌桶容量=5privatestaticfinalRateLimiterRATE_LIMITER=RateLimiter.create(5.0);@GetMapping("/guava")publicRguavaLimit(){// 尝试获取令牌，非阻塞booleanacquire=RATE_LIMITER.tryAcquire();if(!acquire){returnR.error("系统繁忙，请求限流，请稍后重试");}returnR.ok("请求正常处理");}}

特点

✅ 轻量、零配置、代码极简
❌单机限流，集群环境失效
✅ 令牌桶，支持突发流量

四、Nginx + Lua 分布式限流（生产常用）

1. 架构流程图

3. Nginx + Lua 完整配置

1）Nginx 配置`nginx.conf`

http { # 加载lua脚本 lua_package_path "/usr/local/nginx/lua/?.lua;;"; server { listen 80; server_name localhost; location /api/ { # 执行限流lua脚本 access_by_lua_file /usr/local/nginx/lua/limit.lua; # 转发后端服务 proxy_pass http://127.0.0.1:8080; proxy_set_header Host $host; } } }

2）Lua脚本`limit.lua`（Redis滑动窗口限流）

-- 连接redislocalredis=require"resty.redis"localred=redis:new()red:set_timeout(1000)localok,err=red:connect("127.0.0.1",6379)ifnot okthenngx.log(ngx.ERR,"redis连接失败: ",err)returnend-- 限流参数locallimit_key="nginx:limit:api"localnow=ngx.time()localwindow=60-- 时间窗口：60秒localmax_count=100-- 单窗口最大请求数-- 1. 移除窗口外过期数据red:zremrangebyscore(limit_key,0,now-window)-- 2. 统计当前窗口请求数localcount=red:zcard(limit_key)iftonumber(count)>=max_countthen-- 触发限流，直接返回ngx.status=429ngx.say("{\"code\":429,\"msg\":\"请求过于频繁，已被限流\"}")ngx.exit(429)end-- 3. 记录当前请求red:zadd(limit_key,now,now..math.random())red:expire(limit_key,window)

4. 特点

✅分布式全局限流，集群生效
✅ 网关层拦截，减轻后端压力
✅ 高性能，适合高并发项目
❌ Nginx+Lua 有一定运维成本

五、三种方案横向对比（面试必背）

限流方案	底层	范围	性能	适用场景
Guava RateLimiter	令牌桶	单机	极高	单体项目、简单内部接口
Nginx+Lua	Redis+滑动窗口	分布式全局	超高	对外API、网关统一限流
Sentinel	滑动窗口	微服务分布式	高	SpringCloud 微服务体系