SpringCloud 学习（四）Hystrix

news2024/12/23 17:18:22

6. Netflix.Hystrix

6.1 简介

● 扇出

多服务之间调用，若微服务 A 调用微服务 B 和微服务 C，微服务 B 和 微服务 C 又调用其他微服务，这就是扇出

● 服务雪崩

若扇出的链路上某个微服务的调用响应时间过长或者不可用，么此扇出链路的调用就会占用越来越多的系统资源，进而引起系统崩溃，这就是雪崩效应

● 断路器

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

● 服务降级

服务降级一般是指在服务器压力剧增的时候，根据实际业务使用情况以及流量，对一些服务和页面有策略的不处理或者用一种简单的方式进行处理，从而释放服务器资源的资源以保证核心业务的正常高效运行。

● 服务熔断

服务熔断是应对系统服务雪崩的一种保险措施，是一种特殊降级措施。

服务熔断是服务降级的一种特殊情况，他是防止服务雪崩而采取的措施。 系统发生异常或者延迟或者流量太大，都会触发该服务的服务熔断措施，链路熔断，返回兜底方法。 这是对局部的一种保险措施。在 SpringCloud 框架中，熔断机制通常使用 Hystrix 实现。

● 什么是 Hystrix

Hystrix 是一个用于处理分布式系统的延迟和容错的开源库，能保证某个依赖出问题的情况下，不使整体服务失败，避免级联故障，提高分布式系统的弹性。

官方文档：Home · Netflix/Hystrix Wiki (github.com)

翻译文档：Hystrix 使用手册 | 官方文档翻译 - 闪客sun - 博客园 (cnblogs.com)

● Hystrix 能干什么

  • 服务降级

  • 服务熔断

    Hystrix 监控微服务间的调用状况，当失败的调用到一定阈值，缺省为5秒内20次调用失败就会启动熔断机制，熔断机制的注解是 @HystrixCommand

  • 服务限流

  • 接近实时的监控

    …

6.2 实现服务熔断

调整 springcloud-provider-dept-8001 服务

● 新建 maven module

将 springcloud-provider-dept-8001 服务复制到本服务，修改相关配置

在这里插入图片描述

● 添加依赖

<!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-hystrix -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-hystrix</artifactId>
    <version>1.4.6.RELEASE</version>
</dependency>

● 修改控制层

@RestController
public class DeptController {

    @Autowired
    private DeptService deptService;

    @GetMapping("/dept/getDept/{id}")
    // 此函数执行失败后指定跳转函数
    @HystrixCommand(fallbackMethod = "hystrixGetDept")
    public Dept getDept(@PathVariable("id") Long id) {
        Dept dept = deptService.queryById(id);
        if (dept == null) throw new RuntimeException("id = " + id + " => 用户不存在");
        return dept;
    }

    /**
     * 备选方法
     * @param id 用户编号
     * @return 返回 Dept 对象，其 dname 为提示信息
     */
    public Dept hystrixGetDept(@PathVariable("id") Long id) {
        return new Dept()
                .setDeptno(id)
                .setDname("@hystrix id = " + id + " => 用户不存在")
                .setDb_source("no this data in database");
    }

}

● 开启熔断支持

// 服务启动后注册到 eureka 注册中心
@EnableEurekaClient
// 服务发现
@EnableDiscoveryClient
// 熔断支持
@EnableCircuitBreaker
@SpringBootApplication
public class HystrixDeptProvider_8001 {
    public static void main(String[] args) {
        SpringApplication.run(HystrixDeptProvider_8001.class, args);
    }
}

在这里插入图片描述

查询数据库内不存在的数据

在这里插入图片描述

6.3 实现服务降级

● 创建后备工厂

在公共服务 springcloud-api 中定义后备工厂，即服务无法调用或调用失败后的备用方法

在这里插入图片描述

package com.why.springcloud.service;

import com.why.springcloud.pojo.Dept;
import feign.hystrix.FallbackFactory;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * 服务降级
 *
 * @author why
 * @since 2021/9/9 20:56
 */
