<!-- Redis核心依賴(lài) -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- Redisson分布式限流 -->
<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.23.3</version>
</dependency>
<!-- Spring Cloud Gateway網(wǎng)關(guān) -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<!-- Nacos動(dòng)態(tài)配置（限流規(guī)則熱更新） -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
<!-- 熔斷降級(jí)（Sentinel，可選替換為Resilience4j） -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<!-- 工具類(lèi) -->
<dependency>
    <groupId>cn.hutool</groupId>
    <artifactId>hutool-all</artifactId>
    <version>5.8.23</version>
</dependency>
<!-- 本地降級(jí)限流（Guava） -->
<dependency>
    <groupId>com.google.guava</groupId>
    <artifactId>guava</artifactId>
    <version>32.1.3-jre</version>
</dependency>

spring:
  redis:
    host: 192.168.1.100 # 生產(chǎn)替換為Redis集群地址
    port: 6379
    password: prod_redis_123
    database: 2 # 限流專(zhuān)用庫(kù)，與業(yè)務(wù)隔離
    lettuce:
      pool:
        max-active: 50 # 最大連接數(shù)，按QPS調(diào)整
        max-idle: 20
        min-idle: 5
        max-wait: 3000ms # 連接超時(shí)，生產(chǎn)建議3s內(nèi)
    timeout: 2000ms # Redis操作超時(shí)
  # Nacos配置（動(dòng)態(tài)限流規(guī)則）
  cloud:
    nacos:
      config:
        server-addr: 192.168.1.101:8848
        namespace: prod
        group: DEFAULT_GROUP
        file-extension: yml
        shared-configs:
          - data-id: redis-limit-rules.yml # 限流規(guī)則統(tǒng)一配置文件
            group: DEFAULT_GROUP
            refresh: true # 支持熱更新

import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.redisson.config.ReadMode;
import org.redisson.config.SubscriptionMode;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RedissonConfig {
    // 從Nacos/配置文件讀取Redis集群地址
    @Value("${spring.redis.cluster.nodes}")
    private String clusterNodes;
    @Value("${spring.redis.password}")
    private String password;
    @Value("${spring.redis.database:0}")
    private int database;

    @Bean(destroyMethod = "shutdown")
    public RedissonClient redissonClient() {
        Config config = new Config();
        // 集群模式配置（生產(chǎn)核心）
        config.useClusterServers()
                .addNodeAddress(clusterNodes.split(","))
                .setPassword(password)
                .setDatabase(database)
                .setScanInterval(2000) // 節(jié)點(diǎn)掃描間隔
                .setMasterConnectionPoolSize(50) // 主節(jié)點(diǎn)連接池
                .setSlaveConnectionPoolSize(20) // 從節(jié)點(diǎn)連接池
                .setReadMode(ReadMode.SLAVE) // 讀從節(jié)點(diǎn)，分擔(dān)壓力
                .setSubscriptionMode(SubscriptionMode.SLAVE); // 訂閱從節(jié)點(diǎn)
        // 超時(shí)配置，避免Redis阻塞
        config.setConnectTimeout(2000);
        config.setTimeout(2000);
        return Redisson.create(config);
    }
}

spring:
  redis:
    cluster:
      nodes: redis://192.168.1.100:7001,redis://192.168.1.100:7002,redis://192.168.1.100:7003

-- 固定窗口限流Lua腳本（原子性）
-- KEYS[1]：限流key（如limit:api:order:192.168.1.1）
-- ARGV[1]：限流閾值（如100）
-- ARGV[2]：窗口過(guò)期時(shí)間（秒，如60）
local key = KEYS[1]
local limit = tonumber(ARGV[1])
local expire = tonumber(ARGV[2])

-- 原子計(jì)數(shù)
local current = redis.call('incr', key)
-- 首次計(jì)數(shù)，設(shè)置過(guò)期時(shí)間（避免內(nèi)存泄漏）
if current == 1 then
    redis.call('expire', key, expire)
end
-- 超過(guò)閾值返回0，否則返回1
if current > limit then
    return 0
else
    return 1
end

