• sentinel整合ribbon+fallback（5）

    前期准备：

    启动nacos和sentinel

    提供者9003/9004 （以9003为样本）

    新建cloudalibaba-provider-payment9003/9004

    pom文件

    1.  
    2. "1.0" encoding="UTF-8"?>
    3. <project xmlns="http://maven.apache.org/POM/4.0.0"
    4.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    5.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    6.     <parent>
    7.         <artifactId>mscloud03artifactId>
    8.         <groupId>com.atguigu.springcloudgroupId>
    9.         <version>1.0-SNAPSHOTversion>
    10.     parent>
    11.     <modelVersion>4.0.0modelVersion>
    12.  
    13.     <artifactId>cloudalibaba-provider-payment9003artifactId>
    14.  
    15.  
    16.  
    17.     <dependencies>
    18.         
    19.         <dependency>
    20.             <groupId>com.alibaba.cloudgroupId>
    21.             <artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId>
    22.         dependency>
    23.         <dependency>
    24.             <groupId>com.atguigu.springcloudgroupId>
    25.             <artifactId>cloud-api-commonsartifactId>
    26.             <version>${project.version}version>
    27.         dependency>
    28.         
    29.         <dependency>
    30.             <groupId>org.springframework.bootgroupId>
    31.             <artifactId>spring-boot-starter-webartifactId>
    32.         dependency>
    33.         <dependency>
    34.             <groupId>org.springframework.bootgroupId>
    35.             <artifactId>spring-boot-starter-actuatorartifactId>
    36.         dependency>
    37.         
    38.         <dependency>
    39.             <groupId>org.springframework.bootgroupId>
    40.             <artifactId>spring-boot-devtoolsartifactId>
    41.             <scope>runtimescope>
    42.             <optional>trueoptional>
    43.         dependency>
    44.         <dependency>
    45.             <groupId>org.projectlombokgroupId>
    46.             <artifactId>lombokartifactId>
    47.             <optional>trueoptional>
    48.         dependency>
    49.         <dependency>
    50.             <groupId>org.springframework.bootgroupId>
    51.             <artifactId>spring-boot-starter-testartifactId>
    52.             <scope>testscope>
    53.         dependency>
    54.     dependencies>
    55. project>

    yml文件

    1. server:
    2.   port: 9003
    3.  
    4. spring:
    5.   application:
    6.     name: nacos-payment-provider
    7.   cloud:
    8.     nacos:
    9.       discovery:
    10.         server-addr: localhost:8848 #配置Nacos地址
    11.  
    12. management:
    13.   endpoints:
    14.     web:
    15.       exposure:
    16.         include: '*'

    配置9004的时候记得修改端口 

    主启动类

    1. @SpringBootApplication
    2. @EnableDiscoveryClient
    3. public class PaymentMain9003
    4. {
    5.     public static void main(String[] args) {
    6.             SpringApplication.run(PaymentMain9003.class, args);
    7.     }
    8. }

    业务类

    1. @RestController
    2. public class PaymentController
    3. {
    4.     @Value("${server.port}")
    5.     private String serverPort;
    6.  
    7.     public static HashMap hashMap = new HashMap<>();
    8.     static
    9.     {
    10.         hashMap.put(1L,new Payment(1L,"28a8c1e3bc2742d8848569891fb42181"));
    11.         hashMap.put(2L,new Payment(2L,"bba8c1e3bc2742d8848569891ac32182"));
    12.         hashMap.put(3L,new Payment(3L,"6ua8c1e3bc2742d8848569891xt92183"));
    13.     }
    14.  
    15.     @GetMapping(value = "/paymentSQL/{id}")
    16.     public CommonResult paymentSQL(@PathVariable("id") Long id)
    17.     {
    18.         Payment payment = hashMap.get(id);
    19.         CommonResult result = new CommonResult(200,"from mysql,serverPort:  "+serverPort,payment);
    20.         return result;
    21.     }
    22.  
    23.  
    24.  
    25. }

    测试1

    启动9003访问localhost:9003/paymentSQL/1 

     

    消费者84 

    新建cloudalibaba-consumer-nacos-order84 

    pom文件

     

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <parent>
    6.         <artifactId>mscloud03artifactId>
    7.         <groupId>com.atguigu.springcloudgroupId>
    8.         <version>1.0-SNAPSHOTversion>
    9.     parent>
    10.     <modelVersion>4.0.0modelVersion>
    11.  
    12.     <artifactId>cloudalibaba-consumer-nacos-order84artifactId>
    13.  
    14.     <dependencies>
    15.         
    16.         <dependency>
    17.             <groupId>com.alibaba.cloudgroupId>
    18.             <artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId>
    19.         dependency>
    20.         
    21.         <dependency>
    22.             <groupId>com.alibaba.cloudgroupId>
    23.             <artifactId>spring-cloud-starter-alibaba-sentinelartifactId>
    24.         dependency>
    25.         
    26.         <dependency>
    27.             <groupId>com.atguigu.springcloudgroupId>
    28.             <artifactId>cloud-api-commonsartifactId>
    29.             <version>${project.version}version>
    30.         dependency>
    31.         
    32.         <dependency>
    33.             <groupId>org.springframework.bootgroupId>
    34.             <artifactId>spring-boot-starter-webartifactId>
    35.         dependency>
    36.         <dependency>
    37.             <groupId>org.springframework.bootgroupId>
    38.             <artifactId>spring-boot-starter-actuatorartifactId>
    39.         dependency>
    40.         
    41.         <dependency>
    42.             <groupId>org.springframework.bootgroupId>
    43.             <artifactId>spring-boot-devtoolsartifactId>
    44.             <scope>runtimescope>
    45.             <optional>trueoptional>
    46.         dependency>
    47.         <dependency>
    48.             <groupId>org.projectlombokgroupId>
    49.             <artifactId>lombokartifactId>
    50.             <optional>trueoptional>
    51.         dependency>
    52.         <dependency>
    53.             <groupId>org.springframework.bootgroupId>
    54.             <artifactId>spring-boot-starter-testartifactId>
    55.             <scope>testscope>
    56.         dependency>
    57.     dependencies>
    58. project>

    yml文件

    1. server:
    2.   port: 84
    3.  
    4.  
    5. spring:
    6.   application:
    7.     name: nacos-order-consumer
    8.   cloud:
    9.     nacos:
    10.       discovery:
    11.         server-addr: localhost:8848
    12.     sentinel:
    13.       transport:
    14.         #配置Sentinel dashboard地址
    15.         dashboard: localhost:8080
    16.         #默认8719端口，假如被占用会自动从8719开始依次+1扫描,直至找到未被占用的端口
    17.         port: 8719
    18.  
    19.  
    20. #消费者将要去访问的微服务名称(注册成功进nacos的微服务提供者)
    21. service-url:
    22.   nacos-user-service: http://nacos-payment-provider

    主启动

    1. @EnableDiscoveryClient
    2. @SpringBootApplication
    3. public class OrderNacosMain84
    4. {
    5.     public static void main(String[] args) {
    6.             SpringApplication.run(OrderNacosMain84.class, args);
    7.     }
    8. }

    配置类 

    1. @Configuration
    2. public class ApplicationContextConfig
    3. {
    4.     @Bean
    5.     @LoadBalanced
    6.     public RestTemplate getRestTemplate()
    7.     {
    8.         return new RestTemplate();
    9.     }
    10. }

    业务类1

    1. @RestController
    2. @Slf4j
    3. public class CircleBreakerController
    4. {
    5.     public static final String SERVICE_URL = "http://nacos-payment-provider";
    6.  
    7.     @Resource
    8.     private RestTemplate restTemplate;
    9.  
    10.     @RequestMapping("/consumer/fallback/{id}")
    11.     @SentinelResource(value = "fallback") 
    12.      public CommonResult fallback(@PathVariable Long id)
    13.     {
    14.         CommonResult result = restTemplate.getForObject(SERVICE_URL + "/paymentSQL/"+id,CommonResult.class,id);
    15.  
    16.         if (id == 4) {
    17.             throw new IllegalArgumentException ("IllegalArgumentException,非法参数异常....");
    18.         }else if (result.getData() == null) {
    19.             throw new NullPointerException ("NullPointerException,该ID没有对应记录,空指针异常");
    20.         }
    21.  
    22.         return result;
    23.     }
    24. }

    测试2 

    启动9003 9004 84

    访问http://localhost:84/consumer/fallback/1

      再访问http://localhost:84/consumer/fallback/1

     可以发现第一次是9004端口，第二次是9003端口，这里面的话，就可以就知道意见实现了ribbon中的轮训

    测试3 

     访问http://localhost:84/consumer/fallback/4http://localhost:84/consumer/fallback/4

    给客户error页面，不友好 

     修改业务类（只配置fallback）

    1. @RestController
    2. @Slf4j
    3. public class CircleBreakerController
    4. {
    5.     public static final String SERVICE_URL = "http://nacos-payment-provider";
    6.  
    7.     @Resource
    8.     private RestTemplate restTemplate;
    9.  
    10.     @RequestMapping("/consumer/fallback/{id}")
    11.     @SentinelResource(value = "fallback",fallback = "handlerFallback") //fallback负责业务异常
    12.     public CommonResult fallback(@PathVariable Long id)
    13.     {
    14.         CommonResult result = restTemplate.getForObject(SERVICE_URL + "/paymentSQL/"+id,CommonResult.class,id);
    15.  
    16.         if (id == 4) {
    17.             throw new IllegalArgumentException ("IllegalArgumentException,非法参数异常....");
    18.         }else if (result.getData() == null) {
    19.             throw new NullPointerException ("NullPointerException,该ID没有对应记录,空指针异常");
    20.         }
    21.  
    22.         return result;
    23.     }
    24.     public CommonResult handlerFallback(@PathVariable  Long id,Throwable e) {
    25.         Payment payment = new Payment(id,"null");
    26.         return new CommonResult<>(444,"兜底异常handlerFallback,exception内容  "+e.getMessage(),payment);
    27.     }
    28. }

     本例sentinel无配置

    测试4

    访问http://localhost:84/consumer/fallback/4

    这里可以发现没有出现error界面，而是我们自己配置的兜底的处理方案 

     修改业务类（只配置blockHandler ）

    1. @RestController
    2. @Slf4j
    3. public class CircleBreakerController
    4. {
    5.     public static final String SERVICE_URL = "http://nacos-payment-provider";
    6.  
    7.     @Resource
    8.     private RestTemplate restTemplate;
    9.  
    10.     @RequestMapping("/consumer/fallback/{id}")
    11.      @SentinelResource(value = "fallback",blockHandler = "blockHandler") //blockHandler负责在sentinel里面配置的降级限流
    12.     public CommonResult fallback(@PathVariable Long id)
    13.     {
    14.         CommonResult result = restTemplate.getForObject(SERVICE_URL + "/paymentSQL/"+id,CommonResult.class,id);
    15.         if (id == 4) {
    16.             throw new IllegalArgumentException ("非法参数异常....");
    17.         }else if (result.getData() == null) {
    18.             throw new NullPointerException ("NullPointerException,该ID没有对应记录");
    19.         }
    20.         return result;
    21.     }
    22.     public CommonResult handlerFallback(@PathVariable  Long id,Throwable e) {
    23.         Payment payment = new Payment(id,"null");
    24.         return new CommonResult<>(444,"fallback,无此流水,exception  "+e.getMessage(),payment);
    25.     }
    26.     public CommonResult blockHandler(@PathVariable  Long id,BlockException blockException) {
    27.         Payment payment = new Payment(id,"null");
    28.         return new CommonResult<>(445,"blockHandler-sentinel限流,无此流水: blockException  "+blockException.getMessage(),payment);
    29.     }
    30.  
    31. }

     配置sentinel

     测试5

     访问2次以后http://localhost:84/consumer/fallback/4

      修改业务类（fallback和blockHandler都配置）

    1. @RestController
    2. @Slf4j
    3. public class CircleBreakerController
    4. {
    5.     public static final String SERVICE_URL = "http://nacos-payment-provider";
    6.  
    7.     @Resource
    8.     private RestTemplate restTemplate;
    9.  
    10.     @RequestMapping("/consumer/fallback/{id}")
    11.      @SentinelResource(value = "fallback",fallback = "handlerFallback",blockHandler = "blockHandler")
    12.     public CommonResult fallback(@PathVariable Long id)
    13.     {
    14.         CommonResult result = restTemplate.getForObject(SERVICE_URL + "/paymentSQL/"+id,CommonResult.class,id);
    15.         if (id == 4) {
    16.             throw new IllegalArgumentException ("非法参数异常....");
    17.         }else if (result.getData() == null) {
    18.             throw new NullPointerException ("NullPointerException,该ID没有对应记录");
    19.         }
    20.         return result;
    21.     }
    22.     public CommonResult handlerFallback(@PathVariable  Long id,Throwable e) {
    23.         Payment payment = new Payment(id,"null");
    24.         return new CommonResult<>(444,"fallback,无此流水,exception  "+e.getMessage(),payment);
    25.     }
    26.     public CommonResult blockHandler(@PathVariable  Long id,BlockException blockException) {
    27.         Payment payment = new Payment(id,"null");
    28.         return new CommonResult<>(445,"blockHandler-sentinel限流,无此流水: blockException  "+blockException.getMessage(),payment);
    29.     }
    30.  
    31. }

     

     

    测试 6

     访问http://localhost:84/consumer/fallback/4

    再访问的时候，那就意味着这个时候会被限流处理 

    若 blockHandler 和 fallback 都进行了配置，则被限流降级而抛出 BlockException 时只会进入 blockHandler 处理逻辑。 

      修改业务类（忽略属性.......） 

    1. @RestController
    2. @Slf4j
    3. public class CircleBreakerController
    4. {
    5.     public static final String SERVICE_URL = "http://nacos-payment-provider";
    6.  
    7.     @Resource
    8.     private RestTemplate restTemplate;
    9.  
    10.     @RequestMapping("/consumer/fallback/{id}")
    11.     @SentinelResource(value = "fallback", fallback = "handlerFallback", blockHandler = "blockHandler",
    12.             exceptionsToIgnore = {IllegalArgumentException.class})
    13.     public CommonResult fallback(@PathVariable Long id)
    14.     {
    15.         CommonResult result = restTemplate.getForObject(SERVICE_URL + "/paymentSQL/"+id,CommonResult.class,id);
    16.         if (id == 4) {
    17.             throw new IllegalArgumentException ("非法参数异常....");
    18.         }else if (result.getData() == null) {
    19.             throw new NullPointerException ("NullPointerException,该ID没有对应记录");
    20.         }
    21.         return result;
    22.     }
    23.     public CommonResult handlerFallback(@PathVariable  Long id,Throwable e) {
    24.         Payment payment = new Payment(id,"null");
    25.         return new CommonResult<>(444,"fallback,无此流水,exception  "+e.getMessage(),payment);
    26.     }
    27.     public CommonResult blockHandler(@PathVariable  Long id,BlockException blockException) {
    28.         Payment payment = new Payment(id,"null");
    29.         return new CommonResult<>(445,"blockHandler-sentinel限流,无此流水: blockException  "+blockException.getMessage(),payment);
    30.     }
    31. }

     

    测试7 

    访问http://localhost:84/consumer/fallback/4

     

  • 相关阅读:
    使用IDEA画结构图
    Promise梳理
    Vue3 SFC 和 TSX 方式自定义组件实现 v-model
    Git--原理与使用
    uniapp IOS上架AppStore因打开相机、相册提示不明确被拒
    亚马逊国际按关键字搜索商品 API 返回值说明
    Swagger2的配置
    通过cpolar实现外网ssh远程连接linux
    Fedora文件历史记录怎么开启? Fedora历史记录的显示方法
    可编程直流电源的特点都有哪些呢?
  • 原文地址：https://blog.csdn.net/m0_62436868/article/details/126460737