Spring-alibaba-sentinel具体配置使用，持久化策略

﹏ヽ暗。殇╰゛Y 2021-06-10 20:39 300阅读 0赞

\*\*Sentinel：\*\*随着微服务的流行，服务和服务之间的稳定性变得越来越重要。  
Sentinel 以流量为切入点，从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。  
是用来管理和配置服务的流控，降级，熔断等等的。

## Sentinel下载 ##

首先我们自然要下载**sentinel**  
2020年9月25日目前的最新版本是1.8.0  
下载地址：**https://github.com/alibaba/Sentinel**

## 启动事项 ##

而sentinel启动的**默认端口**为**8080**，这和Tomcat的端口重合，所以当端口重合的时候启动就会报错，  
我们要修改Sentinel的启动端口  
使用下面这段代码来进行启动

java -Dserver.port=8858 -jar sentinel-dashboard-1.8.0.jar

这样就把启动的端口改为**8858**而不会和Tomcat的8080重合报错  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center]

## 运行界面 ##

cmd运行成功后我们打开浏览器，输入localhost：8858进入到下面页面就是运行成功  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 1]  
账户密码初始都是sentinel  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 2]  
一开始应该是一片空白，我这里是已经运行过的。  
那么我们先来配置一个服务端来登录sentinel来进行调试

## 配置服务端 ##

**pom**

<dependency>
                <groupId>com.qwf</groupId>
                <artifactId>cloud-api-commons</artifactId>
                <version>${project.version}</version>
            </dependency>
            
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            </dependency>
            
            <dependency>
                <groupId>com.alibaba.csp</groupId>
                <artifactId>sentinel-datasource-nacos</artifactId>
            </dependency>
            
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>cn.hutool</groupId>
                <artifactId>hutool-all</artifactId>
                <version>4.6.3</version>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>

这里有些配置后续会用到，我先导入，**spring-cloud-starter-openfeign**和**sentinel-datasource-nacos**暂时用不到，后面我再慢慢讲

**application.yml**

server:
      port: 8401
    spring:
      application:
        name: cloudalibaba-sentinel-service
      cloud:
        nacos:
          discovery:
            server-addr: localhost:8848
        sentinel:
          transport:
            dashboard: localhost:8858
            port: 8719
    management:
      endpoints:
        web:
          exposure:
            include: "*"

这里的**spring.cloud.nacos.discovery.server-addr**是链接到*nacos*的路径  
下面的**spring.cloud.sentinel.transport.dashboard**是链接的*sentinel*的路径，

**port**是在应用对应的机器上启动一个 Http Server，该 **Server 会与 Sentinel 控制台做交互**。比如 Sentinel 控制台添加了1个限流规则，会把规则**数据 push 给这个 Http Server 接收**，**Http Server 再将规则注册到 Sentinel 中**。  
默认这个server端口是**从8719开始**，如果被占就+1从8720一直到找到空闲的端口为止。

**management.endpoints.web.exposure.include**是把包含的节点全部暴露给监控

***main方法***

@SpringBootApplication
    @EnableDiscoveryClient
    public class SentinelServiceMain8401 {
        public static void main(String[] args) {
            SpringApplication.run(SentinelServiceMain8401.class,args);
        }
    }

下面我们先写两个方法来测试  
**FlowLimitController**

@RestController
    @Slf4j
    public class FlowLimitController {
        @GetMapping(value = "/testA")
        public String getTestA(){
            log.info(Thread.currentThread().getName()+"\t"+"........textA");
            return "************TestA";
        }
        
        @GetMapping(value = "/testB")
        public String getTestB(){
            return "************TestB";
        }

简单的配置完成，我们运行查看

## 运行调试 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 3]  
发现可以直接通过  
接下来我们观察Sentinel发生了什么变化  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 4]  
原本空白的界面出现了我们配置的服务，sentinel是服务运行通过之后才会获取服务信息。  
我们再来看一下服务监控，点击簇点链路  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 5]  
可以发现我们刚刚点的路径名testA，而上面的context是服务一步步获取的路径。  
我们先点击流控  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 6]  
在这里开始解释：  
针对来源是特指对调用这个服务的人进行流控，default是指没有  
阈值类型QPS是每秒钟请求的次数，线程数是指电脑处理对testA的请求的线程数，  
是否集群不用解释

