当前位置:   article > 正文

springboot整合Sentinel实现服务熔断-降级-限流_springboot熔断后,后期还能调嘛

springboot熔断后,后期还能调嘛

前言:服务熔断、降级、限流基本概念
在这里插入图片描述
Hystrix与Sentinel对比:
在这里插入图片描述

1.导入Sentinel依赖

<dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
  • 1
  • 2
  • 3
  • 4

2.下载sentinel控制台
官网:

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

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

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

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

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

<dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
  • 1
  • 2
  • 3
  • 4

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);
  }
  • 1
  • 2
  • 3
  • 4
  • 5

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

@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());
    }
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9

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) {
  // 资源访问阻止,被限流或被降级
  // 在此处进行相应的处理操作
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/你好赵伟/article/detail/740918
推荐阅读
相关标签
  

闽ICP备14008679号