SpringCloudAlibaba：Sentinel-熔断和fegin调用

转x33g5p2x  于2021-10-03 转载在 Spring  
字(10.6k)|赞(0)|评价(0)|浏览(497)

一、环境准备

父模块依赖

  1. <properties>
  2.         <java.version>1.8</java.version>
  3.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  4.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  5.         <spring-boot.version>2.3.7.RELEASE</spring-boot.version>
  6.         <spring-cloud.version>Hoxton.SR9</spring-cloud.version>
  7.         <spring-cloud-alibaba.version>2.1.0.RELEASE</spring-cloud-alibaba.version>
  8.     </properties>
  9.     <dependencyManagement>
  10.         <dependencies>
  11.             <dependency>
  12.                 <groupId>org.springframework.boot</groupId>
  13.                 <artifactId>spring-boot-dependencies</artifactId>
  14.                 <version>${spring-boot.version}</version>
  15.                 <type>pom</type>
  16.                 <scope>import</scope>
  17.             </dependency>
  18.             <dependency>
  19.                 <groupId>org.springframework.cloud</groupId>
  20.                 <artifactId>spring-cloud-dependencies</artifactId>
  21.                 <version>${spring-cloud.version}</version>
  22.                 <type>pom</type>
  23.                 <scope>import</scope>
  24.             </dependency>
  25.             <!--spring cloud alibaba 2.1.0.RELEASE-->
  26.             <dependency>
  27.                 <groupId>com.alibaba.cloud</groupId>
  28.                 <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  29.                 <version>${spring-cloud-alibaba.version}</version>
  30.                 <type>pom</type>
  31.                 <scope>import</scope>
  32.             </dependency>
  33.         </dependencies>
  34.     </dependencyManagement>

nacos-provider

pom文件
  1. <dependencies>
  2.         <dependency>
  3.             <groupId>com.alibaba.cloud</groupId>
  4.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  5.         </dependency>
  6.         <dependency>
  7.             <groupId>org.springframework.boot</groupId>
  8.             <artifactId>spring-boot-starter-web</artifactId>
  9.         </dependency>
  10.         <dependency>
  11.             <groupId>org.springframework.boot</groupId>
  12.             <artifactId>spring-boot-starter-actuator</artifactId>
  13.         </dependency>
  14.         <dependency>
  15.             <groupId>org.springframework.boot</groupId>
  16.             <artifactId>spring-boot-starter-test</artifactId>
  17.             <scope>test</scope>
  18.         </dependency>
  19.     </dependencies>

application.yml

  1. server:
  2.   port: 8001
  4. spring:
  5.   application:
  6.     name: provider
  7.   cloud:
  8.     nacos:
  9.       discovery:
  10.         server-addr: 192.168.31.100:8848
  12. #暴露监控
  13. management:
  14.   endpoints:
  15.     web:
  16.       exposure:
  17.         include: '*'
启动类
  1. @SpringBootApplication
  2. @EnableDiscoveryClient
  3. public class NacosProviderApplication {
  5.     public static void main(String[] args) {
  6.         SpringApplication.run(NacosProviderApplication.class, args);
  7.     }
  9. }
controller
  1. @RestController
  2. @RequestMapping("/provider")
  3. public class ProviderController {
  4.     @Value("${server.port}")
  5.     private Integer port;
  6.     @GetMapping("/hello")
  7.     public String hello(){
  8.         return "Hello nacos , server port is "+port;
  9.     }
  10. }
测试

http://localhost:8001/provider/hello

nacos-provider-salve

nacos-provider-salve模块跟nacos-provider模块一样就端口不一样

http://localhost:8002/provider/hello

nacos-consumer

pom文件
  1. <dependencies>
  2.         <!--sentinel nacos-->
  3.         <dependency>
  4.             <groupId>com.alibaba.csp</groupId>
  5.             <artifactId>sentinel-datasource-nacos</artifactId>
  6.             <version>1.8.2</version>
  7.         </dependency>
  8.         <!--sentinel-->
  9.         <dependency>
  10.             <groupId>com.alibaba.cloud</groupId>
  11.             <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
  12.             <version>2.2.1.RELEASE</version>
  13.         </dependency>
  14.         <!--spring cloud alibaba-->
  15.         <dependency>
  16.             <groupId>com.alibaba.cloud</groupId>
  17.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  18.             <version>2.1.0.RELEASE</version>
  19.         </dependency>
  20.         <dependency>
  21.             <groupId>org.springframework.boot</groupId>
  22.             <artifactId>spring-boot-starter-web</artifactId>
  23.         </dependency>
  24.         <dependency>
  25.             <groupId>org.springframework.boot</groupId>
  26.             <artifactId>spring-boot-starter-actuator</artifactId>
  27.         </dependency>
  28.         <dependency>
  29.             <groupId>org.springframework.boot</groupId>
  30.             <artifactId>spring-boot-starter-test</artifactId>
  31.             <scope>test</scope>
  32.         </dependency>
  33.     </dependencies>
