欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

spring cloud zuul 與 sentinel的結(jié)合使用操作

 更新時間：2021年06月25日 10:53:03   作者：mjlfto  
這篇文章主要介紹了spring cloud zuul 與 sentinel 的結(jié)合使用操作，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教

spring cloud zuul 與 sentinel結(jié)合

本來大型服務(wù)處理請求超時，限流，降級熔斷工作用hystrix,但是這個這個項目不再更新了，雖說它現(xiàn)在提供的版本不會影響到大多數(shù)開發(fā)者的使用，但是長遠考慮，被更換是一件必然的事，而且現(xiàn)在像resilience4j， Sentinel這樣的替代品出現(xiàn)，今天我們就看看使用zuul 與 Sentinel整合，實現(xiàn)降級與超時處理，其實網(wǎng)上有很多這樣的教程，這里我只是做一個自己的筆記而已

1、必須的依賴

        <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-netflix-zuul</artifactId>
        </dependency>

        <dependency>
            <groupId>com.alibaba.csp</groupId>
            <artifactId>sentinel-zuul-adapter</artifactId>
            <version>1.7.1</version>
        </dependency>

2、配置文件，其實Sentinel在這里沒什么配置

server:
  port: 6001
spring:
  application:
    name: e-zuul

eureka:
  instance:
    hostname: localhost
    lease-expiration-duration-in-seconds: 90 #表示服務(wù)端多長時間沒有接受到心跳信息后可以刪除自己
    lease-renewal-interval-in-seconds: 30 #表示需要要向服務(wù)端發(fā)送信息，表示自己還活著
    ip-address: true
  client:
    healthcheck:
      enabled: true #客戶端心跳檢測
    service-url:
      defaultZone: http://${eureka.instance.hostname}:3001/eureka/

zuul:
  add-proxy-headers: true
  LogFilter:
    pre:
      disable=true:
  routes:
    e-email:
      serviceId: e-email
      path: /email/**
    e-user:
      serviceId: e-user
      path: /user/**

3、配置類, 其實配置類和后邊的降級回調(diào)處理類才是關(guān)鍵

而且配置類中幾個關(guān)于zuul與Sentinel的過濾器非常關(guān)鍵，這里要是不提供它們，將無法實現(xiàn)我們想要的功能，還有就是網(wǎng)關(guān)規(guī)則，可以選擇qps, 超時，線程等，setGrade(RuleConstant.DEGRADE_GRADE_RT)提供選擇不同的策略

package com.mjlf.ezuul.config;
import com.alibaba.csp.sentinel.adapter.gateway.common.rule.GatewayFlowRule;
import com.alibaba.csp.sentinel.adapter.gateway.common.rule.GatewayRuleManager;
import com.alibaba.csp.sentinel.adapter.gateway.zuul.fallback.ZuulBlockFallbackManager;
import com.alibaba.csp.sentinel.adapter.gateway.zuul.filters.SentinelZuulErrorFilter;
import com.alibaba.csp.sentinel.adapter.gateway.zuul.filters.SentinelZuulPostFilter;
import com.alibaba.csp.sentinel.adapter.gateway.zuul.filters.SentinelZuulPreFilter;
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 com.netflix.zuul.ZuulFilter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.annotation.PostConstruct;
import java.util.HashSet;
import java.util.Set;

@Configuration
public class ZuulConfig {
    @Bean
    public ZuulFilter sentinelZuulPreFilter() {
        // We can also provider the filter order in the constructor.
        return new SentinelZuulPreFilter();
    }

    @Bean
    public ZuulFilter sentinelZuulPostFilter() {
        return new SentinelZuulPostFilter();
    }

    @Bean
    public ZuulFilter sentinelZuulErrorFilter() {
        return new SentinelZuulErrorFilter();
    }

    @PostConstruct
    public void doInit() {
        // 注冊 FallbackProvider
        ZuulBlockFallbackManager.registerProvider(new MyBlockFallbackProvider());
        initGatewayRules();
    }

    /**
     * 配置限流規(guī)則
     */
    private void initGatewayRules() {
        Set<GatewayFlowRule> rules = new HashSet<>();
        rules.add(new GatewayFlowRule("e-user").setCount(3) // 限流閾值
                .setIntervalSec(1) // 統(tǒng)計時間窗口，單位是秒，默認是 1 秒
        );
        rules.add(new GatewayFlowRule("e-user")
                .setGrade(RuleConstant.DEGRADE_GRADE_RT)//設(shè)置超時類型規(guī)則
                .setMaxQueueingTimeoutMs(500)
        );
        GatewayRuleManager.loadRules(rules);
    }
}