@Component
public class DeptClientFallbackFactory implements FallbackFactory {
    @Override
    public DeptClientService create(Throwable throwable) {
        return new DeptClientService() {
            @Override
            public Dept queryById(Long id) {
                return new Dept()
                        .setDeptno(id)
                        .setDname("@hystrix id = " + id + " => 此服务已关闭")
                        .setDb_source("this service has stopped");
            }

            @Override
            public List<Dept> queryAll() {
                return null;
            }

            @Override
            public boolean addDept(Dept dept) {
                return false;
            }
        };
    }
}

● Feign 绑定后备工厂

在这里插入图片描述

@FeignClient(value = "SPRINGCLOUD-PROVIDER-DEPT", fallbackFactory = DeptClientFallbackFactory.class)

● 消费端开启 feign.hytrix

在这里插入图片描述

# feign.hystrix
feign:
  hystrix:
    enabled: true

在这里插入图片描述

关闭服务，再次访问

在这里插入图片描述

6.4 实现服务监控

(1) 新建 dashboard 服务模块

在这里插入图片描述

(2) 导入依赖

<!--实体类 + web-->
<dependencies>

    <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-hystrix -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-hystrix</artifactId>
        <version>1.4.6.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
        <version>1.4.6.RELEASE</version>
    </dependency>

    <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-ribbon -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-ribbon</artifactId>
        <version>1.4.6.RELEASE</version>
    </dependency>

    <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-eureka -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-eureka</artifactId>
        <version>1.4.6.RELEASE</version>
    </dependency>


    <dependency>
        <groupId>org.example</groupId>
        <artifactId>springcloud-api</artifactId>
        <version>1.0-SNAPSHOT</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-devtools</artifactId>
    </dependency>
</dependencies>

(3) 应用配置文件

server:
  port: 9001

# 避免 Cannot execute request on any known server 异常
eureka:
  client:
    # 是否将自己注册到 Eureka-Server 中，默认为 true
    # registerWithEureka等同于register_with_eureka
    register-with-eureka: false
    # 是否需要拉取服务信息，默认为 true
    # fetchRegistry等同于 fetch-registry
    fetch-registry: false

(4) 启动类开启监控

@SpringBootApplication
// 开启监控页面
@EnableHystrixDashboard
public class DeptConsumerDashboard_9001 {
    public static void main(String[] args) {
        SpringApplication.run(DeptConsumerDashboard_9001.class, args);
    }
}

(5) 访问监控页面

localhost:9001/hystrix

在这里插入图片描述

(5) 服务端添加 servlet

springcloud-provider-dept-hystrix-8001

// HystrixDeptProvider_8001.java
@Bean
public ServletRegistrationBean<HystrixMetricsStreamServlet> hystrixMetricsStreamServlet() {
    ServletRegistrationBean<HystrixMetricsStreamServlet> registrationBean = new ServletRegistrationBean<>(new HystrixMetricsStreamServlet());
    registrationBean.addUrlMappings("/actuator/hystrix.stream");
    return registrationBean;
}

(6) 访问监控页面

启动 springcloud-consumer-hystrix-dashboard

启动 springcloud-provider-dept-hystrix-8001

启动 springcloud-eureka-7001

向服务 springcloud-provider-dept-hystrix-8001 发送一个 get 请求

在这里插入图片描述

查看服务 springcloud-provider-dept-hystrix-8001 的流情况

在这里插入图片描述

填写监控页面信息

在这里插入图片描述

在这里插入图片描述

  • 实心圆
    • 颜色表示实例的健康状况， 绿色<黄色<橙色<红色
    • 面积表示实例的请求流量，面积越大，流量越大
  • 实线
    • 记录两分钟内流量的相对变化

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1041698.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

ESP32在CAN(TWAI)波特率不同时收发数据，导致总线错误无法恢复

ESP32在CAN(TWAI)波特率不同时收发数据，导致总线错误无法恢复

问题描述&#xff1a; 总线上有两个设备&#xff0c;主机&#xff1a;100ms周期发送数据。从机&#xff1a;以不同波特率发送数据&#xff0c;再把从机波特率调节至主机波特率一致无法通信。 环境&#xff1a;VSCODE IDF-v5.0 问题分析&#xff1a; 我们先看下ESP32技术参…
阅读更多...
Spring 学习（四）注解实现自动装配及注解开发

Spring 学习（四）注解实现自动装配及注解开发