-- 滑動(dòng)窗口限流Lua腳本（原子性）
-- KEYS[1]：限流key（如limit:api:seckill:192.168.1.1）
-- ARGV[1]：限流閾值（如100）
-- ARGV[2]：窗口時(shí)長(zhǎng)（毫秒，如60000）
-- ARGV[3]：當(dāng)前請(qǐng)求時(shí)間戳（毫秒，如System.currentTimeMillis()）
local key = KEYS[1]
local limit = tonumber(ARGV[1])
local windowMs = tonumber(ARGV[2])
local now = tonumber(ARGV[3])
-- 窗口開(kāi)始時(shí)間：當(dāng)前時(shí)間 - 窗口時(shí)長(zhǎng)
local windowStart = now - windowMs

-- 1. 移除ZSet中過(guò)期的請(qǐng)求記錄（score < 窗口開(kāi)始時(shí)間）
redis.call('zremrangebyscore', key, 0, windowStart)
-- 2. 統(tǒng)計(jì)當(dāng)前窗口內(nèi)的請(qǐng)求數(shù)
local current = redis.call('zcard', key)
-- 3. 超過(guò)閾值，返回0拒絕
if current >= limit then
    return 0
end
-- 4. 未超閾值，添加當(dāng)前請(qǐng)求到ZSet（score=時(shí)間戳，value=唯一標(biāo)識(shí)避免重復(fù)）
redis.call('zadd', key, now, now .. math.random(10000))
-- 5. 設(shè)置ZSet過(guò)期時(shí)間，避免內(nèi)存泄漏（窗口時(shí)長(zhǎng)+1秒）
redis.call('expire', key, math.ceil(windowMs / 1000) + 1)
return 1

import cn.hutool.core.util.StrUtil;
import org.springframework.core.io.ClassPathResource;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.script.DefaultRedisScript;
import org.springframework.scripting.support.ResourceScriptSource;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.util.Collections;
import java.util.Objects;

/**
 * Redis Lua腳本限流通用工具類(lèi)（固定窗口+滑動(dòng)窗口）
 */
@Component
public class RedisLimitLuaUtil {
    @Resource
    private RedisTemplate<String, Object> redisTemplate;

    // 固定窗口腳本
    private DefaultRedisScript<Long> fixedWindowScript;
    // 滑動(dòng)窗口腳本
    private DefaultRedisScript<Long> slideWindowScript;

    // 限流key前綴，統(tǒng)一規(guī)范
    private static final String LIMIT_KEY_PREFIX = "limit:";

    /**
     * 初始化Lua腳本（項(xiàng)目啟動(dòng)時(shí)加載，避免重復(fù)加載）
     */
    @PostConstruct
    public void initScript() {
        // 固定窗口腳本初始化
        fixedWindowScript = new DefaultRedisScript<>();
        fixedWindowScript.setResultType(Long.class);
        fixedWindowScript.setScriptSource(new ResourceScriptSource(new ClassPathResource("lua/limit_fixed_window.lua")));

        // 滑動(dòng)窗口腳本初始化
        slideWindowScript = new DefaultRedisScript<>();
        slideWindowScript.setResultType(Long.class);
        slideWindowScript.setScriptSource(new ResourceScriptSource(new ClassPathResource("lua/limit_slide_window.lua")));
    }

    /**
     * 固定窗口限流判斷
     * @param limitDimension 限流維度（api/ip/user）
     * @param target 限流目標(biāo)（如接口名order/create、IP192.168.1.1、用戶(hù)ID1001）
     * @param limit 限流閾值
     * @param expire 窗口過(guò)期時(shí)間（秒）
     * @return true=允許，false=拒絕
     */
    public boolean fixedWindowLimit(String limitDimension, String target, int limit, int expire) {
        try {
            String key = generateLimitKey(limitDimension, target);
            // 執(zhí)行Lua腳本，原子判斷
            Long result = redisTemplate.execute(
                    fixedWindowScript,
                    Collections.singletonList(key),
                    limit,
                    expire
            );
            // 結(jié)果為1則允許，0則拒絕
            return Objects.nonNull(result) && result == 1;
        } catch (Exception e) {
            // Redis異常時(shí)，返回false觸發(fā)降級(jí)策略
            log.error("固定窗口限流Redis執(zhí)行異常，維度：{}，目標(biāo)：{}", limitDimension, target, e);
            return false;
        }
    }