4、回調(diào)處理類，當有請求被攔截到后，就會調(diào)用降級回調(diào)方法

// 自定義 FallbackProvider
@Component
public class MyBlockFallbackProvider implements ZuulBlockFallbackProvider {
    private Logger logger = LoggerFactory.getLogger(DefaultBlockFallbackProvider.class);
    // you can define route as service level 
    @Override
    public String getRoute() {
        return "*";
    }

    @Override
    public BlockResponse fallbackResponse(String route, Throwable cause) {
        RecordLog.info(String.format("[Sentinel DefaultBlockFallbackProvider] Run fallback route: %s", route));
        if (cause instanceof BlockException) {
            return new BlockResponse(429, "Sentinel block exception", route);
        } else {
            return new BlockResponse(500, "System Error", route);
        }
    }
}

zuul集成Sentinel最新的網(wǎng)關(guān)流控組件

一、說明

Sentinel 網(wǎng)關(guān)流控支持針對不同的路由和自定義的 API 分組進行流控，支持針對請求屬性（如 URL 參數(shù)，Client IP，Header 等）進行流控。

Sentinel 1.6.3 引入了網(wǎng)關(guān)流控控制臺的支持，用戶可以直接在 Sentinel 控制臺上查看 API Gateway 實時的 route 和自定義 API 分組監(jiān)控，管理網(wǎng)關(guān)規(guī)則和 API 分組配置。

二、功能接入

1. 網(wǎng)關(guān)添加sentinel相關(guān)的jar依賴

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-datasource-nacos</artifactId>
</dependency>
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId>
</dependency>

2. 網(wǎng)關(guān)zuul的sentinel配置

spring:
  # sentinel動態(tài)配置規(guī)則
  cloud:
    sentinel:
      zuul:
        enabled: true
        order:
          pre: 2000
          post: 500
          error: -100
      filter:
        enabled: false
      datasource:
        # 限流
        ds1:
          nacos:
            server-addr: ${zlt.nacos.server-addr}
            dataId: ${spring.application.name}-sentinel-gw-flow
            groupId: DEFAULT_GROUP
            rule-type: gw-flow
        # api分組
        ds2:
          nacos:
            server-addr: ${zlt.nacos.server-addr}
            dataId: ${spring.application.name}-sentinel-gw-api-group
            groupId: DEFAULT_GROUP
            rule-type: gw-api-group

綁定gw-flow(限流)和gw-api-group(api分組)的規(guī)則數(shù)據(jù)源為nacos
并指定nacos上對應(yīng)的dataId和groupId

3. nacos規(guī)則配置

3.1. 限流配置gw-flow

在這里插入圖片描述

Data ID：api-gateway-sentinel-gw-flow

Group：DEFAULT_GROUP

配置內(nèi)容：

[
  {
    "resource": "user",
    "count": 0,
    "paramItem": {
      "parseStrategy": 3,
      "fieldName": "name"
    }
  },
  {
    "resource": "uaa_api",
    "count": 0
  }
]

規(guī)則1：所有user的請求只要參數(shù)帶有name的都攔截(qps=0)，user為zuul路由配置上的routeId
規(guī)則2：api分組為uaa_api的所有請求都攔截(qps=0)

3.2. api分組配置gw-api-group

在這里插入圖片描述

Data ID：api-gateway-sentinel-gw-api-group

Group：DEFAULT_GROUP

配置內(nèi)容：

[
  {
    "apiName": "uaa_api",
    "predicateItems": [
      {
        "pattern": "/user/login"
      },
      {
        "pattern": "/api-uaa/oauth/**",
        "matchStrategy": 1
      }
    ]
  }
]