1. 注解实现自动装配 JDK 1.5 开始支持注解&#xff0c;Spring 2.5 开始支持注解。 使用须知 导入约束 配置注解的支持&#xff08; <context:annotation-config/> &#xff09; <?xml version"1.0" encoding"UTF-8"?> <beans xmlns&qu…
阅读更多...
2023微信头像生成小程序，国庆头像生成，基于skyline+vue3+t

2023微信头像生成小程序，国庆头像生成，基于skyline+vue3+t

微信头像生成小程序&#xff0c;基于skylinevue3t该项目已适配微信小程序隐私政策&#xff0c;截图、获取头像等诸多新的接口 如何使用&#xff1a; 将代码导入到HBuilderX开发工具&#xff0c; 可无需修改任何代码&#xff0c;运行并编译到微信开发者工具 skyline需要使用微…
阅读更多...
layui中使用JavaScript监听下拉框（select）的变化，根据选中的值来决定是否显示或隐藏input元素

layui中使用JavaScript监听下拉框（select）的变化，根据选中的值来决定是否显示或隐藏input元素

HTML代码 <div class"layui-form-item" id"rubric"><label class"layui-form-label">前端说明</label><div class"layui-input-inline"><input type"text" id"user_rubric" name"…
阅读更多...
页面添加遮罩层

页面添加遮罩层

1.css代码 // 子绝父相.self-check-tag {display: inline-block;min-width: 132px;height: 32px;position: relative;.overlay {position: absolute;top: 0;left: 0;width: 100%;height: 100%;background-color: gray;opacity: 0.1;}2.效果
阅读更多...
QT windows dpi变化导致的界面异常处理

QT windows dpi变化导致的界面异常处理

问题&#xff1a;已经在UI界面中利用布局设计好界面&#xff0c;但是运行程序后显示的界面出现错乱&#xff0c;而且在做出一些修改后重新构建&#xff0c;运行时界面无变化。 目录 一、解决UI设计界面与运行时显示界面不一致的问题 1、导致该现象的原因有&#xff1a;显示屏…
阅读更多...
[Linux] 3.Linux下编码和执行文件

[Linux] 3.Linux下编码和执行文件

Ctrl Alt T快捷键调出命令终端 输入xrandr指令把现有的电脑分辨率列出来 &#xff0c;xrandr -s 分辨率可以调节至想要的分辨率 调节字体大小&#xff1a;Ctrl Shift “”或Ctrl Shift “-” 使字体变大变小 拖动窗口右下角可调节窗口大小 Ctrl “L”清屏 编写C代码文件:…
阅读更多...
【数据结构】散列表（哈希表）的学习知识总结

【数据结构】散列表（哈希表）的学习知识总结

目录 1、散列表 2、散列函数 2.1 定义 2.2 散列函数的构造 2.2.1 除留余数法 2.2.2 直接定址法 2.2.3 数字分析法 2.2.4 平方取中法 3、冲突&#xff08;碰撞&#xff09; 4、处理冲突的方法 4.1 拉链法&#xff08;链接法&#xff09; 4.2 开放定址法 5、C语言…
阅读更多...
电缆直埋、电缆沟、电缆井大样图

电缆直埋、电缆沟、电缆井大样图

一、图纸下载&#xff1a; 链接&#xff1a;https://pan.baidu.com/s/1_SUnhFHMUY8Q_kkhgzscDQ?pwd8888 提取码&#xff1a;8888 二、部分图纸预览
阅读更多...
GoogLeNet网络

GoogLeNet网络

目录 1. 创新点 1.1 引入Inception结构 1.2 11卷积降维 1.3 两个辅助分类器 1.4 丢弃全连接层&#xff0c;使用平均池化层 2. 网络结构 3. 知识点 3.1 torch.cat 3.2 关于self.training 3.3 关于load_state_dict中的strict 4. 代码 4.1 model.py 4.2 train.py …
阅读更多...
MQ - 30 基础功能：死信队列的设计

MQ - 30 基础功能：死信队列的设计

文章目录 导图概述什么是死信队列死信队列实现的技术方案死信队列的存储目标死信队列的方案设计生产死信队列消费死信队列Broker 的死信队列主流消息队列的死信功能RocketMQRabbitMQ总结导图 概述 在日常业务的消费数据过程中，如果遇到数据无法被正确处理，就需要先手动把消息…
阅读更多...
202309解决新版Animate Diff报错问题

202309解决新版Animate Diff报错问题

