详解SpringCloud微服务架构之Hystrix断路器

更新时间：2018年01月10日 14:54:14 作者：Bob_F

本篇文章主要介绍了详解SpringCloud微服务架构之Hystrix断路器，Hystrix是一个库，通过添加延迟容差和容错逻辑来帮助您控制这些分布式服务之间的交互，有兴趣的可以了解一下

一：什么是Hystrix

在分布式环境中，许多服务依赖项中的一些将不可避免地失败。Hystrix是一个库，通过添加延迟容差和容错逻辑来帮助您控制这些分布式服务之间的交互。Hystrix通过隔离服务之间的访问点，停止其间的级联故障以及提供回退选项，从而提高系统的整体弹性。

Hystrix旨在执行以下操作

1：对通过第三方客户端库访问（通常通过网络）的依赖关系提供保护并控制延迟和故障。

2：隔离复杂分布式系统中的级联故障。

3：快速发现故障，尽快恢复。

4：回退，尽可能优雅地降级。

5：启用近实时监控，警报和操作控制。

二：为什么需要Hystrix?

大型分布式系统中，一个客户端或者服务依赖外部服务，如果一个服务宕了，那么由于我们设置了服务调用系统超时时间，势必会影响相应时间，在高并发的情况下大多数服务器的线程池就出现阻塞(BLOCK),影响整个线上服务的稳定性。

(图片官方图片)

当一切都健康时，请求可以看起来像这样

当许多后端服务系统中的一个宕掉时，整个用户请求：

如果多个客户端调用同一个异常服务的时候，出现的情况是：

三：Hystrix解决什么问题？

分布式架构中的应用程序具有几十个依赖关系，每个依赖关系在某个时刻将不可避免的出现异常。如果应用程序不与这些外部故障隔离，则可能出现线程池阻塞，引起系统雪崩。

例如，对于依赖30个服务的应用程序，每个服务的正常运行时间为99.99％，您可以：

99.99%的30次方 = 99.7％正常运行时间

0.3％的10亿次请求= 3,000,000次故障

2+小时宕机/月，即使所有依赖关系正常运行时间。

当使用Hystrix进行熔断后，每个依赖关系彼此隔离了，限制了当发生延迟时的阻塞。

四：Hystrix结合Feign使用

创建一个工程eureka_feign_hystrix_client

pom.xml文件内容

<dependencies>

    <dependency>

      <groupId>org.springframework.cloud</groupId>

      <artifactId>spring-cloud-starter-feign</artifactId>

    </dependency>

    <dependency>

      <groupId>org.springframework.cloud</groupId>

      <artifactId>spring-cloud-starter-eureka</artifactId>

    </dependency>

    <dependency>

      <groupId>org.springframework.boot</groupId>

      <artifactId>spring-boot-starter-web</artifactId>

    </dependency>

    <dependency>

      <groupId>org.springframework.boot</groupId>

      <artifactId>spring-boot-starter-actuator</artifactId>

    </dependency>

    <dependency>

      <groupId>org.springframework.boot</groupId>

      <artifactId>spring-boot-starter-test</artifactId>

      <scope>test</scope>

    </dependency>

  </dependencies>

  <dependencyManagement>

    <dependencies>

      <dependency>

        <groupId>org.springframework.cloud</groupId>

        <artifactId>spring-cloud-dependencies</artifactId>

        <version>Brixton.SR5</version>

        <type>pom</type>

        <scope>import</scope>

      </dependency>

    </dependencies>

  </dependencyManagement>

创建启动文件

FeignHystrixApplication

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class FeignHystrixApplication {
  public static void main(String[] args) {

    SpringApplication.run(FeignHystrixApplication.class, args);
  }
}

UserClient类

@FeignClient(value = "biz-service-0",fallback = UserClientHystrix.class)
public interface UserClient {
  @RequestMapping(method = RequestMethod.GET, value = "/getuser")
  public User getuserinfo();
  @RequestMapping(method = RequestMethod.GET, value = "/getuser")
  public String getuserinfostr();
  @RequestMapping(method = RequestMethod.GET, value = "/info")
  public String info();
}

创建熔断类UserClientHystrix

@Service
public class UserClientHystrix implements UserClient {

   @Override
  public User getuserinfo() {
    throw new NullPointerException(" User getuserinfo() 服务不可用。。");

  }