## **流控模式**： ##

**直接**：就是直接对testA资源进行流控，  
**关联**：比如说链接testB，单机阈值为1，textB每秒访问量超过1了，textA就不能用了，就像支付系统 要瘫痪了，下订单接口就先不能用，缓解支付系统压力。  
**链路**：我们访问testA不是直接访问，是先访问sentinel\_web\_servlet\_context再访问testA，可是sentinel\_web\_servlet\_context当中还有其他方法，当这个服务的访问其他方法过多比如访问testB服务过多，为了缓解压力就不让testA访问了，把资源都给其他方法。

说了这么多不如来动手看一下  
**第一种：QPS直接快速失败，阈值为1**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 7]  
在我们连续点击刷新testA后  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 8]  
sentinel发现一秒访问数超过一次，在这一秒内访问都被拒绝

**第二种：QPS直接warm up，阈值为3，预热时长为3**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 9]  
预热时长是指一开始点击并不是到了阈值才流控，而是阈值除以预热时长然后均匀上升直到阈值，这样防止平常无人访问突然来了很大量的访问，系统承受不住直接崩溃，一开始不让你达到阈值慢慢放开，可以防止系统崩溃。

**第三种：：QPS直接排队，阈值为1，超时时间为20秒**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 10]  
如果短时间内大量的请求进来，我就一秒钟处理一个一秒钟处理一个，等待超过20秒的请求就报超时错误。  
下面我用postman连续300毫秒请求30次，观察后台的日志消息时间。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 11]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 12]  
可以观察到一秒钟后台信息出现一次，说明后台一秒钟只处理一次信息

**第四种：：QPS关联快速，阈值为1**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 13]  
我们用postman用200ms调用testB40次，调用期间我们来调用testA。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 14]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 15]

可以看到testA运行失败已经被限流

**第五种：：QPS链路快速，阈值为1**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 16]  
此时我们对testB做相同操作  
得出和上面相同的结果，但是过程不同，上方是对testB控制，这个是对入口限制。

## 降级 ##

降级有三种模式  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 17]  
**慢调用比例：指在一秒内发生的最小请求数（默认是5）当中的RT（请求响应的最久时间）是否超出设定阈值并且超过了全部请求的设定比例。就会熔断。**  
比如说如下图  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 18]  
这个图的意思是当我我一秒钟的请求大于等于5个，而且其中有一半以上的请求数的响应时间都大于200毫秒，我就停止访问5秒。

我们修改一下testA方法，使响应时间大于200毫秒

@GetMapping(value = "/testA")
        public String getTestA(){
            try {
                TimeUnit.MILLISECONDS.sleep(800);
    
            }
            catch (InterruptedException e){
                e.printStackTrace();
            }
            log.info(Thread.currentThread().getName()+"\t"+"........textA");
            return "************TestA";
    
        }

修改之后可以看到运行5次之后TestA开始报错误信息，因为每次响应都超过200毫秒  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 19]  
异常比例就是一秒钟报错的占全部的百分之多少就熔断。  
异常数是以分钟计算，超过就熔断。

## 热点 ##

为了测试热点我们先创建一个getHotKey方法，可以传入p1和p2两个字符串参数而且不用必须要传。  
这里热点限流会直接报500，我们使用@**SentinelResource**来做服务降级

@SentinelResource很像@**HystrixCommand**，  
当发生错误时选择一个方法来作为**服务降级**，  
但是发生的**Sentinel配置错误使用的是blockHandler** ，不要选错。  
**方法运行报错使用的是fallback**。而使用热点必须配置@SentinelResource。否则无法使用。  
这里热点限流明显是sentinel配置错误，使用blockHandler 。

@GetMapping(value = "/hotkey")
        @SentinelResource(value = "hotkey",blockHandler = "hotkey_Fallback")
        public String getHotKey(@RequestParam(value = "p1",required = false) String p1,
                               @RequestParam(value = "p2",required = false) String p2){
            return "************hotkey";
        }
        
        public String hotkey_Fallback(String p1, String p2, BlockException exception){
            return "************hotkey_Fallback,o(╥﹏╥)o";
        }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 20]  
