我要评论开发环境
环境：java 11、mysql 8.0、openfeign、sentinel-dashboard 1.8.6
为什么要保护
微服务在远程调用时，可能存在以下问题：
1. 业务健壮性：
如，购物车服务、商品服务之间互相调用，当一方挂掉，需要做兜底处理从而优化用户体验
假设，查询购物车接口需要调用商品服务，商品服务挂了导致查询失败，但从业务角度为了提高用户体验，即使查询失败，购物车列表也应该展示出来（展示空数据/缓存数据）。而不是丢给用户一堆报错信息。
2. 级联失败（雪崩问题）：
如，高峰期时查询接口并发高，其他接口并发小；由于高并发接口占用过多的tomcat连接，可能导致所有接口都延迟变高、长时间阻塞甚至失败。
以此类推，当互相调用的服务间出现问题时，可能导致整个集群都不可用
sentinel 实现保护
提示：这里可以添加要学的内容
例如：
- 搭建 java 开发环境
- 掌握 java 基本语法
- 掌握条件语句
- 掌握循环语句
策略1：请求限流
理解：限制/控制接口的请求流量
并发太高是导致服务故障的重要原因。
因此通过限制或控制接口的并发流量，避免服务因流量激增而出现故障。
策略2：线程隔离
理解：提前分配好资源（线程）给业务接口
当一个业务接口响应时间长，而且并发高时，就可能耗尽服务器的线程资源，导致服务内的其它接口受到影响。
因此为了降低/减小这种影响，使用线程隔离，其思想参考舱壁模型
如，查询接口访问频繁，会无休止地占用更多的线程资源，而导致其他业务的线程资源紧张或无法分配。
线程隔离：锁死查询接口20线程，其他业务10线程，就算查询接口并发再高，只给20线程资源去调用，确保了其他业务不被影响。
策略3：服务熔断
理解：对故障/速度慢的接口进行暂时切断，并提供一个友好提示以优化用户体验
服务熔断主要有两点：
- 编写服务降级逻辑：调用失败后的处理逻辑，可抛出异常/友好提示/默认数据/缓存数据。
- 异常统计和熔断：统计异常比例，当比例过高表明该接口会影响到其它服务，应该拒绝调用该接口，而是直接走降级逻辑。
sentinel 流量控制
sentinel 主要有两部分
- 核心库（jar包）：直接引入到
pom.xml就生效，在项目中可以编程式编写限流、隔离、熔断等规则。 - 控制台（dashboard）：负责管理推送规则、监控、管理机器信息等。
依赖引入：
<dependency> <groupid>com.alibaba.cloud</groupid> <artifactid>spring-cloud-starter-alibaba-sentinel</artifactid> <version>2021.0.4.0</version> </dependency>
控制台启动：
下载：控制台jar包
启动：java -dserver.port=8090 -dcsp.sentinel.dashboard.server=localhost:8090 -dproject.name=sentinel-dashboard -jar sentinel-dashboard.jar
配置application.yaml
spring:
cloud:
sentinel:
transport:
dashboard: localhost:8090
http-method-specify: true # 开启请求方式前缀（为了区分get/post/delete等请求）配置策略
细节1：需要触发一次请求才会在sentinel面板看到该接口的簇点
细节2：默认直接在面板上的配置是临时的，重启服务后配置就清空了
具体的流控规则需要根据业务来进行设置
sentinel 服务熔断
问题1：当接口触发sentinel配置的流控规则时，抛出异常，用户体验不佳
解决方案：降级处理，展示空数据/缓存的旧数据
问题2：当a接口需要远程调用b，而b延迟较高，拖慢了a的服务，用户体验差
解决方案：熔断慢接口，直接停止使用b接口，走降级逻辑
本次练习采用的是openfeign远程调用，使用远程调用主要有两种方式
- 方式一：fallbackclass，无法对远程调用的异常做处理
- 方式二：fallbackfactory，可以对远程调用的异常做处理，我们一般选择这种方式。
故使用更为灵活的fallbackfactory
首先配置降级逻辑：返回空集合
@slf4j
public class itemclientfallback implements fallbackfactory<itemclient> {
@override
public itemclient create(throwable cause) {
return new itemclient() {
@override
public list<itemdto> queryitembyids(collection<long> ids) {
log.error("远程调用itemclient#queryitembyids方法出现异常，参数：{}", ids, cause);
// 查询购物车允许失败，查询失败，返回空集合
return collutils.emptylist();
}
@override
public void deductstock(list<orderdetaildto> items) {
log.error("扣减商品库存失败!",cause);
// 库存扣减业务需要触发事务回滚，查询失败，抛出异常
throw new bizillegalexception(cause);
}
};
}
}将降级处理逻辑注册成@bean
/**
* feign配置类
*/
public class defaultfeignconfig {
@bean
public itemclientfallback itemclientfallback(){
return new itemclientfallback();
}
}在远程调用的注解处配置：失败处理逻辑的类
/**
* 远程调用商品服务
*/
@feignclient(value = "item-service",fallbackfactory = itemclientfallback.class)
public interface itemclient {
...
}总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持代码网。
发表评论