    /**
     * 滑動(dòng)窗口限流判斷
     * @param limitDimension 限流維度（api/ip/user）
     * @param target 限流目標(biāo)
     * @param limit 限流閾值
     * @param windowMs 窗口時(shí)長(zhǎng)（毫秒）
     * @return true=允許，false=拒絕
     */
    public boolean slideWindowLimit(String limitDimension, String target, int limit, long windowMs) {
        try {
            String key = generateLimitKey(limitDimension, target);
            long now = System.currentTimeMillis();
            // 執(zhí)行Lua腳本，原子判斷
            Long result = redisTemplate.execute(
                    slideWindowScript,
                    Collections.singletonList(key),
                    limit,
                    windowMs,
                    now
            );
            return Objects.nonNull(result) && result == 1;
        } catch (Exception e) {
            log.error("滑動(dòng)窗口限流Redis執(zhí)行異常，維度：{}，目標(biāo)：{}", limitDimension, target, e);
            return false;
        }
    }

    /**
     * 生成限流key：limit:維度:目標(biāo)
     * 例：limit:ip:192.168.1.1、limit:api:order/create
     */
    private String generateLimitKey(String limitDimension, String target) {
        return StrUtil.format("{}{}:{}", LIMIT_KEY_PREFIX, limitDimension, target);
    }
}

import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

@RestController
@RequestMapping("/api/order")
public class OrderController {
    @Resource
    private RedisLimitLuaUtil redisLimitLuaUtil;
    @Resource
    private LimitDegradeUtil limitDegradeUtil; // 降級(jí)工具類(lèi)（后續(xù)實(shí)現(xiàn)）

    @PostMapping("/create")
    public Result createOrder(HttpServletRequest request) {
        // 1. 提取限流目標(biāo)（接口+IP雙維度，生產(chǎn)常用）
        String apiTarget = "order/create";
        String ipTarget = request.getRemoteAddr();
        // 2. 限流規(guī)則：接口每分鐘1000次，IP每分鐘100次
        boolean apiLimit = redisLimitLuaUtil.fixedWindowLimit("api", apiTarget, 1000, 60);
        boolean ipLimit = redisLimitLuaUtil.fixedWindowLimit("ip", ipTarget, 100, 60);
        // 3. 限流判斷+降級(jí)（Redis異常時(shí)觸發(fā)本地降級(jí)）
        if (!apiLimit || !ipLimit) {
            // 觸發(fā)降級(jí)：先嘗試本地兜底，失敗則返回限流提示
            if (!limitDegradeUtil.localLimitFallback(apiTarget)) {
                return Result.fail(429, "請(qǐng)求過(guò)于頻繁，請(qǐng)稍后再試");
            }
        }
        // 4. 執(zhí)行業(yè)務(wù)邏輯
        return Result.success("訂單創(chuàng)建成功");
    }
}

import org.redisson.api.RRateLimiter;
import org.redisson.api.RSemaphore;
import org.redisson.api.RateIntervalUnit;
import org.redisson.api.RateType;
import org.redisson.api.RedissonClient;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.concurrent.TimeUnit;

/**
 * Redisson限流工具類(lèi)（令牌桶+信號(hào)量）
 * 令牌桶：控制QPS，支持突發(fā)流量
 * 信號(hào)量：控制并發(fā)數(shù)，保護(hù)下游資源
 */
@Component
public class RedissonLimitUtil {
    @Resource
    private RedissonClient redissonClient;

    // 限流key前綴
    private static final String RATE_LIMIT_PREFIX = "rate:limit:";
    private static final String SEMAPHORE_PREFIX = "semaphore:limit:";

