Hystrix服务降级，feign解决服务雪崩系列问题（二）

爱被打了一巴掌 2023-03-14 08:09 11阅读 0赞

### 为什么要服务降级？什么是服务降级？ ###

##### 比如服务有A,B,C,D四个服务，比如说我们的A服务，遇到访问洪流，资源利用过大，然而B,C,D服务访问量过少，那么我们就关闭BCD服务，释放资源提供给A服务。 #####

##### 当我们关闭服务BCD，客户端再访问的时候，那么可能就会出现网页404的错误。这时候给用户带来了不好的使用，那我们网页应该显示我们关闭了此服务，而不是返回给用户一个404. #####

### 服务降级，feign负在均衡，感觉就 1.导入pom依赖 2.写配置文件 3.开启服务注解。 ###

//feign依赖
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-feign</artifactId>
        <version>1.4.6.RELEASE</version>
    </dependency>

##### feign是社区版，面向接口编程，所以我们创建一个service接口，接口代码如下 #####

@FeignClient(value = "SPRINGCLOUD-PROVIDER-DEPT-8001")
    public interface DeptClientService { 
    
        @GetMapping("/dept/get/{id}")
        public Dept queryById(@PathVariable("id") long id);
        @GetMapping("/start")
        List<Dept> queryAll();
        @GetMapping("/dept/add")
        Dept addDept(Dept dept);
    
    }

##### 注解@FeignClient(value = “SPRINGCLOUD-PROVIDER-DEPT-8001”)，中的value就是绑定eureka监控中心的服务id，类似于ribbonrestTemplate.getForObject(url) #####

### 2.写一个服务消费者的module–>springcloud-consumer-dept-feign-80 ###

#### (1)pom ####

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-eureka</artifactId>
        <version>1.4.6.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-feign</artifactId>
        <version>1.4.6.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>com.wang</groupId>
        <artifactId>springcloud-api</artifactId>
        <version>1.0-SNAPSHOT</version>
    </dependency>

#### (2)application.yml ####

server:
      port: 80
    
    
    eureka:
      client:
        register-with-eureka: false
        service-url:
          defaultZone: http://eureka7001.com:7001/eureka/

#### (3) config,负载均衡 ####

@Configuration
    public class RestTemplatePro { 
    
        @Bean
        //基于客户端实现负载均衡
        @LoadBalanced
        public RestTemplate getRestTemplate(){ 
            return new RestTemplate();
        }
    }

#### （4）controller ####

@RestController
    public class DeptConsumerController { 
    
        //消费者不应该有service层
        //RestTemplate 供我们直接调用
    
    
        @Autowired
        private DeptClientService service = null;
    
        @RequestMapping("/consumer/dept/get/{id}")
        public Dept get(@PathVariable("id") long id){ 
            return service.queryById(id);
        }
        @RequestMapping("/consumer/dept/add")
        public Dept add(Dept dept){ 
            return service.addDept(dept);
        }
        @RequestMapping("/consumer/dept/list")
        public List<Dept> list(){ 
            return this.service.queryAll();
        }
    
    }

##### 开启服务注解 #####

@SpringBootApplication
    @EnableEurekaClient
    //feign核心注解
    @EnableFeignClients(basePackages = { "com.wang.springcloud"})//扫面包
    
    public class FeignConsumer_80 { 
        public static void main(String[] args) { 
            SpringApplication.run(FeignConsumer_80.class,args);
        }
    }

##### 以上就实现了feign实现基于客户端实现负载均衡 #####

#### 接下来我们实现服务降级操作 ####

##### 1，在service层，我们要写一个回调工程 #####

@Component
    public class DeptClientServiceFallbackFactory implements FallbackFactory { 
        @Override
        public DeptClientService create(Throwable throwable) { 
            return new DeptClientService() { 
                @Override
                public Dept queryById(long id) { 
                    return new Dept()
                            .setDeptno(id)
                            .setDname(id+"没有对应的客户信息")
                            .setDb_source("欸有数据，这个服务已经关闭");
                }
    
                @Override
                public List<Dept> queryAll() { 
                    return null;
                }
    
                @Override
                public Dept addDept(Dept dept) { 
                    return null;
                }
            };
        }
    }

#### 接下来我们的service接口就可以使用这个工程 ####

@FeignClient(value = "SPRINGCLOUD-PROVIDER-DEPT-8001"
    ,fallbackFactory = DeptClientServiceFallbackFactory.class)
    public interface DeptClientService { 
    
        @GetMapping("/dept/get/{id}")
        public Dept queryById(@PathVariable("id") long id);
        @GetMapping("/start")
        List<Dept> queryAll();
        @GetMapping("/dept/add")
        Dept addDept(Dept dept);
    
    }

#### fallbackFactory = DeptClientServiceFallbackFactory.class)这个就可以调用到我么的工厂类，当我们的服务停止工作 ####

#### 项目结构图： ####

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

#### 结果图 ####

##### 正常访问： #####

![在这里插入图片描述][20200516185352904.png]

##### 关闭服务提供者，就是上边说的关闭服务BCD，不能给用户返回404，而是告知用户我们关闭服务的相关消息 #####

![在这里插入图片描述][20200516185457872.png]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3BfeGlhb3hpYW8_size_16_color_FFFFFF_t_70]: /images/20230312/94df58c3c0fd473c85d9d55f0409be83.png
[20200516185352904.png]: /images/20230312/4be1707a7c144edcb4fd22346dd866f8.png
[20200516185457872.png]: /images/20230312/4194a54a5cb64b0eb4ac2188b05b2bcb.png