本篇文章为大家展示了SpringCloud中如何使用Hystrix熔断器，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。
创新互联公司，专注为中小企业提供官网建设、营销型网站制作、成都响应式网站建设公司、展示型成都网站设计、成都网站制作、外贸网站建设等服务，帮助中小企业通过网站体现价值、有效益。帮助企业快速建站、解决网站建设与网站营销推广问题。
一、简介
什么是Hystrix
单词本身意思就是断路器，发音 [hɪst'rɪks] ，怎么读听这里 https://www.koolearn.com/dict/wd_73657.html
Hystrix是NetFlix公司开源的项目，提供了熔断器的功能,能够阻止分布式系统中出现的联动故障。
Hystrix通过隔离服务的访问点阻止联动故障，并且提供故障解决方案，提高了分布式系统的弹性和容错。
Hystrix所解决的问题
防止服务故障导致资源耗尽。
通过熔断机制，可以防止单个服务故障导致影响整个Servlet容器的线程资源。
避免过长等待。
快速失败机制，如果某个服务故障，则接下来该服务不会处理请求，快速的返回失败。
增加服务弹性。
提供监控。
提供熔断器的监控组件 Hystrix Dashboard，可以实时监控断路器的状态。
二、简单使用
无论是Ribbon使用还是Feign使用，都需要前面两步
pom.xml中增加依赖
org.springframework.cloud
spring-cloud-starter-hystrix
启动类增加注解表示开启熔断器功能
@SpringBootApplication
@EnableEurekaClient
@EnableHystrix
public class ServerApplication {
private static final Logger logger = LoggerFactory.getLogger(ServerApplication.class);
public static void main(String[] args) {
SpringApplication.run(ServerApplication.class,args);
logger.info("hystrix server start up finished !");
}
}Ribbon搭配使用
@Autowired
private RestTemplate restTemplate;
/**
* 每个需要熔断的远程方法上，增加注解，定义回调
* @HystrixCommand定义服务降级，这里的fallbackMethod服务调用失败后调用的方法。
* @return
*/
@HystrixCommand(fallbackMethod = "hiError")
public String getHi(){
return restTemplate.getForObject("http://hystrix-service/hi", String.class);
}
/**
* fallbackMethod指向此方法，表示远程调用失败后，快速的使用此方法替代
*/
public String hiError(){
return "error";
}Fiegn搭配使用
在远程服务的FeignClient的注解上增加回调，定义回调类
@FeignClient(value = "common-service",
configuration = FeignConfiguration.class,
fallback = RemoteCommonServiceCallback.class)
public interface RemoteCommonServiceClient {
/**
* 调用远程方法
* @return
*/
@GetMapping(value = "/hello")
String remoteCommonServiceHello();
}实现FeignClient中定义的回调类
/**
*
* @Component注册为一个组件，实现RemoteCommonServiceClient，重写方法定义回调
*
* @author Calvin
* @date 2019/10/24
* @since 1.0
*/
@Component
public class RemoteCommonServiceCallback implements RemoteCommonServiceClient {
@Override
public String remoteCommonServiceHello() {
return "something error， this is callback";
}
}
application.yml中开启Feign对Hystrix的支持
feign:
hystrix:
enabled: true
具体测试，可以通过停掉需要被调用的远程服务来测试，或者自己制造一些，服务在某段时间不可用，使线程睡眠等操作
三、监控
Hystrix Dashboard
增加依赖
org.springframework.boot
spring-boot-starter-actuator
org.springframework.cloud
spring-cloud-starter-hystrix-dashboard
启动类增加注解开启dashboard
/**
*
* 启动类，集合了服务注册、FeignClient声明式调用、开启熔断器、开启熔断器监控
*
*
* @author Calvin
* @date 2019/10/24
* @since 1.0
*/
@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients
@EnableHystrix
@EnableHystrixDashboard
public class HystrixServerApplication {
private static final Logger logger = LoggerFactory.getLogger(HystrixServerApplication.class);
public static void main(String[] args) {
SpringApplication.run(HystrixServerApplication.class,args);
logger.info("hystrix server start up finished !");
}
}
监控页面观察
Turbine聚合监控
新建服务turbine-monitor
pom.xml
hystrix-test
com.calvin.hystrix
1.0-SNAPSHOT
4.0.0
turbine-monitor
org.springframework.cloud
spring-cloud-starter-turbine
org.springframework.cloud
spring-cloud-starter-hystrix
org.springframework.cloud
spring-cloud-starter-hystrix-dashboard
org.springframework.boot
spring-boot-starter-actuator
org.springframework.boot
spring-boot-maven-plugin
TurbineMonitorApplication
/**
*
* 启动类
*
*
* @author Calvin
* @date 2019/10/24
* @since
*/
@SpringBootApplication
@EnableTurbine
@EnableHystrix
@EnableHystrixDashboard
public class MonitorApplication {
public static void main(String[] args) {
SpringApplication.run(MonitorApplication.class,args);
}
}
application.yml
spring:
application:
name: turbine-monitor
server:
port: 8040
eureka:
client:
service-url:
defaultZone: http://localhost:8010/eureka/
turbine:
# 需要监控的服务名
app-config: common-service, hystrix-service
# 服务名的集群
cluster-name-expression: new String("default")启动服务
调用远程服务
上述内容就是SpringCloud中如何使用Hystrix熔断器，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注创新互联行业资讯频道。
当前标题：SpringCloud中如何使用Hystrix熔断器
转载来于：
http://www.cdkjz.cn/article/jdjehg.html