    /**
     * 令牌桶限流（獲取1個(gè)令牌，無(wú)超時(shí)）
     * @param target 限流目標(biāo)（如seckill/sku1001、gateway/api）
     * @param rate 令牌生成速率（如100）
     * @param rateInterval 令牌生成時(shí)間間隔（如1）
     * @param unit 時(shí)間單位（如SECONDS）
     * @param capacity 令牌桶最大容量（突發(fā)流量上限，如200）
     * @return true=獲取令牌成功，false=失敗
     */
    public boolean rateLimit(String target, int rate, int rateInterval, RateIntervalUnit unit, int capacity) {
        try {
            String key = RATE_LIMIT_PREFIX + target;
            // 獲取令牌桶實(shí)例（全局唯一，Redisson自動(dòng)緩存）
            RRateLimiter rateLimiter = redissonClient.getRateLimiter(key);
            // 初始化令牌桶規(guī)則（僅首次執(zhí)行有效，后續(xù)修改需調(diào)用setRate）
            rateLimiter.trySetRate(RateType.OVERALL, rate, rateInterval, unit, capacity);
            // 獲取1個(gè)令牌，無(wú)超時(shí)等待
            return rateLimiter.tryAcquire(1);
        } catch (Exception e) {
            log.error("Redisson令牌桶限流異常，目標(biāo)：{}", target, e);
            return false;
        }
    }

    /**
     * 令牌桶限流（帶超時(shí)等待，適合高并發(fā)突發(fā)場(chǎng)景）
     * @param target 限流目標(biāo)
     * @param rate 生成速率
     * @param rateInterval 時(shí)間間隔
     * @param unit 時(shí)間單位
     * @param capacity 桶容量
     * @param waitTime 超時(shí)等待時(shí)間
     * @param waitUnit 等待時(shí)間單位
     * @return true=成功，false=失敗
     */
    public boolean rateLimitWithWait(String target, int rate, int rateInterval, RateIntervalUnit unit,
                                     int capacity, long waitTime, TimeUnit waitUnit) {
        try {
            String key = RATE_LIMIT_PREFIX + target;
            RRateLimiter rateLimiter = redissonClient.getRateLimiter(key);
            rateLimiter.trySetRate(RateType.OVERALL, rate, rateInterval, unit, capacity);
            return rateLimiter.tryAcquire(1, waitTime, waitUnit);
        } catch (Exception e) {
            log.error("Redisson令牌桶限流（帶等待）異常，目標(biāo)：{}", target, e);
            return false;
        }
    }

    /**
     * 信號(hào)量限流（獲取1個(gè)許可，控制并發(fā)數(shù)）
     * @param target 限流目標(biāo)（如resource/mysql、resource/kafka）
     * @param permits 最大許可數(shù)（最大并發(fā)數(shù)）
     * @return true=成功，false=失敗
     */
    public boolean semaphoreLimit(String target, int permits) {
        try {
            String key = SEMAPHORE_PREFIX + target;
            RSemaphore semaphore = redissonClient.getSemaphore(key);
            // 初始化許可數(shù)（僅首次有效）
            if (!semaphore.isExists()) {
                semaphore.trySetPermits(permits);
            }
            // 獲取1個(gè)許可，無(wú)超時(shí)
            return semaphore.tryAcquire(1);
        } catch (Exception e) {
            log.error("Redisson信號(hào)量限流異常，目標(biāo)：{}", target, e);
            return false;
        }
    }

    /**
     * 信號(hào)量限流（帶超時(shí)，釋放許可必須在finally中執(zhí)行）
     * @param target 限流目標(biāo)
     * @param permits 最大并發(fā)數(shù)
     * @param waitTime 超時(shí)時(shí)間
     * @param unit 時(shí)間單位
     * @return RSemaphore實(shí)例（用于釋放許可），null=獲取失敗
     */
    public RSemaphore semaphoreLimitWithWait(String target, int permits, long waitTime, TimeUnit unit) {
        try {
            String key = SEMAPHORE_PREFIX + target;
            RSemaphore semaphore = redissonClient.getSemaphore(key);
            if (!semaphore.isExists()) {
                semaphore.trySetPermits(permits);
            }
            if (semaphore.tryAcquire(1, waitTime, unit)) {
                return semaphore;
            }
        } catch (Exception e) {
            log.error("Redisson信號(hào)量限流（帶等待）異常，目標(biāo)：{}", target, e);
        }
        return null;
    }

