zuul整合ratelimit實現限流

阿新 • • 發佈：2022-05-23

正常呼叫結果

觸發限流後提示

父類pom

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.example</groupId>
    <artifactId>zuul-aprent</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>
    <modules>
        <module>eureka-service</module>
        <module>prodoct-service</module>
        <module>order-service</module>
        <module>zuul-service</module>
        <module>zuul-one</module>
        <module>zuul-two</module>
    </modules>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.5.RELEASE</version>
    </parent>

    <dependencyManagement>

        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Hoxton.SR3</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>2.1.0.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>



        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <!--編譯外掛-->
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                    <encoding>utf-8</encoding>
                </configuration>
            </plugin>
            <!--打包外掛-->
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>


</project>

　　zuul閘道器配置

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>zuul-aprent</artifactId>
        <groupId>org.example</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.zuul</groupId>
    <artifactId>zuul-two</artifactId>

    <dependencies>
        <!--zuul依賴-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
        </dependency>
        <!--lombok依賴-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.16</version>
        </dependency>
        <!--客戶端-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>


        <dependency>
            <groupId>com.marcosbarbero.cloud</groupId>
            <artifactId>spring-cloud-zuul-ratelimit</artifactId>
            <version>2.2.5.RELEASE</version>
        </dependency>

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

        <dependency>
            <groupId>com.google.code.gson</groupId>
            <artifactId>gson</artifactId>
            <version>2.8.6</version>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
        <finalName>zuul</finalName>
    </build>


</project>

server.port=1004

spring.application.name=zuul-two
#註冊到eureka註冊中心,如果是註冊到叢集就用逗號連線多個，單例項寫上一個就好
eureka.client.service-url.defaultZone=http://localhost:8761/eureka


logging.level.com.zuul=debug
logging.level.web=debug
spring.devtools.add-properties=false




#開啟限流保護
zuul.ratelimit.enabled=true

#限流資料儲存方式
zuul.ratelimit.repository=redis

#自定義需要被限流的服務名
zuul.ratelimit.policy-list.order-service[0].limit=5
zuul.ratelimit.policy-list.order-service[0].refresh-interval=60

spring.redis.database=1
spring.redis.host=127.0.0.1
spring.redis.port=6379 
spring.redis.password=

package com.zuul;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.zuul.EnableZuulProxy;

/**
 * @author yourheart
 * @Description   自定義限流策略
 * @create 2022-05-21 23:44
 */
@SpringBootApplication
//開啟zuul註解
@EnableZuulProxy
@EnableDiscoveryClient
public class ZuulTwoApplication {

    public static void main(String[] args) {
        SpringApplication.run(ZuulTwoApplication.class,args);
    }
}

　　配置token驗證

package com.zuul.config;

import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext;
import com.netflix.zuul.exception.ZuulException;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Component;

import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.io.PrintWriter;

/**
 * @author yourheart
 * @Description
 * @create 2022-05-09 21:56
 */
@Component
@Slf4j
public class AccessFilter extends ZuulFilter {
    @Override
    public String filterType() {
        return "pre";
    }

    @Override
    public int filterOrder() {
        return 1;
    }

    @Override
    public boolean shouldFilter() {
        return true;
    }

    @Override
    public Object run() throws ZuulException {
        //獲取請求上下文
        RequestContext rc = RequestContext.getCurrentContext();
        HttpServletRequest request = rc.getRequest();
        String token=request.getHeader("token");
        if (null==token){
            log.warn("【token為空】");
            //請求結束
            rc.setSendZuulResponse(false);
            //狀態碼,401未授權
            rc.setResponseStatusCode(HttpStatus.UNAUTHORIZED.value());
            rc.getResponse().setContentType("application/jsop; charset=utf-8");
            PrintWriter writer=null;

            try {
                writer=rc.getResponse().getWriter();
                writer.print("401,登入未授權");
            } catch (IOException e) {
                e.printStackTrace();
            }

        }else {
            log.info("【token id ok】token:{}",token);
        }

        return null;
    }
}

自定義限流策略

package com.zuul.config;

import com.marcosbarbero.cloud.autoconfigure.zuul.ratelimit.config.RateLimitUtils;
import com.marcosbarbero.cloud.autoconfigure.zuul.ratelimit.config.properties.RateLimitProperties;
import com.marcosbarbero.cloud.autoconfigure.zuul.ratelimit.support.DefaultRateLimitKeyGenerator;
import org.springframework.cloud.netflix.zuul.filters.Route;
import org.springframework.stereotype.Component;