  @Override
  public String getuserinfostr() {
    return " UserClientHystrix getuserinfostr() is fallback 服务不可用。。";

  }

  @Override
  public String info() {
    return " UserClientHystrix info() is fallback 服务不可用。。";

  }
}

当网络出现异常的时候或直接跳转到这里实现类里面

创建action类

UserController

@Autowired
  UserClient userClient;

  @RequestMapping(value = "/getuserinfo", method = RequestMethod.GET)
  public User getuserinfo() {
    return userClient.getuserinfo();
  }

  @RequestMapping(value = "/getuserinfostr", method = RequestMethod.GET)
  public String getuserinfostr() {
    return userClient.getuserinfostr();
  }

  @RequestMapping(value = "/info", method = RequestMethod.GET)
  public String info() {
    return userClient.info();
  }

先启动：eureka_register_service（注册中心）工程

然后运行我们写好的FeignHystrixApplication

这个时候我们明显发现没有运行biz-service-0 服务，那么我们打开 http://127.0.0.1:8005/getuserinfostr

出现

UserClientHystrix getuserinfostr() is fallback 服务不可用。。

这个就是我们自定义的熔断返回结果

如果不用熔断页面会出现这个

Whitelabel Error Page

This application has no explicit mapping for /error, so you are seeing this as a fallback.

Wed Mar 22 14:32:21 CST 2017

There was an unexpected error (type=Internal Server Error, status=500).

getuserinfo failed and fallback failed.

代码地址：https://github.com/zhp8341/SpringCloudDemo

本人也看了一些Hystrix相关原理，由于没有全部看完所以暂时没有写上去，本文是结合Feign使用和学习。

有兴起的可以看下官方的Hystrix很详细，就是看起来有点费劲，

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

Java -jar参数设置小结
本文主要介绍了Java -jar参数设置小结，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2023-06-06
java mybatis如何操作postgresql array数组类型
这篇文章主要介绍了java mybatis如何操作postgresql array数组类型，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-01-01
使用mybatis-plus分页出现两个Limit的问题解决
在使用MyBatis-Plus进行分页查询时,可能会遇到查询SQL中出现两个limit语句的问题,这通常是由于在多个模块中重复引入了MyBatis-Plus的分页插件所导致的,下面就来介绍一下如何解决,感兴趣的可以了解一下
2024-10-10
Java中实现多重排序的几种方法小结
Java中的多重排序通常指的是同时对一个集合中的两个或更多列或多维度的数据进行排序,这通常通过自定义Comparator实现,可以结合Arrays.sort()或Collections.sort()方法,当需要进行多重排序时,即根据多个字段进行排序,我们可以采用以下几种方法
2024-10-10
SpringBoot3整合SpringCloud启动后nacos报错获取不到配置、无法注册服务的解决方案
文章介绍了如何使用Spring Boot 3.3.4和Spring Cloud 2023.0.3搭建微服务项目,并解决与Nacos服务注册发现和配置中心的集成问题,主要解决了依赖版本不兼容、配置文件导入问题及服务注册失败等问题,感兴趣的朋友跟随小编一起看看吧
2025-02-02
Java如何优雅地关闭资源try-with-resource及其异常抑制
这篇文章主要介绍了Java如何优雅地关闭资源try-with-resource及其异常抑制，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2019-02-02
Java之Scanner.nextLine()读取回车的问题及解决
这篇文章主要介绍了Java之Scanner.nextLine()读取回车的问题及解决，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2023-04-04
Java中getParameterTypes()方法的使用与原理分析
本文详细介绍了Java中getParameterTypes()方法的使用方式、工作原理及其在实际开发中的应用,该方法用于获取方法的参数类型列表,并通过反射机制在运行时动态地获取这些信息,感兴趣的朋友跟随小编一起看看吧
2025-01-01
java多线程从入门到精通看这篇就够了
熟悉 Java 多线程编程的同学都知道，当我们线程创建过多时，容易引发内存溢出，因此我们就有必要使用线程池的技术了，今天通过本文给大家分享java多线程从入门到精通的相关知识，一起看看吧
2021-06-06
Java小程序赛马游戏实现过程详解
这篇文章主要介绍了Java小程序赛马游戏实现过程详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-03-03

详解SpringCloud微服务架构之Hystrix断路器

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具