    /**
     * 釋放信號(hào)量許可（必須調(diào)用，避免資源泄漏）
     */
    public void releaseSemaphore(RSemaphore semaphore) {
        if (semaphore != null && semaphore.isAcquired()) {
            semaphore.release(1);
        }
    }
}

@RestController
@RequestMapping("/api/seckill")
public class SeckillController {
    @Resource
    private RedissonLimitUtil redissonLimitUtil;
    @Resource
    private LimitDegradeUtil limitDegradeUtil;

    @PostMapping("/buy/{skuId}")
    public Result seckill(@PathVariable String skuId) {
        String target = "seckill/sku" + skuId;
        // 限流規(guī)則：每秒生成100個(gè)令牌，桶容量200（支持200的突發(fā)流量）
        boolean acquire = redissonLimitUtil.rateLimitWithWait(
                target, 100, 1, RateIntervalUnit.SECONDS, 200,
                500, TimeUnit.MILLISECONDS // 超時(shí)等待500ms
        );
        if (!acquire) {
            if (!limitDegradeUtil.localLimitFallback(target)) {
                return Result.fail(429, "秒殺太火爆了，請(qǐng)稍后再試");
            }
        }
        // 執(zhí)行秒殺業(yè)務(wù)
        return Result.success("秒殺成功");
    }
}

@Service
public class OrderQueryService {
    @Resource
    private RedissonLimitUtil redissonLimitUtil;
    @Resource
    private LimitDegradeUtil limitDegradeUtil;

    public List<Order> queryOrderByUserId(Long userId) {
        String target = "resource/mysql/orderQuery";
        // 限流規(guī)則：最大并發(fā)數(shù)20（避免數(shù)據(jù)庫(kù)連接池打滿(mǎn)）
        RSemaphore semaphore = redissonLimitUtil.semaphoreLimitWithWait(
                target, 20, 1, TimeUnit.SECONDS
        );
        if (semaphore == null) {
            if (!limitDegradeUtil.localLimitFallback(target)) {
                throw new BusinessException(429, "當(dāng)前查詢(xún)?nèi)藬?shù)過(guò)多，請(qǐng)稍后再試");
            }
        }
        // 必須在finally中釋放許可，避免資源泄漏
        try {
            // 執(zhí)行數(shù)據(jù)庫(kù)查詢(xún)
            return orderMapper.selectByUserId(userId);
        } finally {
            redissonLimitUtil.releaseSemaphore(semaphore);
        }
    }
}

# 網(wǎng)關(guān)限流規(guī)則（key=路由ID，與gateway路由配置一致）
gateway:
  limit:
    rules:
      order-service: # 訂單服務(wù)路由ID
        enable: true # 是否開(kāi)啟限流
        target: gateway/order-service # 限流目標(biāo)
        rate: 200 # 令牌生成速率（QPS）
        rateInterval: 1 # 時(shí)間間隔（秒）
        capacity: 400 # 令牌桶容量
        waitTime: 500 # 超時(shí)等待時(shí)間（毫秒）
      seckill-service: # 秒殺服務(wù)路由ID
        enable: true
        target: gateway/seckill-service
        rate: 500
        rateInterval: 1
        capacity: 1000
        waitTime: 300
      default: # 全局默認(rèn)規(guī)則
        enable: true
        target: gateway/default
        rate: 1000
        rateInterval: 1
        capacity: 2000
        waitTime: 200

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.stereotype.Component;

import java.util.Map;

/**
 * 網(wǎng)關(guān)限流規(guī)則配置（Nacos熱更新）
 */
@Data
@Component
@RefreshScope // 開(kāi)啟配置熱更新
@ConfigurationProperties(prefix = "gateway.limit")
public class GatewayLimitRule {
    // key=路由ID，value=具體規(guī)則
    private Map<String, GatewayLimitItem> rules;

