spring cloud zuul 與 sentinel的結(jié)合使用操作
spring cloud zuul 與 sentinel結(jié)合
本來大型服務(wù)處理請(qǐng)求超時(shí),限流,降級(jí)熔斷工作用hystrix,但是這個(gè)這個(gè)項(xiàng)目不再更新了,雖說它現(xiàn)在提供的版本不會(huì)影響到大多數(shù)開發(fā)者的使用,但是長(zhǎng)遠(yuǎn)考慮,被更換是一件必然的事,而且現(xiàn)在像resilience4j, Sentinel這樣的替代品出現(xiàn),今天我們就看看使用zuul 與 Sentinel整合,實(shí)現(xiàn)降級(jí)與超時(shí)處理,其實(shí)網(wǎng)上有很多這樣的教程,這里我只是做一個(gè)自己的筆記而已
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、配置文件,其實(shí)Sentinel在這里沒什么配置
server:
port: 6001
spring:
application:
name: e-zuul
eureka:
instance:
hostname: localhost
lease-expiration-duration-in-seconds: 90 #表示服務(wù)端多長(zhǎng)時(shí)間沒有接受到心跳信息后可以刪除自己
lease-renewal-interval-in-seconds: 30 #表示需要要向服務(wù)端發(fā)送信息,表示自己還活著
ip-address: true
client:
healthcheck:
enabled: true #客戶端心跳檢測(cè)
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、配置類, 其實(shí)配置類和后邊的降級(jí)回調(diào)處理類才是關(guān)鍵
而且配置類中幾個(gè)關(guān)于zuul與Sentinel的過濾器非常關(guān)鍵,這里要是不提供它們,將無法實(shí)現(xiàn)我們想要的功能,還有就是網(wǎng)關(guān)規(guī)則,可以選擇qps, 超時(shí),線程等,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() {
// 注冊(cè) 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)計(jì)時(shí)間窗口,單位是秒,默認(rèn)是 1 秒
);
rules.add(new GatewayFlowRule("e-user")
.setGrade(RuleConstant.DEGRADE_GRADE_RT)//設(shè)置超時(shí)類型規(guī)則
.setMaxQueueingTimeoutMs(500)
);
GatewayRuleManager.loadRules(rules);
}
}
4、回調(diào)處理類,當(dāng)有請(qǐng)求被攔截到后,就會(huì)調(diào)用降級(jí)回調(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)流控支持針對(duì)不同的路由和自定義的 API 分組進(jìn)行流控,支持針對(duì)請(qǐng)求屬性(如 URL 參數(shù),Client IP,Header 等)進(jìn)行流控。
Sentinel 1.6.3 引入了網(wǎng)關(guān)流控控制臺(tái)的支持,用戶可以直接在 Sentinel 控制臺(tái)上查看 API Gateway 實(shí)時(shí)的 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動(dòng)態(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上對(duì)應(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的請(qǐng)求只要參數(shù)帶有name的都攔截(qps=0),user為zuul路由配置上的routeId
規(guī)則2:api分組為uaa_api的所有請(qǐng)求都攔截(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:精準(zhǔn)匹配/user/login
分組規(guī)則2:前綴匹配/api-uaa/oauth/**
4. 網(wǎng)關(guān)zuul啟動(dòng)參數(shù)
需要在接入端原有啟動(dòng)參數(shù)的基礎(chǔ)上添加-Dcsp.sentinel.app.type=1啟動(dòng)以將您的服務(wù)標(biāo)記為 API Gateway,在接入控制臺(tái)時(shí)您的服務(wù)會(huì)自動(dòng)注冊(cè)為網(wǎng)關(guān)類型,然后您即可在控制臺(tái)配置網(wǎng)關(guān)規(guī)則和 API 分組,例如:
java -Dcsp.sentinel.app.type=1 -jar zuul-gateway.jar
三、sentinel控制臺(tái)管理
API管理(分組)

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

四、測(cè)試限流api
1. 測(cè)試限流規(guī)則1
所有user的請(qǐng)求只要參數(shù)帶有name的都攔截(qps=0)
不加name參數(shù),可以訪問api

后面加上name參數(shù),請(qǐng)求被攔截

2. 測(cè)試限流規(guī)則2
api分組為uaa_api的所有請(qǐng)求都攔截(qps=0)
前綴匹配/api-uaa/oauth/**

精準(zhǔn)匹配/user/login
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
- 詳解Spring Cloud Zuul網(wǎng)關(guān)修改為短連接方法
- SpringCloud之Zuul網(wǎng)關(guān)原理及其配置講解
- SpringCloud網(wǎng)關(guān)(Zuul)如何給多個(gè)微服務(wù)之間傳遞共享參數(shù)
- 關(guān)于服務(wù)網(wǎng)關(guān)Spring Cloud Zuul(Finchley版本)
- 解決spring cloud zuul與nginx的域名轉(zhuǎn)發(fā)問題
- SpringCloud Zuul實(shí)現(xiàn)負(fù)載均衡和熔斷機(jī)制方式
- SpringCloud如何實(shí)現(xiàn)Zuul集群(負(fù)載均衡)
- SpringCloud zuul 網(wǎng)關(guān)如何解決跨域問題
- Spring?Cloud詳細(xì)講解zuul集成Eureka流程
相關(guān)文章
關(guān)于post請(qǐng)求內(nèi)容無法重復(fù)獲取的解決方法
這篇文章主要介紹了關(guān)于post請(qǐng)求內(nèi)容無法重復(fù)獲取的解決方法,文中通過代碼示例給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下2024-03-03
淺談java中對(duì)集合對(duì)象list的幾種循環(huán)訪問
下面小編就為大家?guī)硪黄猨ava中對(duì)集合對(duì)象list的幾種循環(huán)訪問詳解。小編覺得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2016-07-07
Java中的數(shù)組基礎(chǔ)知識(shí)學(xué)習(xí)教程
這篇文章主要介紹了Java中的數(shù)組基礎(chǔ)知識(shí)學(xué)習(xí)教程,文中同時(shí)也整理了Java對(duì)數(shù)字類型的支持狀況及Number類中的方法,需要的朋友可以參考下2016-02-02
Java中notify()和notifyAll()的使用區(qū)別
本文主要介紹了Java中notify()和notifyAll()的使用區(qū)別,文中通過示例代碼介紹的非常詳細(xì),感興趣的小伙伴們可以參考一下2021-06-06
JAVA 對(duì)象創(chuàng)建與對(duì)象克隆
這篇文章主要介紹了JAVA 對(duì)象創(chuàng)建與對(duì)象克隆,new 創(chuàng)建、反射、克隆、反序列化,克隆它分為深拷貝和淺拷貝,通過調(diào)用對(duì)象的 clone方法,進(jìn)行對(duì)象的克隆,下面來看看文章的詳細(xì)內(nèi)容吧2022-02-02

