摘要：對(duì)請(qǐng)求的目標(biāo)進(jìn)行限流例如某個(gè)每分鐘只允許調(diào)用多少次對(duì)客戶(hù)端的訪問(wèn)進(jìn)行限流例如某個(gè)每分鐘只允許請(qǐng)求多少次對(duì)某些特定用戶(hù)或者用戶(hù)組進(jìn)行限流例如非用戶(hù)限制每分鐘只允許調(diào)用次某個(gè)等多維度混合的限流。

對(duì)請(qǐng)求的目標(biāo)URL進(jìn)行限流（例如：某個(gè)URL每分鐘只允許調(diào)用多少次）

對(duì)客戶(hù)端的訪問(wèn)IP進(jìn)行限流（例如：某個(gè)IP每分鐘只允許請(qǐng)求多少次）

對(duì)某些特定用戶(hù)或者用戶(hù)組進(jìn)行限流（例如：非VIP用戶(hù)限制每分鐘只允許調(diào)用100次某個(gè)API等）

多維度混合的限流。此時(shí)，就需要實(shí)現(xiàn)一些限流規(guī)則的編排機(jī)制。與、或、非等關(guān)系。

spring-cloud-zuul-ratelimit是和zuul整合提供分布式限流策略的擴(kuò)展，只需在yaml中配置幾行配置，就可使應(yīng)用支持限流

    com.marcosbarbero.cloud
    spring-cloud-zuul-ratelimit
    1.3.4.RELEASE

服務(wù)粒度 (默認(rèn)配置，當(dāng)前服務(wù)模塊的限流控制)

用戶(hù)粒度 （詳細(xì)說(shuō)明，見(jiàn)文末總結(jié)）

ORIGIN粒度 (用戶(hù)請(qǐng)求的origin作為粒度控制)

接口粒度 (請(qǐng)求接口的地址作為粒度控制)

以上粒度自由組合，又可以支持多種情況。

如果還不夠，自定義RateLimitKeyGenerator實(shí)現(xiàn)。

//默認(rèn)實(shí)現(xiàn)
public String key(final HttpServletRequest request, final Route route, final RateLimitProperties.Policy policy) {
    final List types = policy.getType();
    final StringJoiner joiner = new StringJoiner(":");
    joiner.add(properties.getKeyPrefix());
    if (route != null) {
        joiner.add(route.getId());
    }
    if (!types.isEmpty()) {
        if (types.contains(Type.URL) && route != null) {
            joiner.add(route.getPath());
        }
        if (types.contains(Type.ORIGIN)) {
            joiner.add(getRemoteAddr(request));
        }
        // 這個(gè)結(jié)合文末總結(jié)。
        if (types.contains(Type.USER)) {
            joiner.add(request.getUserPrincipal() != null ? request.getUserPrincipal().getName() : ANONYMOUS_USER);
        }
    }
    return joiner.toString();
}

InMemoryRateLimiter - 使用 ConcurrentHashMap作為數(shù)據(jù)存儲(chǔ)

ConsulRateLimiter - 使用 Consul 作為數(shù)據(jù)存儲(chǔ)

RedisRateLimiter - 使用 Redis 作為數(shù)據(jù)存儲(chǔ)

SpringDataRateLimiter - 使用 數(shù)據(jù)庫(kù) 作為數(shù)據(jù)存儲(chǔ)

limit 單位時(shí)間內(nèi)允許訪問(wèn)的個(gè)數(shù)

quota 單位時(shí)間內(nèi)允許訪問(wèn)的總時(shí)間（統(tǒng)計(jì)每次請(qǐng)求的時(shí)間綜合）

refresh-interval 單位時(shí)間設(shè)置

zuul:
  ratelimit:
    key-prefix: your-prefix 
    enabled: true 
    repository: REDIS 
    behind-proxy: true
    policies:
      myServiceId:
        limit: 10
        quota: 20
        refresh-interval: 30
        type:
          - user
        

以上配置意思是：30秒內(nèi)允許10個(gè)訪問(wèn)，并且要求總請(qǐng)求時(shí)間小于20秒

yaml配置：

zuul:
  ratelimit:
    key-prefix: pig-ratelimite 
    enabled: true 
    repository: REDIS 
    behind-proxy: true
    policies:
      pig-admin-service:
        limit: 2
        quota: 1
        refresh-interval: 3

動(dòng)態(tài)圖 ↓↓↓↓↓

Redis 中數(shù)據(jù)結(jié)構(gòu) 注意紅色字體

可以使用Spring Boot Actuator 提供的服務(wù)狀態(tài)，動(dòng)態(tài)設(shè)置限流開(kāi)關(guān)

源碼可以參考：https://gitee.com/log4j/pig

用戶(hù)限流的實(shí)現(xiàn)：如果你的項(xiàng)目整合 Shiro 或者 Spring Security 安全框架，那么會(huì)自動(dòng)維護(hù)request域UserPrincipal，如果是自己的框架，請(qǐng)登錄成功后維護(hù)request域UserPrincipal，才能使用用戶(hù)粒度的限流。未登錄默認(rèn)是：anonymous