热点是只能用QPS模式，参数索引是指你传入的第几个参数，从0开始，比如说getHotKey的p1参数就是0，p2就是1。  
阈值和时长就不解释了。  
我们设定hotkey的热点，设定p1一秒钟只能调用一次  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 21]  
当我们不传p1时可以快速刷新而hotkey不会限流  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 22]  
而传入p1参数后刷新2次就被限流了  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 23]

## @SentinelResource讲解 ##

首先我们创建一个新的controller来查看@SentinelResource的配置

@GetMapping("/byResource")
        @SentinelResource(value = "byResource",blockHandler = "byResource_Fallback")
        public ConmonResult byResource(){
            return new ConmonResult(200,"按资源名称限流测试",new Payment(2020L,"serial0001"));
        }
        
        public ConmonResult byResource_Fallback(BlockException e){
            return new ConmonResult(444,e.getClass().getCanonicalName()+"\t"+"服务不可用");
        }

@SentinelResource当中的value为sentinel当中看到的资源名，可以随意命名，但为了规范最好和方法名或者路径名相同。

blockHandler 是指当发生限流时，该使用那个服务降级方法。默认的就是sentinel limited  
我们可以测试一下发生降级时调用了哪个方法名  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 24]  
![在这里插入图片描述][20200926021131994.png_pic_center]  
发生降级会调用com.alibaba.csp.sentinel.slots.block.flow.FlowException这个方法来进行服务降级

## sentinel配置持久化 ##

但是会发现一个问题，当我们重启服务时，我这边的服务是8401  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 25]  
我们再看一下sentinel  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 26]  
可以看到我们之前配置的流控，热点，降级方法都没有了。如果这样每次我们更新都要重新配置一次。那是多么大而且麻烦的工作。

我们可以在application.yml中修改spring，在里面修改成下面这段代码

spring:
      application:
        name: cloudalibaba-sentinel-service
      cloud:
        nacos:
          discovery:
            server-addr: localhost:8848
        sentinel:
          transport:
            dashboard: localhost:8858
            port: 8719
          datasource:
            ds1:
              nacos:
                server-addr: localhost:8848
                dataId: cloudalibaba-sentinel-service
                groupId: DEFAULT_GROUP
                data-type: json
                rule-type: flow

我们链接到nacos，创建下面这个配置cloudalibaba-sentinel-service，名称就是spring.cloud.sentinel.datasource.ds1.nacos.dataId的内容，格式为json![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 27]  
**resource**是资源名  
**limitApp**是来源应用  
**grade**是阈值类型，**0是线程，1是QPS**  
**count**是阈值  
**strategy**是流控模式，**0是直接，1是关联，2是链接**  
**controlBehavior**是流控效果，**0是直接，1是warm up，2是排队**  
**clusterMode**是集群模式  
这样就配置成功每次运行时都会使byGlobalRescource按照QPS快速直接，阈值为1非集群环境下限流，实现了持久化。

## 全局服务降级方法 ##

但是@ServiceResource每次都要编写一个服务降级方法，既增加了代码量，耦合还更高了。自然可以写一个方法全局调用  
我们写一个全局服务降级方法的handler

public class ConsumerBlockHandler {
        public static ConmonResult handlerException1(BlockException e){
            return new ConmonResult(4444,"handlerException1的fallback");
        }
        public static ConmonResult handlerException2(BlockException e){
            return new ConmonResult(4444,"handlerException2的fallback");
        }
    }

再在controller中添加一个应用全局配置的方法

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 28]

![在这里插入图片描述][20200926024405509.png_pic_center]

![在这里插入图片描述][20200926024549505.png_pic_center]  
可以看到调用服务降级方法成功，这样减少了代码量还减少了耦合，看起来舒服了很多。

我们再来修改一下byGlobalResource（）方法

@GetMapping("/byGlobalResource")
        @SentinelResource(value = "byGlobalResource",blockHandlerClass=
        ConsumerBlockHandler.class,blockHandler = "handlerException1",fallback="byGlobalResourceFallback" )
        public ConmonResult byGlobalResource(){
            Integer a=10/0;
            return new ConmonResult(200,"按资源名称限流测试",new Payment(2020L,"serial0001"));
        }
        
        public ConmonResult byGlobalResourceFallback(){
            return new ConmonResult(445,"运行错误，调用byGlobalResourceFallback",new Payment(2020L,"error"));
        }

