Java springboot B2B2C o2o多用户商城 springcloud架构(四)断路器(Hystrix)
发布日期:2021-08-30 16:01:54 浏览次数:3 分类:技术文章

本文共 2215 字,大约阅读时间需要 7 分钟。

在微服务架构中,根据业务来拆分成一个个的服务,服务与服务之间可以相互调用(RPC),在Spring Cloud可以用RestTemplate+Ribbon和Feign来调用。为了保证其高可用,单个服务通常会集群部署。由于网络原因或者自身的原因,服务并不能保证100%可用,如果单个服务出现问题,调用这个服务就会出现线程阻塞,此时若有大量的请求涌入,Servlet容器的线程资源会被消耗完毕,导致服务瘫痪。服务与服务之间的依赖性,故障会传播,会对整个微服务系统造成灾难性的严重后果,这就是服务故障的“雪崩”效应。

为了解决这个问题,业界提出了断路器模型。

一、断路器简介

Netflix has created a library called Hystrix that implements the circuit breaker pattern. In a microservice architecture it is common to have multiple layers of service calls.

. —-摘自官网

Netflix开源了Hystrix组件,实现了断路器模式,SpringCloud对这一组件进行了整合。 在微服务架构中,一个请求需要调用多个服务是非常常见的,如下图:

较底层的服务如果出现故障,会导致连锁故障。当对特定的服务的调用的不可用达到一个阀值(Hystric 是5秒20次) 断路器将会被打开。

断路打开后,可用避免连锁故障,fallback方法可以直接返回一个固定值。

二、准备工作

这篇文章基于上一篇文章的工程,首先启动上一篇文章的工程,启动eureka-server 工程;启动service-hi工程,它的端口为8762。

三、在ribbon使用断路器

改造serice-ribbon 工程的代码,首先在pox.xml文件中加入spring-cloud-starter-hystrix的起步依赖:

1
2
3
4
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>

  在程序的启动类ServiceRibbonApplication 加@EnableHystrix注解开启Hystrix:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
@SpringBootApplication
@EnableDiscoveryClient
@EnableHystrix
public class ServiceRibbonApplication {
public static void main(String[] args) {
SpringApplication.run(ServiceRibbonApplication. class , args);
}
@Bean
@LoadBalanced
RestTemplate restTemplate() {
return new RestTemplate();
}
}

  改造HelloService类,在hiService方法上加上@HystrixCommand注解。该注解对该方法创建了熔断器的功能,并指定了fallbackMethod熔断方法,熔断方法直接返回了一个字符串,字符串为”hi,”+name+”,sorry,error!”,代码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
@Service
public class HelloService {
@Autowired
RestTemplate restTemplate;
@HystrixCommand (fallbackMethod = "hiError" )
public String hiService(String name) {
return restTemplate.getForObject( "http://SERVICE-HI/hi?name=" +name,String. class );
}
public String hiError(String name) {
return "hi," +name+ ",sorry,error!" ;
}
}

  启动:service-ribbon 工程,当我们访问,浏览器显示:

1
hi forezp,i am from port: 8762

  此时关闭 service-hi 工程,当我们再访问,浏览器会显示:

1
hi ,forezp,orry,error!

  这就说明当 service-hi 工程不可用的时候,service-ribbon调用 service-hi的API接口时,会执行快速失败,直接返回一组字符串,而不是等待响应超时,这很好的控制了容器的线程阻塞。

架构代码如下:

需要JAVASpring Cloud大型企业分布式微服务云构建的B2B2C电子商务平台源码请加企鹅求求:一零三八七七四六二六

转载于:https://juejin.im/post/5ca47cd2f265da30b34096c6

转载地址:https://blog.csdn.net/weixin_34038652/article/details/91484605 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!

上一篇:一条SQL完成跨数据库实例Join查询
下一篇:java版 b2b2c o2o电子商务云商平台spring cloud+springmvc+mybatis

发表评论

最新留言

感谢大佬
[***.172.111.71]2022年05月22日 09时56分50秒

关于作者

    喝酒易醉,品茶养心,人生如梦,品茶悟道,何以解忧?唯有杜康!
-- 愿君每日到此一游!

最新文章