Spring Cloud 实战 (五) 服务异常处理 Hystrix

妖狐艹你老母 2022-02-02 23:49 226阅读 0赞

SpringCloud 集成了 Netflix 开源的 Hystrix 组件，该组件实现了熔断器模型，它使得我们很方便地实现熔断器。  
在实际项目中，一个请求调用多个服务是比较常见的，如果较底层的服务发生故障将会发生连锁反应。这对于一个大型项目是灾难性的。因此，我们需要利用 Hystrix 组件，当特定的服务不可用达到一个阈值（Hystrix 默认 5 秒 20 次），将打开熔断器，即可避免发生连锁反应。  
这篇在[Spring Cloud (四) 服务消费者 feign][Spring Cloud _ _ feign]的基础上进行  
OpenFeign 是默认自带熔断器的，但是默认关闭的，我们可以在 application.yml 中开启它：

feign:
      hystrix:
        enabled: true #开启熔断器

新建一个类 ApiServiceError.java 并实现 ApiService：

import org.springframework.stereotype.Component;
    
    /** 
    * @author  作者 : 小布
    * @version 创建时间 : 2019年5月8日 上午10:53:23 
    * @explain 类说明 : 
    */
    @Component
    public class ApiServiceError implements ApiService {
    
        @Override
        public String index() {
            return "服务发生故障！";
        }
        
    }

然后在 ApiService 的注解中指定 fallback：

import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    
    /** 
    * @author  作者 : 小布
    * @version 创建时间 : 2019年5月8日 上午10:33:10 
    * @explain 类说明 : 
    */
    @FeignClient(value = "SpringCloud-client-A",fallback = ApiServiceError.class)
    public interface ApiService {
    
        @RequestMapping(value = "/hello/index",method = RequestMethod.GET)
        String index();
        
    }

创建 Controller 类：

import java.util.HashMap;
    import java.util.Map;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import com.springcloud.service.ApiService;
    
    /** 
    * @author  作者 : 小布
    * @version 创建时间 : 2019年5月8日 上午10:44:19 
    * @explain 类说明 : 
    */
    @RestController
    @RequestMapping("/hello")
    public class TestController {
    
    	@Autowired
        private ApiService apiService;
    	
    	@RequestMapping("/index")
        public Map<String, Object> index(){
    		Map<String, Object> mp = new HashMap<String, Object>();
    		mp.put("a", apiService.index());
    		mp.put("b", apiService.index());
    		mp.put("c", apiService.index());
    		mp.put("d", apiService.index());
    		mp.put("e", apiService.index());
    		return mp;
        }
    	
    }

然后开启多个 SpringCloud-client-A ：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjExODI4NA_size_16_color_FFFFFF_t_70]  
访问路径：[http://localhost:8088/hello/index][http_localhost_8088_hello_index]  
效果图：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjExODI4NA_size_16_color_FFFFFF_t_70 1]  
当我们停止 SpringCloud-client-A 时 ：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjExODI4NA_size_16_color_FFFFFF_t_70 2]  
Hystrix 给我们提供了一个强大的功能，那就是 Dashboard。Dashboard 是一个 Web 界面，它可以让我们监控 Hystrix Command 的响应时间、请求成功率等数据。  
在 SpringCloud-feign 的 Maven 添加 以下：

<dependency>
    		    <groupId>org.springframework.cloud</groupId>
    		    <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
    		</dependency>

修改 SpringCloud-feign 启动类：

import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.web.servlet.ServletRegistrationBean;
    import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
    import org.springframework.cloud.openfeign.EnableFeignClients;
    import org.springframework.context.annotation.Bean;
    
    import com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet;
    
    @SpringBootApplication
    @EnableFeignClients
    @EnableHystrixDashboard
    public class SpringCloudFeignApplication {
    
    	public static void main(String[] args) {
    		SpringApplication.run(SpringCloudFeignApplication.class, args);
    		System.out.println("启动feign");
    	}
    
    	@Bean
        public ServletRegistrationBean getServlet(){
            HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();
            ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet );
            registrationBean.setLoadOnStartup(1);
            registrationBean.addUrlMappings("/hystrix.stream");
         registrationBean.setName("HystrixMetricsStreamServlet");
            return registrationBean;
        }
    	
    }

访问 [http://localhost:8088/hystrix][http_localhost_8088_hystrix]  
效果图：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjExODI4NA_size_16_color_FFFFFF_t_70 3]  
[上一篇 Spring Cloud 实战 (四) 服务消费者 feign][Spring Cloud _ _ feign]

[下一篇 Spring Cloud 实战 (六) 链路追踪 zipkin][Spring Cloud _ _ _ zipkin]

[git源码地址][git]

[Spring Cloud _ _ feign]: https://blog.csdn.net/weixin_42118284/article/details/89949917
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjExODI4NA_size_16_color_FFFFFF_t_70]: /images/20220203/88d2cb45c9744f898d91db8166b8a488.png
[http_localhost_8088_hello_index]: http://localhost:8088/hello/index
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjExODI4NA_size_16_color_FFFFFF_t_70 1]: /images/20220203/37766fe922944978a1615fa6b71853fb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjExODI4NA_size_16_color_FFFFFF_t_70 2]: /images/20220203/3259f94940e7408bad96fca4c3cd34e9.png
[http_localhost_8088_hystrix]: http://localhost:8088/hystrix
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjExODI4NA_size_16_color_FFFFFF_t_70 3]: /images/20220203/f45e6c3a99434b06b8cdae860e779985.png
[Spring Cloud _ _ _ zipkin]: https://blog.csdn.net/weixin_42118284/article/details/89950958
[git]: https://github.com/mars0520/Spring-Cloud