当blockHandler 和fallback同时存在时，会调用哪一个呢  
我们设置了一个除0错误。运行时出现  
![在这里插入图片描述][20200926025206342.png_pic_center]  
发现了是调用fallback当中的服务降级方法，但是如果我们也设置限流然后多运行几次会发生什么呢？  
![在这里插入图片描述][20200926025331800.png_pic_center]  
发现一开始几次是fallback错误，后面限流开始调用blockHandler 错误。由此我们也明白了sentinel的优先级。

## sentinel和openfeign结合 ##

首先我们要在父工程pom中的依赖最上方添加

<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-openfeign-dependencies</artifactId>
            <version>2.2.0.RELEASE</version>
            <type>pom</type>
            <scope>import</scope>
          </dependency>

用最新的openfeign会报错

看了一下代码，问题的表现是从Sentinel抛出，本质是由于feign核心接口方法命名纠正拼写错误导致

Hoxton.SR7 中，fegin.context接口方法的定义为parseAndValidateMetadata

很明显是为了纠正拼写错误。我们先降低openfeign版本到2.2.0.RELEASE

## 我们先创建一个服务端 ##

**pom**

<dependencies>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            <dependency>
                <groupId>com.alibaba.csp</groupId>
                <artifactId>sentinel-datasource-nacos</artifactId>
            </dependency>
            
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
            <dependency>
                <groupId>com.qwf</groupId>
                <artifactId>cloud-api-commons</artifactId>
                <version>${project.version}</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>

**application.yml**

server:
      port: 9001
    spring:
      application:
        name: nacos-payment-provider
      cloud:
        nacos:
          discovery:
            server-addr: localhost:8848
        sentinel:
          transport:
            dashboard: localhost:8858
            port: 8719
    management:
      endpoints:
        web:
          exposure:
            include: "*"

**main**

@SpringBootApplication
    @EnableDiscoveryClient
    public class AlibabaProviderMain9002 {
        public static void main(String[] args) {
            SpringApplication.run(AlibabaProviderMain9002.class,args);
        }
    }

**controller**

@RestController
    public class VirtualDatabaseController {
        @Value("${server.port}")
        private String port;
    
        public static HashMap<Long, Payment> hashMap=new HashMap<>();
        static {
            hashMap.put(1L,new Payment(1L,"6eb391a3-345f-43e5-a940-d2ca5001e589"));
            hashMap.put(2L,new Payment(2L,"63cf224d-79af-41a7-b0c6-3a992da6dd46"));
            hashMap.put(3L,new Payment(3L,"f5d8d70b-f15f-47fd-9251-b809939955e5"));
        }
        @GetMapping("/paymentSQL/{id}")
        public ConmonResult<Payment> paymentSQL(@PathVariable(value = "id") Long id){
            Payment payment=hashMap.get(id);
            ConmonResult<Payment> result=new ConmonResult(200,"from mysql, porr="+port,payment);
            return result;
        }
    }

## 用户端 ##

**pom**

<dependencies>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
            
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            </dependency>
            
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
            </dependency>
            
            <dependency>
                <groupId>com.qwf</groupId>
                <artifactId>cloud-api-commons</artifactId>
                <version>${project.version}</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>

**application.yml**

server:
      port: 84
    spring:
      application:
        name: nacos-order-consumer
      cloud:
        nacos:
          discovery:
            server-addr: localhost:8848
        sentinel:
          transport:
            dashboard: localhost:8858
            port: 8719
    service-url:
      nacos-user-service: http://nacos-payment-provider
    feign:
      sentinel:
        enabled: true

相比于服务端多了一个feign.sentinel.enabled=true  
**main方法**

@SpringBootApplication
    @EnableDiscoveryClient
    @EnableFeignClients
    public class SentinelConsumerMain84 {
        public static void main(String[] args) {
            SpringApplication.run(SentinelConsumerMain84.class,args);
        }
    }

**service接口**