application.yml
  1. server:
  2.   port: 8003
  3. spring:
  4.   application:
  5.     name: customer
  6.   cloud:
  7.     nacos:
  8.       discovery:
  9.         server-addr: 192.168.31.100:8848
  10.     sentinel:
  11.       transport:
  12.         #配置sentinel地址,端口
  13.         dashboard: 192.168.31.100:8859   #这里是我linux地址
  14.         #客户端IP(sentinel dashboard进行实时监控的主机ip地址)
  15.         # 默认端口8719端口假如被占用会自动从8719开始依次+1扫描，直到找到未被占用的端口
  16.         port: 8719
  17.         client-ip: 172.100.20.220   #这里是我windows地址
controller
  1. @RestController
  2. @RequestMapping("/customer")
  3. public class CustomerController {
  4.     @Autowired
  5.     private RestTemplate restTemplate;
  7.     private final String SERVER_URL="http://provider";
  9.     @GetMapping(value = "/hello")
  10.     @SentinelResource(value = "hello")
  11.     public String hello(){
  12.         return restTemplate.getForObject(SERVER_URL+"/provider/hello", String.class);
  13.     }
  14. }
RestTemplateConfig
  1. @Configuration
  2. public class RestTemplateConfig {
  3.     @Bean
  4.     @LoadBalanced
  5.     public RestTemplate restTemplate(){
  6.         return new RestTemplate();
  7.     }
  8. }
启动类
  1. @SpringBootApplication
  2. @EnableDiscoveryClient
  3. public class NacosConsumerApplication {
  5.     public static void main(String[] args) {
  6.         SpringApplication.run(NacosConsumerApplication.class, args);
  7.     }
  9. }
测试

测试接口

http://localhost:8003/customer/hello

查看nacos

查看sentinel

二、fallback

1.修改CustomerController

  1. @RestController
  2. @RequestMapping("/customer")
  3. public class CustomerController {
  4.     @Autowired
  5.     private RestTemplate restTemplate;
  7.     private final String SERVER_URL="http://provider";
  9.     @GetMapping(value = "/hello/{id}")
  10.     @SentinelResource(value = "hello",fallback = "fallbackHandler")
  11.     public String hello(@PathVariable("id") String id){
  12.         if (id.equals("1")){
  13.             throw new RuntimeException("id不能为1");
  14.         }
  15.         return restTemplate.getForObject(SERVER_URL+"/provider/hello", String.class);
  16.     }
  18.     public String fallbackHandler(@PathVariable("id") String id ,Throwable e){
  19.         return "CustomerController invoke fallbackHandler";
  20.     }
  21. }

2.测试

http://localhost:8003/customer/hello/1

http://localhost:8003/customer/hello/2

3.注意

fallback：是进行降级处理

三、blockHandler

1.修改CustomerController

  1. @RestController
  2. @RequestMapping("/customer")
  3. public class CustomerController {
  5.     @Autowired
  6.     private RestTemplate restTemplate;
  8.     private final String SERVER_URL="http://provider";
  10.     /** * blockHandler：仅负责sentinel违规 */
  11.     @GetMapping(value = "/hello/{id}")
  12.     @SentinelResource(value = "hello",blockHandler = "helloBlockHandler")
  13.     public String hello(@PathVariable("id") String id){
  14.         if (id.equals("1")){
  15.             throw new RuntimeException("id不能为1");
  16.         }
  17.         return restTemplate.getForObject(SERVER_URL+"/provider/hello", String.class);
  18.     }
  19.     public String fallbackHandler(@PathVariable("id") String id ,Throwable e){
  20.         return "CustomerController invoke fallbackHandler";
  21.     }
  22.     public String helloBlockHandler(String id, BlockException e){
  23.         return "CustomerController invoke blockHandler";
  24.     }
  25. }

2.sentinel配置

3.测试

  1. #访问1时直接报错，java没有对应fallback处理
  2. http://localhost:8003/customer/hello/1
  3. #当频繁访问，出现限流响应
  4. http://localhost:8003/customer/hello/2

4.注意

blockHandler：仅负责sentinel违规

四、fallback、blockHandler同时配置

