Hystrix 豪猪哥

服务雪崩

多个微服务之间调用的时候，假设微服务A调用微服务B和微服务C，微服务B和C又调用其它微服务，这就是“扇出”。如果扇出的链路上某个微服务的调用响应时间过长或者不可用，对微服务A的调用就会占用越来越多的系统资源，进而引起系统崩溃，即为雪崩效应。

Hystrix

Hystrix是一个用于处理分布式系统的延迟和容错的开源库，在分布式系统里面，许多依赖不可避免的会调用失败，比如超时，异常等，Hystrix能够保证在一个依赖出问题的情况下，不会导致整体服务失败，避免级联故障，以提高分布式的弹性。

断路器，本身是一个开关装置，当某个服务单元发生故障后，通过断路器的故障监控（类似熔断保险丝），向调用方返回一个符合预期的，可处理的备选响应（FallBack），而不是长时间等待或者抛出异常，这样就保证了服务调用方的线程不被长时间，不必要地占用，从而避免了故障在分布式系统中的蔓延，乃至雪崩。

作用：

服务降级
服务器忙，请稍后再试，客户端一个友好提示（异常，超时等）
服务熔断
类比保险丝，达到最大服务访问后，直接拒绝访问，拉闸限电。然后调用服务降级的方法并返回友好提示
过程===》
服务的降级---->进而熔断----->恢复调用的链路。
接近实时的监控
服务限流等
秒杀高并发等操作，严禁一窝蜂的过来拥挤，大家排队，一秒钟N个，有序进行。

编码模拟

创建cloud-provider-hystrix-paymant8001模块
导依赖

 <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-eureka-client</artifactId></dependency><dependency><groupId>org.example</groupId><artifactId>cloud-api-commons</artifactId><version>${project.version}</version></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.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.1.10</version></dependency><!--mysql-connector-java--><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><!--jdbc--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-jdbc</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId><scope>runtime</scope><optional>true</optional></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.11</version><scope>test</scope></dependency></dependencies>

yml

server:port: 8001spring:application:name: cloud-provider-hystrix-paymentdatasource:type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包url: jdbc:mysql://localhost:3306/db2019?useUnicode=true&characterEncoding=utf-8&useSSL=falseusername: rootpassword: *******eureka:client:register-with-eureka: truefetch-registry: trueservice-url:
#      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eurekadefaultZone: http://eureka7001.com:7001/eureka

主启动

@SpringBootApplication
@EnableEurekaClient
public class PaymentHystrixMain8001 {public static void main(String[] args) {SpringApplication.run(PaymentHystrixMain8001.class,args);}}

service

package ink.awz.springcloud.service;import org.springframework.stereotype.Service;import java.util.concurrent.TimeUnit;@Service
public class PaymentService {public String paymentInfo_OK(Integer id) {return "线程池：   "+Thread.currentThread().getName()+"paymentInfo_OK,id:  "+id+"\t"+"haha";}public String paymentInfo_TimeOut(Integer id) {try {TimeUnit.SECONDS.sleep(3);} catch (InterruptedException e) {throw new RuntimeException(e);}return "线程池：   "+Thread.currentThread().getName()+"paymentInfo_OK,id:  "+id+"\t"+"耗时3秒钟";}
}

controller

package ink.awz.springcloud.controller;import ink.awz.springcloud.service.PaymentService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;@RestController
@Slf4j
public class PaymentController {@Autowiredprivate PaymentService paymentService;@Value("${server.port}")private String serverPort;@GetMapping("/payment/hystrix/ok/{id}")public String paymentInfo_OK(@PathVariable("id") Integer id) {String result = paymentService.paymentInfo_OK(id);log.info("result"+result);return result;}@GetMapping("/payment/hystrix/timeOut/{id}")public String paymentInfo_timeOut(@PathVariable("id") Integer id) {String result = paymentService.paymentInfo_TimeOut(id);log.info("result"+result);return result;}
}

关联下一篇JMeter压力测试工具

Hystrix 豪猪哥相关推荐

SpringCloud学习记录 | 第十篇：Hystrix DashBoard 实时图像监控界面(豪猪哥)
一.Hystrix DashBoard Hystrix提供了准实时的调用监控(Hystrix Dashboard),Hystrix会持续记录所有的通过Hystrix发起的请求执行信息,并以统计报表和图 ...
微服务——Hystrix断路器（豪猪哥）
提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档文章目录概述分布式系统面临的问题是什么能干嘛 Hystrix重要概念服务降级(fallback) 哪些情况会触发降级服务熔 ...
服务熔断 hystrix（豪猪哥）
前提为何需要服务熔断没有熔断服务会导致一个服务挂掉后,另一个服务也收到影响,也挂掉,以此类推.(故障蔓延) 0.Hystrix防止故障蔓延,通过控制那些访问的远程的服务结点,提供强大的故障和延迟提 ...
Spring Cloud H （五）初战服务降级和熔断Hystrix（豪猪哥）
目录目录前言概述服务雪崩服务限流服务降级服务熔断如何理解服务降级和熔断之间的关系代码实战 Hystrix支付微服务构建订单微服务调用支付服务出现卡顿 Hystrix之服务降级支付侧 ...
SpringCloud04-Ribbon、OpenFeign、Hystrix
SpringCloud04 Ribbon负载均衡服务调用一.Ribbon 二.Ribbon的负载均衡和Rest调用 pom RestTemplate的使用三.Ribbon负载规则四.Ribbon ...
SpringCloud学习使用（三）——Hystrix
Hystrix介绍在分布式环境中,不可避免地会有许多服务依赖项中的某些失败.Hystrix是一个库,可通过添加等待时间容限和容错逻辑来帮助您控制这些分布式服务之间的交互.Hystrix通过隔离服务之 ...
[云原生]微服务架构是什么
作者简介:大家好,我是?让我们一起共同进步吧!?? ??个人主页:的csdn博客 ??系列专栏: 数据结构与算法 ??哲学语录: 承认自己的无知,乃是开启智慧的大门 ??如果觉得博主的文章还不错的话, ...
【Java学习路线之JavaWeb】Spring Cloud教程（非常详细）
文章目录读者阅读条件微服务是什么微服务,我们可以从字面上去理解,即"微小的服务",下面我们从"服务"和"微小"两个方面进行介绍. 微 ...
【Sentinel】
提示:写完文章后,目录可以自动生成,如何生成可参考右边的帮助文档文章目录一. 服务雪崩二. 断路器三. Sentinel的下载和安装 Windows下安装 docker安装四.初始化监控 1 ...

Hystrix 豪猪哥

服务雪崩

Hystrix

作用：

编码模拟

Hystrix 豪猪哥相关推荐

最新文章

热门文章