如何使用Sentinel实现微服务的请求限流、线程隔离、服务熔断和降级

基于OpenFeign和Sentinel实现服务的请求限流、服务熔断和自动降级

0. 前提和准备

你已经使用openFeign实现了微服务之间的调用。

你会使用Jmeter进行压力测试，不会也没事，我这里有快速入门教学：
如何使用Jmeter对接口进行压力测试

1. Sentinel控制台的下载和安装

下载sentinel控制台的地址：

在jar包的目录下，cmd输入以下运行命令：

1	`java -jar sentinel-dashboard-1.8.6.jar --server.port=8858 \`

访问地址：

1	`http://localhost:8858`

默认账号密码都是sentinel，进入首页：

2. 在服务中引入sentinel的依赖

例如：A服务要调用B服务的接口
则A服务的pom.xml文件加入sentinel的依赖：

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

如果还没有用到openfeign，则还要添加openFeign的依赖：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

3. 配置Sentinel

在A服务（服务调用方）的bootstrap.yml(或者application.yml)配置文件中引入以下配置：

# 控制服务和Sentinel控制台之间的通信行为
spring:
  cloud:
    sentinel:
      transport:
        port: 8719
        dashboard: localhost:8858

# 开启Feign与Sentinel的整合
feign:
  sentinel:
    enabled: true

4. 使用Sentinel控制台

此时访问你要调用的远程接口。

例如，在swagger中访问以下接口：

1	`http://localhost:8084/aimin-admin/drug/category`

然后再打开Sentinel控制台，刷新一下：

可以看到Sentinel开始监控我们的服务了。

5. 服务降级

5.1 在FeignClient接口上加入fallback，指向fallback实现类

@FeignClient(name = "aimin-drug",path = "/aimin-drug",fallback = DrugFeignFallback.class)
public interface DrugFeignClient {
    // .....
    // 你的代码逻辑
}

5.2 实现fallback类

我这边要实现的是DrugFeignFallback.java

因为DrugFeignFallback是DrugFeignClient接口的实现类，所以要重写所有的接口方法

package com.oimc.aimin.admin.feign;

@Component
public class DrugFeignFallback implements DrugFeignClient{

    @Override
    public Result<?> insert(DrugRequest drug) {
        return Result.error("药品服务暂不可用（降级）");
    }

    @Override
    public Result<?> batchDelete(List<Integer> ids) {
        return Result.error("药品服务暂不可用（降级）");
    }

    @Override
    public Result<?> update(DrugRequest drug) {
        return Result.error("药品服务暂不可用（降级）");
    }

    @Override
    public Result<?> getById(String id) {
        return Result.error("药品服务暂不可用（降级）");
    }

    @Override
    public Result<?> drugList() {
        return Result.error("药品服务暂不可用（降级）");
    }

    @Override
    public Result<?> page(PageDrugRequest page) {
        return Result.error("药品服务暂不可用（降级）");
    }

    @Override
    public Result<?> categoryTree(Integer id) {
        return Result.error("药品服务暂不可用（降级）");
    }

    @Override
    public Result<?> categoryList() {
        return Result.error("药品服务暂不可用（降级）");
    }

    @Override
    public Result<?> insertCategory(DrugCategoryRequest request) {
        return Result.error("药品服务暂不可用（降级）");
    }

    @Override
    public Result<?> updateCategory(Integer id, DrugCategoryRequest request) {
        return Result.error("药品服务暂不可用（降级）");
    }

    @Override
    public Result<?> deleteCategory(Integer id) {
        return Result.error("药品服务暂不可用（降级）");
    }

    @Override
    public Result<?> batchUpload(@RequestPart List<MultipartFile> files) {
        return Result.error("药品上传服务暂不可用（降级）");
    }

    @Override
    public Result<Boolean> setMainImage(Integer imageId) {
        return Result.error("图片设置失败，药品服务不可用（降级）");
    }

    @Override
    public Result<?> getById(Integer imageId) {
        return Result.error("图片查询失败，药品服务不可用（降级）");
    }

    @Override
    public Result<?> listByDrugId(Integer drugId) {
        return Result.error("药品图片列表服务暂不可用（降级）");
    }

    @Override
    public Result<Boolean> deleteImage(Integer imageId) {
        return Result.error("图片删除失败，药品服务不可用（降级）");
    }

    @Override
    public void deleteImageByPath(String path) {
        // void 方法不返回值，降级处理方式：只打印日志即可
        System.err.println("药品服务不可用，无法删除图片路径!");
    }

}