import javax.servlet.http.HttpServletRequest;

/**
 * @author yourheart
 * @Description
 * @create 2022-05-21 23:46
 */
@Component
public class RateLimitKeyGenerator extends DefaultRateLimitKeyGenerator {

    public RateLimitKeyGenerator(RateLimitProperties properties, RateLimitUtils rateLimitUtils) {
        super(properties, rateLimitUtils);
    }

    /**
     * 自定義限流策略
     * @param request
     * @param route
     * @param policy
     * @return
     */
    @Override
    public String key(HttpServletRequest request, Route route, RateLimitProperties.Policy policy) {
        return super.key(request, route, policy)+":"+request.getParameter("orderId");
    }
}

　　定製觸發限流返回的錯誤資訊

package com.zuul.handler;

import com.google.gson.JsonObject;
import org.springframework.boot.web.servlet.error.ErrorController;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author yourheart
 * @Description
 * @create 2022-05-22 10:51
 */
@RestController
public class ExceptionHandler implements ErrorController {
    @Override
    public String getErrorPath() {
        return "error";
    }


    @RequestMapping(value="/error")
    public String error(){

        JsonObject jsonObject=new JsonObject();
        jsonObject.addProperty("code","429");
        jsonObject.addProperty("msg","已觸發限流，服務不可用");
        String result = jsonObject.toString();
        return result;
    }
}

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>zuul-aprent</artifactId>
        <groupId>org.example</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.order</groupId>
    <artifactId>order-service</artifactId>

    <dependencies>
        <!--客戶端-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <!--web依賴-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--新增fastjson依賴-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.7</version>
        </dependency>

        <!--lombok依賴-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.16</version>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
        <finalName>order</finalName>
    </build>


</project>


package com.order;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;

/**
 * @author yourheart
 * @Description
 * @create 2022-04-20 21:38
 */
@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class OrderApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderApplication.class,args);
    }
}


package com.order;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author yourheart
 * @Description
 * @create 2022-04-20 21:46
 */
@RestController
@RequestMapping("/order")
@Slf4j
public class OrderController {


    @Autowired
    private ProductService productService;

    @GetMapping("/getId")
    public String getId(Integer orderId){
        return "返回的訂單號:"+orderId;
    }

    @GetMapping("/getOrder/{id}")
    public String getProduct(@PathVariable  String id){
        log.info("【呼叫消費者入參】:{}",id);
        String selectProduct = productService.selectProduct(id);
        return selectProduct;
    }
}


package com.order;


import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;

@FeignClient(value = "product-service")
public interface ProductService {

    @GetMapping("/product/getProduct/{id}")
    String selectProduct(@PathVariable String id);
}

productService.selectProduct(id)該方法可以自己定義
eureka專案

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>zuul-aprent</artifactId>
        <groupId>org.example</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.eureka</groupId>
    <artifactId>eureka-service</artifactId>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
        <finalName>eureka</finalName>
    </build>


</project>


server.port=8761
spring.application.name=eureka-service
eureka.instance.hostname=localhost
eureka.client.service-url.defaultZone=http://localhost:8761/eureka
eureka.client.register-with-eureka=false
eureka.client.fetch-registry=false

logging.level.com.eureka=info
logging.level.web=info
spring.devtools.add-properties=false


package com.eureka;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
/**
 * @author yourheart
 * @Description
 * @create 2022-04-20 21:17
 */
@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaApplication.class,args);
    }
}

　　呼叫http://127.0.0.1:1004/order-service/order/getId?orderId=10

本次配置的是60秒內，呼叫5次觸發限流

zuul整合ratelimit實現限流

正常呼叫結果觸發限流後提示父類pom <?xml version=\"1.0\" encoding=\"UTF-8\"?> <project xmlns=\"http://maven.apache.org/POM/4.0.0\"

SpringCloud Zuul過濾器和谷歌Gauva實現限流

前提：已經配置Zuul閘道器參考： https://www.jb51.net/article/182894.htm 限流方式： 1）nginx層限流

【高併發】面試官問我如何使用Nginx實現限流，我如此回答輕鬆拿到了Offer！