在安装最新版的Animate Diff的时候发现报错了 ImportError: cannot import name images_tensor_to_samples from modules.sd_samplers_common (W:\A1111\stable-diffusion-webui\modules\sd_samplers_common.py)原因很简单&#xff0c;Animate diff已经适配了新版webui1.6 所以…
阅读更多...
基于LQR算法的一阶倒立摆控制

基于LQR算法的一阶倒立摆控制

1. 一阶倒立摆建模 2. 数学模型 倒立摆的受力分析网上有很多&#xff0c;这里就不再叙述。直接放线性化后的方程&#xff1a; F (Mm)x″-mLφ″ (ImL)φ″ mLx″ mgLφ&#xff08;F为外力&#xff0c;x为物块位移&#xff0c;M&#xff0c;m为物块和摆杆的质量&#xff0c;…
阅读更多...
计算机是怎么跑起来的(2)？程序如何驱动硬件工作的？

计算机是怎么跑起来的(2)？程序如何驱动硬件工作的？

上文计算机是怎么跑起来的?从零开始手动组装微型计算机我们说了&#xff0c;如何手动从来组装一台计算机&#xff0c;那组装完后的计算机上是怎么跑起来程序的呢&#xff1f;程序是如何驱动硬件工作的&#xff1f; 前面我们通过DMA将代码输入到内存的指定位置&#xff0c;然后…
阅读更多...
JavaWeb 学习

JavaWeb 学习

1. 基本概念 1.1 Web web&#xff1a;网络&#xff0c;网页 静态 web html&#xff0c;css提供给所有人看的数据始终不会变化 动态 web 淘宝提供给每个人看的数据会有所不同技术栈&#xff1a;Servlet/JSP&#xff0c;ASP&#xff0c;PHP Java 中&#xff0c;动态 web 资…
阅读更多...
如何通过优化Read-Retry机制降低SSD读延迟？

如何通过优化Read-Retry机制降低SSD读延迟？

近日，小编发现发表于2021论文中，有关于优化Read-Retry机制降低SSD读延迟的研究，小编这里给大家分享一下这篇论文的核心的思路，感兴趣的同学可以，可以在【存储随笔】VX公号后台回复“Optimizing Read-Retry”获取下载链接。 本文中主要基于Charge Trap NAND架构分析。NAND基…
阅读更多...
[C++网络协议] 优于select的epoll

[C++网络协议] 优于select的epoll

1.epoll函数为什么优于select函数 select函数的缺点&#xff1a; 调用select函数后&#xff0c;要针对所有文件描述符进行循环处理。每次调用select函数&#xff0c;都需要向该函数传递监视对象信息。 对于缺点2&#xff0c;是提高性能的最大障碍。因为&#xff0c;套接字是…
阅读更多...
python+vue驾校驾驶理论考试模拟系统

python+vue驾校驾驶理论考试模拟系统

管理员的主要功能有&#xff1a; 1.管理员输入账户登陆后台 2.个人中心&#xff1a;管理员修改密码和账户信息 3.用户管理&#xff1a;管理员可以对用户信息进行添加&#xff0c;修改&#xff0c;删除&#xff0c;查询 4.添加选择题&#xff1a;管理员可以添加选择题目&#xf…
阅读更多...
读高性能MySQL（第4版）笔记15_备份与恢复（下）

读高性能MySQL（第4版）笔记15_备份与恢复（下）

1. 二进制日志 1.1. 服务器的二进制日志是需要备份的最重要元素之一 1.2. 对于基于时间点的恢复是必需的&#xff0c;并且通常比数据要小&#xff0c;所以更容易被进行频繁的备份 1.3. 如果有某个时间点的数据备份和所有从那时以后的二进制日志&#xff0c;就可以重放从上次…
阅读更多...
MySQL数据库入门到精通8--进阶篇( MySQL管理)

MySQL数据库入门到精通8--进阶篇( MySQL管理)

7. MySQL管理 7.1 系统数据库 Mysql数据库安装完成后&#xff0c;自带了一下四个数据库&#xff0c;具体作用如下&#xff1a; 7.2 常用工具 7.2.1 mysql 该mysql不是指mysql服务&#xff0c;而是指mysql的客户端工具。 语法 &#xff1a; mysql [options] [database] 选…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023