本文主要是介绍springcloud+Hystrix断路器，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
springcloud+Hystrix断路器
1.Hystrix简介及相关概念
1.1简介
Hystrix是一个用于处理分布式系统的延迟和容错的开源库，在分布式系统里，许多依赖不可避免的会调用失败，比如超时、异常等;
Hystrix能够保证在一个依赖出问题的情况下，不会导致整体服务失败，避免级联故障，以提高分布式系统的弹性。
1.2相关概念
1.服务雪崩：
一个服务,依赖于另一个功能服务的,如果这个功能服务挂掉了,那么依赖的服务就不能再用了,这种级联的失败, 我们可以称之为雪崩。
2.服务降级：
当服务提供者因为某些原因响应过慢，服务提供者主动停掉一些不太重要的业务，释放服务器资源，提高响应速度。
当服务提供者因为某些原因不可用，服务消费者调用本地降级逻辑，迅速返回给客户，避免卡顿。
3.服务熔断
请求错误率达到某一阈值，熔断器全开，产生熔断（熔断期间会对所有请求采用降级处理）；
到熔断时间窗口之后，熔断器会进入半开状态，此时会放过试验性请求 ；
如果该试验性请求成功，熔断器进入关闭状态 ；
如果该试验性请求失败，熔断器重新进入全开状态 。
2.Ribbon中使用Hystrix
2.1前置工作：
1.需要搭建Eureka server，我们以一台Eureka Server为例：
https://blog.csdn.net/u013071014/article/details/111031306
2.Ribbon负载均衡
https://blog.csdn.net/u013071014/article/details/111361176
2.2改造服务消费者项目
1.在pom.xml中新增依赖
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
2.在主启动类上增加@EnableHystrix注解，开启Hystrix断路器功能
package com.springcloud;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.cloud.netflix.ribbon.RibbonClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;import com.springcloud.myRule.myRule;@SpringBootApplication
@EnableEurekaClient
@RibbonClient(name = "springcloud-consumer1", configuration = myRule.class)
@EnableHystrix
public class SpringCloudConsumerApplication {public static void main(String[] args) {// TODO Auto-generated method stubSpringApplication.run(SpringCloudConsumerApplication.class, args);}@Bean@LoadBalanced //开启负载均衡public RestTemplate restTemplate() {return new RestTemplate();}}
3.在controller中需要有熔断机制的方法上添加@HystrixCommand注解，属性fallbackMethod是发生熔断时返回的方法。
package com.springcloud.controller;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;@RestController
@RequestMapping(path = "/consumer")
public class ConsumerController {@Autowiredprivate RestTemplate restTemp;@HystrixCommand(fallbackMethod = "getDefaultResp") //发生熔断时，调用getDefaultResp方法@RequestMapping(path = "/getConsumer", method = RequestMethod.GET)public String getConsumer() {String result = restTemp.getForObject("http://springcloud-provider1/provider/getProvider", String.class);return result;}public String getDefaultResp() {return "发生熔断!!!";}
}
4.启动eureka server、provider以及consumer。
正常访问时：
此时关闭服务提供者，再次访问consumer的API
3.HystrixDashboard服务监控
在Hystrix中提供Hystrix Dashboard来进行微服务监控工作
3.1项目搭建步骤
1.在parent项目右键，New—> Maven Module，名称命名为springcloud-hystrix-dashboard
2.在pom.xml文件中引入依赖
<packaging>jar</packaging><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId></dependency>
</dependencies>
3.在需要被监控的服务的pom.xml文件中引入监控服务依赖库
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
4.在springcloud-hystrix-dashboard配置application.yml文件
server:port: 9999hystrix:dashboard:proxy-stream-allow-list: "*"# Actuator默认只启动了 health 和 info 端点,如下配置打开全部端点
management:endpoints:web:exposure:include: "*"
5.在springcloud-hystrix-dashboard添加主启动类，并使用@EnableHystrixDashboard注解
package com.springcloud;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;@SpringBootApplication
@EnableHystrixDashboard
public class HystrixDashboardApplication {public static void main(String[] args) {SpringApplication.run(HystrixDashboardApplication.class, args);}
}
6.启动springcloud-hystrix-dashboard，访问http://localhost:9999/hystrix测试
7.在需要被监控的服务的主启动类中新增如下方法
@Bean
public ServletRegistrationBean getServlet(){HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);registrationBean.setLoadOnStartup(1);registrationBean.addUrlMappings("/actuator/hystrix.stream");registrationBean.setName("HystrixMetricsStreamServlet");return registrationBean;
}
8.启动eureka server、provider、consumer和dashboard，输入需要监控的url
3.2 dashboard数据解读
4.源码地址
https://github.com/DamonLiu666/springcloud_test
5.Feign + Hystrix使用
见下一篇博客：
https://blog.csdn.net/u013071014/article/details/111627988
这篇关于springcloud+Hystrix断路器的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