@Component("PaymentService")
    @FeignClient(value = "nacos-payment-provider",fallback = PaymentServiceImpl.class)
    public interface PaymentService
    {
        @GetMapping(value = "/paymentSQL/{id}")
        public ConmonResult<Payment> paymentSQL(@PathVariable("id") Long id);
    }

service当中使用了@FeignClient，其中value是链接服务的服务名，fallback是发生服务降级调用方法的类名  
**PaymentServiceImpl**

@Component
    public class PaymentServiceImpl implements PaymentService {
        @Override
        public ConmonResult<Payment> paymentSQL(Long id) {
            return new ConmonResult<>(44444,"发生服务降级，--PaymentFallbackService",new Payment(id,"errorSerial"));
        }
    }

**controller**

@Resource
        private PaymentService paymentService;
    
        @GetMapping("/consumer/openFeign/paymentSQL/{id}")
        public ConmonResult<Payment> paymentSQL(@PathVariable(value = "id") Long id){
            ConmonResult<Payment> result= paymentService.paymentSQL(id);
            if(id==4){
                throw new IllegalArgumentException("IllegalArgumentException，非法参数异常");
            }
            else if(result.getData()==null){
                throw new NullPointerException("空指针异常");
            }
            return result;
    
        }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center]: /images/20210527/d8bb31700b214b8f880a9e4f3e948ccb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20210527/eaa644020d7a465c9fd6ace987729848.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20210527/4ebe4fcffb924264a769b851ee6b5c6c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20210527/9271062d045e4273a5e6696fdebc8a3c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 4]: /images/20210527/acf700e8832844a5a94d2a72bf541f6b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 5]: /images/20210527/9f113699d081425aaf39d412cea95cb2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 6]: /images/20210527/2e008451c5bf45a592d0ef60aa8f6cc8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 7]: /images/20210527/16e66c5183e64d33aeee2d19be5bf978.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 8]: /images/20210527/08e3c9308eba408189b8cb9e22086874.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 9]: /images/20210527/85df81a808224296870140908244fc0f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 10]: /images/20210527/3c9904b863b144418e0fe60fb2ec5595.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 11]: /images/20210527/3b9d2d48b3224dc89238051f10f40d71.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 12]: /images/20210527/556400a94a1b491e8b53ee93e5b14231.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 13]: /images/20210527/ec8b9e035e904ac38c9950f1a9070786.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 14]: /images/20210527/25381ffa82504b5fa0233460a50748e9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 15]: /images/20210527/684b8d69b1224b2abacdc07dd7e7f449.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 16]: /images/20210527/3eb51a09c3c843d59ce31788436b370f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 17]: /images/20210527/bd3dfa8590f54074af874f9be9ce10da.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 18]: /images/20210527/15907e19a44f4020bd4e79ba5bd1fca9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 19]: /images/20210527/d0fd2a2874b449e5bc7280097dfe8c4b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 20]: /images/20210527/8626ca08cce24c3e9e29d584af87868e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 21]: /images/20210527/3342ee40ff7b4cf482075df9be8914d4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 22]: /images/20210527/16eea7deb9c846da90a27932db862fc5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 23]: /images/20210527/0334350761a34420bec2ee1d8e048d92.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 24]: /images/20210527/36c46902a27942e2be4fc6e6e37f4cff.png
[20200926021131994.png_pic_center]: /images/20210527/8fcf7af39f73423c90193200cb0f37a7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 25]: /images/20210527/34e6baaa030549668756c39121a92c44.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 26]: /images/20210527/d14f3eadb62544749fa3b13bc40068ba.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 27]: /images/20210527/09761fc8d4f84e168d49d95cd6f1b985.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODUwNjI3_size_16_color_FFFFFF_t_70_pic_center 28]: /images/20210527/f4d8126be64d4c8cb94356b2f1ab07f7.png
[20200926024405509.png_pic_center]: /images/20210527/0d7bcfe1ae7649e2a31dbb76b72992cc.png
[20200926024549505.png_pic_center]: /images/20210527/d1da2eeda0694755ba66afaefd0792af.png
[20200926025206342.png_pic_center]: /images/20210527/71d89d9d597540aa9ee92f755f2f74b8.png
[20200926025331800.png_pic_center]: /images/20210527/d44b5c664ce14bd09b79b17aad53562a.png