    @Data
    public static class GatewayLimitItem {
        private boolean enable; // 是否開(kāi)啟限流
        private String target; // 限流目標(biāo)
        private int rate; // 令牌速率
        private int rateInterval; // 時(shí)間間隔
        private int capacity; // 桶容量
        private long waitTime; // 超時(shí)等待時(shí)間（毫秒）
    }
}

import cn.hutool.core.util.StrUtil;
import org.redisson.api.RateIntervalUnit;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.http.HttpStatus;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;

import javax.annotation.Resource;
import java.util.Objects;

/**
 * Spring Cloud Gateway全局限流過(guò)濾器（Redisson令牌桶）
 * 優(yōu)先級(jí)最高，最先執(zhí)行
 */
@Component
public class GatewayLimitGlobalFilter implements GlobalFilter, Ordered {
    @Resource
    private RedissonLimitUtil redissonLimitUtil;
    @Resource
    private GatewayLimitRule gatewayLimitRule;
    @Resource
    private LimitDegradeUtil limitDegradeUtil;

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        ServerHttpRequest request = exchange.getRequest();
        ServerHttpResponse response = exchange.getResponse();
        // 1. 獲取當(dāng)前路由ID（gateway路由配置的ID）
        String routeId = exchange.getAttribute("org.springframework.cloud.gateway.support.ServerWebExchangeUtils.GATEWAY_ROUTE_ID");
        if (StrUtil.isBlank(routeId)) {
            routeId = "default"; // 無(wú)路由ID，使用默認(rèn)規(guī)則
        }
        // 2. 匹配限流規(guī)則
        GatewayLimitRule.GatewayLimitItem limitItem = gatewayLimitRule.getRules().get(routeId);
        if (Objects.isNull(limitItem) || !limitItem.isEnable()) {
            return chain.filter(exchange); // 未開(kāi)啟限流，直接放行
        }
        // 3. 執(zhí)行令牌桶限流
        boolean acquire = redissonLimitUtil.rateLimitWithWait(
                limitItem.getTarget(),
                limitItem.getRate(),
                limitItem.getRateInterval(),
                RateIntervalUnit.SECONDS,
                limitItem.getCapacity(),
                limitItem.getWaitTime(),
                java.util.concurrent.TimeUnit.MILLISECONDS
        );
        // 4. 限流判斷+降級(jí)
        if (!acquire) {
            // 觸發(fā)本地降級(jí)，失敗則返回429
            if (!limitDegradeUtil.localLimitFallback(limitItem.getTarget())) {
                response.setStatusCode(HttpStatus.TOO_MANY_REQUESTS);
                response.getHeaders().add("Content-Type", "application/json;charset=UTF-8");
                String errorMsg = "{"code":429,"msg":"網(wǎng)關(guān)限流：請(qǐng)求過(guò)于頻繁"}";
                return response.writeWith(Mono.just(response.bufferFactory().wrap(errorMsg.getBytes())));
            }
        }
        // 5. 放行，執(zhí)行后續(xù)過(guò)濾器
        return chain.filter(exchange);
    }

    /**
     * 過(guò)濾器優(yōu)先級(jí)：最高（Ordered.HIGHEST_PRECEDENCE）
     */
    @Override
    public int getOrder() {
        return Ordered.HIGHEST_PRECEDENCE;
    }
}

spring:
  cloud:
    gateway:
      routes:
        # 訂單服務(wù)路由（ID=order-service，與限流規(guī)則一致）
        - id: order-service
          uri: lb://order-service # 負(fù)載均衡到訂單服務(wù)
          predicates:
            - Path=/api/order/**
          filters:
            - StripPrefix=1 # 去除/api前綴
        # 秒殺服務(wù)路由（ID=seckill-service，與限流規(guī)則一致）
        - id: seckill-service
          uri: lb://seckill-service
          predicates:
            - Path=/api/seckill/**
          filters:
            - StripPrefix=1
        # 全局默認(rèn)路由
        - id: default
          uri: lb://common-service
          predicates:
            - Path=/**

import com.google.common.util.concurrent.RateLimiter;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * 限流降級(jí)工具類(lèi)（Redis異常時(shí)本地兜底）
 * 基于Guava RateLimiter實(shí)現(xiàn)本地令牌桶限流
 */