寫在前面最近，有不少讀者說看了我的文章後，學到了很多知識，其實我本人聽到後是非常開心的，自己寫的東西能夠為大家帶來幫助，確實是一件值得高興的事情。最近，也有不少小夥伴，看了我的文章後，順利拿到了大廠O

使用reids實現限流

1.今天我們就基於Redis元件的特性，實現一個分散式限流元件, 原理首先解釋下為何採用Redis作為限流元件的核心。

在springboot中使用Guava基於令牌桶實現限流

限流說詳細了，名堂也多。這種演算法那種演算法，這種策略那種策略的。沒有絕對的銀彈。都要結合實際的場景來實現。最簡單的，使用Google的Guava，幾行程式碼。就可以優雅的對一個介面完成限流。

多執行緒併發安全計數器實現限流(三) 加鎖實現計數器

一、加鎖實現計數器 public class CounterSync implements Counter { volatile int i = 0; // 本質是修改記憶體中某一個變數的值

多執行緒併發安全計數器實現限流(二) 使用 J.U.C中的AtomicInteger實現計數器

一、使用 J.U.C中的 atomicInteger 實現計數器由於（一）中的計數器不能保證併發安全，因此需要改一下；

多執行緒併發安全計數器實現限流(四)CAS

cas 計數器 public class CounterCAS implements Counter { volatile int i = 0; // 本質是修改記憶體中某一個變數的值

springcloud zuul 閘道器限流

1.新增pom包 <dependency> <groupId>com.marcosbarbero.cloud</groupId> <artifactId>spring-cloud-zuul-ratelimit</artifactId>

Spring Cloud Zuul整合Swagger實現過程解析

Spring Cloud Zuul 整合Swagger 1.準備服務註冊中心eureka-server 2.建立微服務swagger-service-a

如何實現限流（java）

技術標籤：javajava 自我理解服務降級的一種，限制系統輸入和輸出，達到保護系統的作用。方法【1.計數器（控制單位時間的請求數量，缺點兩個單位時間內沒有監控，處於監控漏洞）2.滑動視窗(把單位時間等分成若干

https協議+三種資料庫實現限流+安全防護

1 http 和 https 1.1 http 和 https 的區別 http 明文（報文明文）可以篡改 https 加密（報文密文）

SpringBoot進階教程(六十八)Sentinel實現限流降級

前面兩篇文章nginx限流配置和SpringBoot進階教程(六十七)RateLimiter限流，我們介紹瞭如何使用nginx和RateLimiter限流，這篇文章介紹另外一種限流方式---Sentinel。

工作流中容器化的依賴注入！Activiti整合CDI實現工作流的可配置型和可擴充套件型

Activiti工作流整合CDI簡介 activiti-cdi模組提供activiti的可配置型和cdi擴充套件 activiti-cdi的特性:

Redis 實現限流的三種方式

面對越來越多的高併發場景，限流顯示的尤為重要。當然，限流有許多種實現的方式，Redis具有很強大的功能，我用Redis實踐了三種的實現方式，可以較為簡單的實現其方式。Redis不僅僅是可以做限流，還可以做資料統計，

spring cloud gateway整合sentinel實現閘道器限流

這篇文章主要介紹了spring cloud gateway整合sentinel實現閘道器限流,文中通過示例程式碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下

spring cloud gateway整合sentinel實現閘道器限流全域性處理

官網地址 https://github.com/alibaba/Sentinel/wiki/%E7%BD%91%E5%85%B3%E9%99%90%E6%B5%81 Sentinel 1.6.0釋出了Sentinel API閘道器介面卡通用模組，此模組中包含閘道器限流的規則和自定義API的實體和管理邏輯：

詳解Springboot整合sentinel實現介面限流入門

Sentinel是阿里巴巴開源的限流器熔斷器，並且帶有視覺化操作介面。在日常開發中，限流功能時常被使用，用於對某些介面進行限流熔斷，譬如限制單位時間內介面訪問次數；或者按照某種規則進行限流，如限制ip的單位時間

註解式限流是如何實現滴

知道的越多，不知道的越多一個問題往往會引出了一連串的問題，知識的盲區就這樣被自己悄悄的發現了?。車轍在自己動手寫限流注解時，遇到的問題那是真一個比一個多：

Java併發程式設計入門（十一）限流場景和Spring限流器實現

Java極客 | 作者 / 鏗然一葉這是Java極客的第 39 篇原創文章一、限流場景

zuul整合ratelimit實現限流

相關推薦