🔎这里是【微服务~Sentinel】，关注我学习微服务不迷路
👍如果对你有帮助，给博主一个免费的点赞以示鼓励
欢迎各位🔎点赞👍评论收藏⭐️
👀专栏介绍
【微服务~Sentinel】 目前主要更新微服务，一起学习一起进步。
👀本期介绍
本期主要介绍Sentinel之dashboard控制面板
文章目录
dashboard控制面板
概述
配置dashboard
设置资源点(埋点)
限流
编写测试类
限流方法
限流操作
熔断降级
降级方法
测试
降级操作
限流和降级的区别
dashboard控制面板
概述
Sentinel Dashboard 是一个独立的项目，sentinel-dashboard-1.8.4.jar，需要使用 java -jar 运行
java -jar -Dserver.port=18080 sentinel-dashboard-1.8.4.jar
下载地址
Releases · alibaba/Sentinel · GitHub
配置dashboard
添加坐标（已有）
<!-- 降级 -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
配置yml
#server.port=8071
#spring.application.name=service-consumer
#spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848
#spring.cloud.sentinel.transport.dashboard=192.168.152.153:8080
#端口号
server:
port: 8071
spring:
application:
name: service-consumer #服务名
cloud:
nacos:
discovery:
server-addr: 127.0.0.1:8848 #nacos服务地址
sentinel:
transport:
dashboard: 127.0.0.1:18080
feign:
sentinel:
enabled: true
测试
- 先访问资源
http://localhost:8071/feign/echo/123 - dashboard 登录
查看控制面板 http://localhost:18080/
设置资源点(埋点)
通过 @SentinelResource 注解，设置监控点（定义控制资源、配置控制策略）
package com.czxy.nacos.controller;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.czxy.nacos.feign.TestFeign;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
@RestController
@RequestMapping("/feign")
public class TestFeignController {
@Resource
private TestFeign testMyFeign;
@RequestMapping(value = "/echo/{str}", method = RequestMethod.GET)
@SentinelResource("/feign/echo")
public String echo(@PathVariable String str) {
return testMyFeign.echo(str);
}
}
测试
限流
编写测试类
package com.czxy.controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/user")
public class UserController {
@GetMapping("/login")
public String login(String str) {
return "登录成功" + str;
}
@GetMapping("/register")
public String register(String str) {
return "注册成功";
}
}
限流方法
- 通过
@SentinelResource注解的blockHandler属性制定限流的处理函数
package com.czxy.nacos.controller;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/user")
public class UserController {
@GetMapping("/login")
// 限流设置
@SentinelResource(value="login", blockHandler = "loginBlockHandler")
public String login(String str) {
return "登录成功" + str;
}
public String loginBlockHandler(String str , BlockException e) {
return str + ": 请稍后重试";
}
@GetMapping("/register")
public String register(String str) {
return "注册成功";
}
}
限流操作
- 运行 sentinel-dashboard-1.8.4.jar
- 访问测试功能：http://localhost:8071/user/login?str=1234
- 通过 dashboard 设置限流
连续快速2次访问测试功能
熔断降级
降级方法
- 使用@SentinelResource注解的fallback属性来指定降级的方法名
package com.czxy.controller;
import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import org.apache.commons.lang.math.RandomUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/user")
public class UserController {
@GetMapping("/login")
// 限流设置
@SentinelResource(value="login", blockHandler = "loginBlockHandler")
public String login(String str) {
return "登录成功" + str;
}
public String loginBlockHandler(String str , BlockException e) {
return str + ": 请稍后重试";
}
@GetMapping("/register")
// 熔断降级
@SentinelResource(value="register", fallback = "registerFallback")
public String register(String str) {
int r = RandomUtils.nextInt(10);
if(r < 5) {
int i = 1 / 0;
}
return "注册成功";
}
public String registerFallback(String str) {
return str + ": 熔断降级";
}
}
测试
成功
熔断降级
降级操作
- 慢调用比例：
- RT：平均响应时间
- 比例阈值：
- 熔断时长：
- 最小请求数：
- 异常比例：每秒异常总数占通过量的比值超过阈值（DegradeRule 中的 count）之后，资源进入降级状态
- 异常数：当资源近 1 分钟的异常数目超过阈值之后会进行熔断
限流和降级的区别
- 限流是通过设置QPS(每秒查询率)/线程数，将超过阈值部分拒绝处理；
- 服务降级是监控请求响应时间、响应异常比例、异常数量；超过限定阈值，将进行服务降级熔断，一定时间内不可用；