@Component
public class LimitDegradeUtil {
    // 本地限流實(shí)例緩存：key=限流目標(biāo)，value=Guava RateLimiter
    private final Map<String, RateLimiter> localRateLimiterMap = new ConcurrentHashMap<>();
    // 本地默認(rèn)QPS（可從Nacos動(dòng)態(tài)配置）
    private static final double DEFAULT_LOCAL_QPS = 50.0;

    /**
     * 初始化核心目標(biāo)的本地限流規(guī)則（生產(chǎn)建議從Nacos加載）
     */
    @PostConstruct
    public void initLocalLimit() {
        // 秒殺服務(wù)本地兜底QPS=10
        localRateLimiterMap.put("seckill/sku1001", RateLimiter.create(10.0));
        // 訂單服務(wù)本地兜底QPS=20
        localRateLimiterMap.put("order/create", RateLimiter.create(20.0));
        // 網(wǎng)關(guān)全局本地兜底QPS=100
        localRateLimiterMap.put("gateway/default", RateLimiter.create(100.0));
    }

    /**
     * 本地限流兜底方法
     * @param target 限流目標(biāo)
     * @return true=獲取本地令牌成功，false=失敗
     */
    public boolean localLimitFallback(String target) {
        try {
            // 從緩存獲取本地限流實(shí)例，無(wú)則創(chuàng)建默認(rèn)實(shí)例
            RateLimiter rateLimiter = localRateLimiterMap.getOrDefault(target, RateLimiter.create(DEFAULT_LOCAL_QPS));
            // 嘗試獲取1個(gè)本地令牌（無(wú)超時(shí)）
            return rateLimiter.tryAcquire();
        } catch (Exception e) {
            log.error("本地限流兜底異常，目標(biāo)：{}", target, e);
            return false;
        }
    }

    /**
     * 動(dòng)態(tài)更新本地限流規(guī)則（支持Nacos熱更新調(diào)用）
     * @param target 限流目標(biāo)
     * @param qps 目標(biāo)QPS
     */
    public void updateLocalLimit(String target, double qps) {
        localRateLimiterMap.put(target, RateLimiter.create(qps));
        log.info("本地限流規(guī)則更新成功，目標(biāo)：{}，QPS：{}", target, qps);
    }
}

import com.alibaba.csp.sentinel.annotation.aspectj.SentinelResourceAspect;
import com.alibaba.csp.sentinel.slots.block.RuleConstant;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRule;
import com.alibaba.csp.sentinel.slots.block.degrade.DegradeRuleManager;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.annotation.PostConstruct;
import java.util.ArrayList;
import java.util.List;

/**
 * Sentinel熔斷配置（Redis操作熔斷）
 */
@Configuration
public class SentinelConfig {
    /**
     * 開(kāi)啟Sentinel注解支持
     */
    @Bean
    public SentinelResourceAspect sentinelResourceAspect() {
        return new SentinelResourceAspect();
    }

    /**
     * 初始化Redis操作熔斷規(guī)則
     * 策略：異常比例熔斷，5秒內(nèi)異常率>50%，熔斷10秒
     */
    @PostConstruct
    public void initDegradeRules() {
        List<DegradeRule> rules = new ArrayList<>();
        // Redis Lua腳本限流熔斷規(guī)則
        DegradeRule luaRule = new DegradeRule();
        luaRule.setResource("redisLimitLua"); // 資源名，與@SentinelResource一致
        luaRule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO); // 異常比例
        luaRule.setCount(0.5); // 異常比例閾值50%
        luaRule.setTimeWindow(10); // 熔斷時(shí)間10秒
        luaRule.setMinRequestAmount(10); // 最小請(qǐng)求數(shù)：5秒內(nèi)至少10次請(qǐng)求才觸發(fā)

        // Redisson限流熔斷規(guī)則
        DegradeRule redissonRule = new DegradeRule();
        redissonRule.setResource("redissonLimit");
        redissonRule.setGrade(RuleConstant.DEGRADE_GRADE_EXCEPTION_RATIO);
        redissonRule.setCount(0.5);
        redissonRule.setTimeWindow(10);
        redissonRule.setMinRequestAmount(10);

