springboot整合Sentinel实现服务熔断-降级-限流

前言：服务熔断、降级、限流基本概念 Hystrix与Sentinel对比：

1.导入Sentinel依赖

<dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId> </dependency>

2.下载sentinel控制台 官网：

https://github.com/alibaba/Sentinel/releases

3.配置sentinel控制台地址信息 端口任意

spring.cloud.sentinel.transport.port=8719 spring.cloud.sentinel.transport.dashboard=localhost:8333

4.在控制台调整参数 【默认所有的流控设置都保存在内存中 重启失效】

5.每一个微服务 都导入actuator(); 并配合 management.endpoints.web.exposure.include=*

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

6.自定义sentinel流控规则

7.使用sentinel来保护feign的远程调用：熔断; 1).调用方的保护：在properties文件中配置： feign.sentinel.enabled=true 2).调用方手动指定远程服务的降级策略。远程服务被降级处理，触发我们的熔断回调方法。 3）超大访问量时，必须牺牲一些远程服务，在服务的提供方(远程服务)指定降级策略，提供方在运行，但运行的不是自己的业务逻辑，返回的是降级的方法返回数据 --> 限流的数据

示例：远程调用经常会发生读取超时，要指定fallback

@FeignClient(value = "member",fallback = MemberFeignServiceFallBack.class) public interface MemberFeignService { @PostMapping("/login") R oauthLogin(@RequestBody SocialUser socialUser); }

实现远程调用接口，并加入容器中

@Component @Slf4j public class MemberFeignServiceFallBack implements MemberFeignService { @Override public R oauthLogin(SocialUser socialUser) { log.info("熔断方法MemberFeignServiceFallBack--》》oauthLogin 执行了"); return R.error(BizCodeEnume.TOO_MANY_REQUEST.getCode(),BizCodeEnume.TOO_MANY_REQUEST.getMsg()); } }

8.注解方式定义资源 Sentinel 支持通过 @SentinelResource 注解定义资源并配置 blockHandler 和 fallback 函数来进行限流之后的处理。 9.抛出异常的方式定义资源 SphU 包含了 try-catch 风格的 API。用这种方式，当资源发生了限流之后会抛出 BlockException。这个时候可以捕捉异常，进行限流之后的逻辑处理。示例代码如下:

// 1.5.0 版本开始可以利用 try-with-resources 特性（使用有限制） // 资源名可使用任意有业务语义的字符串，比如方法名、接口名或其它可唯一标识的字符串。 try (Entry entry = SphU.entry("resourceName")) { // 被保护的业务逻辑 // do something here... } catch (BlockException ex) { // 资源访问阻止，被限流或被降级 // 在此处进行相应的处理操作 }