上面配置意思為滿足規(guī)則的api都統(tǒng)一分組為uaa_api
分組規(guī)則1：精準匹配/user/login
分組規(guī)則2：前綴匹配/api-uaa/oauth/**

4. 網(wǎng)關(guān)zuul啟動參數(shù)

需要在接入端原有啟動參數(shù)的基礎(chǔ)上添加-Dcsp.sentinel.app.type=1啟動以將您的服務(wù)標記為 API Gateway，在接入控制臺時您的服務(wù)會自動注冊為網(wǎng)關(guān)類型，然后您即可在控制臺配置網(wǎng)關(guān)規(guī)則和 API 分組，例如：

java -Dcsp.sentinel.app.type=1 -jar zuul-gateway.jar

三、sentinel控制臺管理

API管理(分組)

網(wǎng)關(guān)流控規(guī)則

四、測試限流api

1. 測試限流規(guī)則1

所有user的請求只要參數(shù)帶有name的都攔截(qps=0)

不加name參數(shù)，可以訪問api

后面加上name參數(shù)，請求被攔截

在這里插入圖片描述

2. 測試限流規(guī)則2

api分組為uaa_api的所有請求都攔截(qps=0)

前綴匹配/api-uaa/oauth/**

在這里插入圖片描述

精準匹配/user/login

在這里插入圖片描述 

以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。

相關(guān)文章

  • SpringBoot淺析緩存機制之Redis單機緩存應(yīng)用

    SpringBoot淺析緩存機制之Redis單機緩存應(yīng)用

    在上文中我介紹了Spring Boot使用EhCache 2.x來作為緩存的實現(xiàn)，本文接著介紹使用單機版的Redis作為緩存的實現(xiàn)，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2022-08-08
  • 詳解Spring Cloud Config采用Git存儲時兩種常用的配置策略

    詳解Spring Cloud Config采用Git存儲時兩種常用的配置策略

    這篇文章主要介紹了詳解Spring Cloud Config采用Git存儲時兩種常用的配置策略，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
    2018-07-07
  • IDEA基于支付寶小程序搭建springboot項目的詳細步驟

    IDEA基于支付寶小程序搭建springboot項目的詳細步驟

    這篇文章主要介紹了IDEA基于支付寶小程序搭建springboot項目的詳細步驟，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
    2019-04-04
  • 關(guān)于java開發(fā)的性能問題總結(jié)(必看)

    關(guān)于java開發(fā)的性能問題總結(jié)(必看)

    下面小編就為大家?guī)硪黄P(guān)于java開發(fā)的性能問題總結(jié)(必看)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
    2017-03-03
  • IDEA如何撤銷本地commit的代碼

    IDEA如何撤銷本地commit的代碼

    這篇文章主要介紹了IDEA如何撤銷本地commit的代碼問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2023-09-09
  • JAVA文件讀寫操作詳解

    JAVA文件讀寫操作詳解

    這篇文章主要為大家詳細介紹了JAVA文件讀寫操作，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助
    2022-02-02
  • 基于Javamail實現(xiàn)發(fā)送郵件(QQ/網(wǎng)易郵件服務(wù)器)

    基于Javamail實現(xiàn)發(fā)送郵件(QQ/網(wǎng)易郵件服務(wù)器)

    這篇文章主要介紹了基于Javamail實現(xiàn)發(fā)送郵件，分別使用QQ郵箱作為smtp郵件服務(wù)器發(fā)送郵件，使用網(wǎng)易郵箱作為smtp郵件服務(wù)器發(fā)送郵件，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
    2022-08-08
  • java中@SuppressWarnings注解用法詳解

    java中@SuppressWarnings注解用法詳解

    這篇文章主要介紹了java中@SuppressWarnings注解用法詳解，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2021-02-02
  • java字符串的大寫字母右移實現(xiàn)方法

    java字符串的大寫字母右移實現(xiàn)方法

    下面小編就為大家?guī)硪黄猨ava字符串的大寫字母右移實現(xiàn)方法。小編覺得聽不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
    2017-04-04
  • java中如何實現(xiàn) zip rar 7z 壓縮包解壓

    java中如何實現(xiàn) zip rar 7z 壓縮包解壓

    這篇文章主要介紹了java中如何實現(xiàn) zip rar 7z 壓縮包解壓問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
    2023-07-07

最新評論