        rules.add(luaRule);
        rules.add(redissonRule);
        DegradeRuleManager.loadRules(rules);
    }
}

// 在RedisLimitLuaUtil的fixedWindowLimit方法添加
@SentinelResource(value = "redisLimitLua", fallback = "fixedWindowFallback")
public boolean fixedWindowLimit(String limitDimension, String target, int limit, int expire) {
    // 原有邏輯
}
// 熔斷降級(jí)方法（參數(shù)與原方法一致）
public boolean fixedWindowFallback(String limitDimension, String target, int limit, int expire) {
    log.warn("Redis Lua限流觸發(fā)Sentinel熔斷，觸發(fā)本地降級(jí)，目標(biāo)：{}", target);
    return false; // 返回false觸發(fā)本地兜底
}

// 在RedissonLimitUtil的rateLimit方法添加
@SentinelResource(value = "redissonLimit", fallback = "rateLimitFallback")
public boolean rateLimit(String target, int rate, int rateInterval, RateIntervalUnit unit, int capacity) {
    // 原有邏輯
}
// 熔斷降級(jí)方法
public boolean rateLimitFallback(String target, int rate, int rateInterval, RateIntervalUnit unit, int capacity) {
    log.warn("Redisson令牌桶限流觸發(fā)Sentinel熔斷，觸發(fā)本地降級(jí)，目標(biāo)：{}", target);
    return false;
}

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

@Configuration
public class RedisConfig {
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(factory);
        // JSON序列化器
        Jackson2JsonRedisSerializer<Object> jacksonSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.activateDefaultTyping(om.getPolymorphicTypeValidator(), ObjectMapper.DefaultTyping.NON_FINAL);
        jacksonSerializer.setObjectMapper(om);
        // String序列化器
        StringRedisSerializer stringSerializer = new StringRedisSerializer();
        // key采用String序列化
        template.setKeySerializer(stringSerializer);
        template.setHashKeySerializer(stringSerializer);
        // value采用JSON序列化
        template.setValueSerializer(jacksonSerializer);
        template.setHashValueSerializer(jacksonSerializer);
        template.afterPropertiesSet();
        return template;
    }
}

import io.micrometer.core.instrument.Counter;
import io.micrometer.core.instrument.MeterRegistry;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;

/**
 * 限流監(jiān)控指標(biāo)工具類(lèi)
 */
@Component
public class LimitMonitorUtil {
    @Resource
    private MeterRegistry meterRegistry;
    // 限流拒絕次數(shù)
    private Counter limitRejectCounter;
    // Redis異常次數(shù)
    private Counter redisErrorCounter;
    // 本地降級(jí)次數(shù)
    private Counter localDegradeCounter;

    @PostConstruct
    public void initCounter() {
        limitRejectCounter = Counter.builder("redis.limit.reject.count")
                .description("Redis分布式限流拒絕請(qǐng)求次數(shù)")
                .register(meterRegistry);
        redisErrorCounter = Counter.builder("redis.limit.error.count")
                .description("Redis分布式限流Redis操作異常次數(shù)")
                .register(meterRegistry);
        localDegradeCounter = Counter.builder("redis.limit.local.degrade.count")
                .description("Redis分布式限流本地降級(jí)觸發(fā)次數(shù)")
                .register(meterRegistry);
    }

    // 記錄限流拒絕
    public void recordLimitReject() {
        limitRejectCounter.increment();
    }

    // 記錄Redis異常
    public void recordRedisError() {
        redisErrorCounter.increment();
    }

    // 記錄本地降級(jí)
    public void recordLocalDegrade() {
        localDegradeCounter.increment();
    }
}

if (!apiLimit || !ipLimit) {
    limitMonitorUtil.recordLimitReject(); // 記錄限流拒絕
    if (!limitDegradeUtil.localLimitFallback(apiTarget)) {
        limitMonitorUtil.recordLocalDegrade(); // 記錄本地降級(jí)
        return Result.fail(429, "請(qǐng)求過(guò)于頻繁");
    }
}