1.修改controller

  1. @RestController
  2. @RequestMapping("/customer")
  3. public class CustomerController {
  5.     @Autowired
  6.     private RestTemplate restTemplate;
  8.     private final String SERVER_URL="http://provider";
  10.     /** * blockHandler：仅负责sentinel违规 */
  11.     @GetMapping(value = "/hello/{id}")
  12.     @SentinelResource(value = "hello",blockHandler = "helloBlockHandler",fallback = "fallbackHandler")
  13.     public String hello(@PathVariable("id") String id){
  14.         System.out.println(id);
  15.         if (id.equals("1")){
  16.             throw new RuntimeException("id不能为1");
  17.         }
  18.         return restTemplate.getForObject(SERVER_URL+"/provider/hello", String.class);
  19.     }
  20.     public String fallbackHandler(@PathVariable("id") String id ,Throwable e){
  21.         return "CustomerController invoke fallbackHandler";
  22.     }
  23.     public String helloBlockHandler(String id,BlockException e){
  24.         return "CustomerController invoke blockHandler";
  25.     }
  26. }

2.测试

  1. #java异常fallback->fallbackHandler
  2. http://localhost:8003/customer/hello/1
  3. #限流控制->helloBlockHandler
  4. http://localhost:8003/customer/hello/2

五、OpenFegin

1.pom文件

  1. <dependencies>
  2.         <dependency>
  3.             <groupId>org.springframework.cloud</groupId>
  4.             <artifactId>spring-cloud-starter-openfeign</artifactId>
  5.         </dependency>
  6.         <!--sentinel nacos-->
  7.         <dependency>
  8.             <groupId>com.alibaba.csp</groupId>
  9.             <artifactId>sentinel-datasource-nacos</artifactId>
  10.         </dependency>
  11.         <!--sentinel-->
  12.         <dependency>
  13.             <groupId>com.alibaba.cloud</groupId>
  14.             <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
  15.         </dependency>
  16.         <!--spring cloud alibaba-->
  17.         <dependency>
  18.             <groupId>com.alibaba.cloud</groupId>
  19.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  20.         </dependency>
  21.         <dependency>
  22.             <groupId>org.springframework.boot</groupId>
  23.             <artifactId>spring-boot-starter-web</artifactId>
  24.         </dependency>
  25.         <dependency>
  26.             <groupId>org.springframework.boot</groupId>
  27.             <artifactId>spring-boot-starter-actuator</artifactId>
  28.         </dependency>
  29.         <dependency>
  30.             <groupId>org.springframework.boot</groupId>
  31.             <artifactId>spring-boot-starter-test</artifactId>
  32.         </dependency>
  33.     </dependencies>

2.application.yml

  1. server:
  2.   port: 9005
  3. spring:
  4.   application:
  5.     name: customer-fegin
  6.   cloud:
  7.     nacos:
  8.       discovery:
  9.         server-addr: 192.168.31.100:8848
  10.     sentinel:
  11.       transport:
  12.         #配置sentinel地址,端口
  13.         dashboard: 192.168.31.100:8859
  14.         port: 8719
  15.         #客户端IP
  16.         client-ip: 172.100.20.220
  17. #开启sentinel 对fegin的支持
  18. feign:
  19.   sentinel:
  20.     enabled: true

3.启动类

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

4.降级类

  1. @Service
  2. public class ProviderServiceFallback implements ProviderService {
  3.     @Override
  4.     public String hello() {
  5.         return "ProviderServiceFallback invoke hello";
  6.     }
  7. }

5.Fegin服务类

  1. @FeignClient(value = "provider",path = "/provider",fallback = ProviderServiceFallback.class)
  2. @Service
  3. public interface ProviderService {
  4.     @GetMapping("/hello")
  5.     String hello();
  6. }

6.controller

  1. @RestController
  2. @RequestMapping("/fegin")
  3. public class FeginController {
  5.     @Autowired
  6.     private ProviderService providerService;
  8.     @GetMapping("/hello")
  9.     @SentinelResource(value = "hello")
  10.     public String hello(){
  11.         return providerService.hello();
  12.     }
  13. }

7.启动主程序

  1. #报错
  2. com.alibaba.cloud.sentinel.feign.SentinelContractHolder.parseAndValidateMetadata(Ljava/lang/Class;)
  3. #解决办法，修改父pomspringcloud版本为Hoxton.SR1。- -，BUG。期待后续解决 - -！！！，修改后重启解决
  4. <spring-cloud.version>Hoxton.SR1</spring-cloud.version>

8.测试

http://localhost:9005/fegin/hello/

版权说明 : 本文为转载文章, 版权归原作者所有 版权申明

原文链接 : https://blog.csdn.net/weixin_43296313/article/details/121034803

内容来源于网络，如有侵权，请联系作者删除！

Javaspringspringcloudspring cloud

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com