微服务设计模式 - 断路器模式 (Circuit Breaker Pattern)

微服务设计模式 - 断路器模式 (Circuit Breaker Pattern)

Circuit Breaker Pattern

定义

断路器模式（Circuit Breaker Pattern）是云计算和微服务架构中的一种保护性设计模式，其目的是避免系统中的调用链出现故障时，导致系统瘫痪。通过断路器模式，可以检测到系统的故障并及时切断不稳定的调用，防止对失败的操作进行连续请求，保护服务的正常运行。

状态结构

断路器模式包含以下三个主要状态：

  1. 关闭状态 (Closed)：初始状态，允许请求通过。如果请求失败次数超过阈值，则状态切换为“打开状态”。
  2. 打开状态 (Open)：不允许请求通过，直接返回错误。经过一段时间后，将状态切换为“半开状态”。
  3. 半开状态 (Half-Open)：允许部分请求通过。如果请求成功，则状态切换为关闭状态；否则，切换回打开状态。

状态转换

Circuit-Breaker-Pattern-State

状态转换说明

  • 初始状态：状态机从 Closed 状态开始，代表断路器默认的工作状态。
  • Closed 状态：
    • 行为：允许所有请求通过，并监控请求的失败次数。
    • 状态转换：如果请求失败次数超过设定阈值，转换到 Open 状态。
  • Open 状态：
    • 行为：所有新请求立即失败，并设置一个超时时间。
    • 状态转换：超时结束后，断路器转换到 HalfOpen 状态。
  • HalfOpen 状态：
    • 行为：允许部分请求通过，以测试外部服务是否恢复正常。
    • 状态转换：
      • 如果请求成功，转换回 Closed 状态。
      • 如果请求失败，转换回 Open 状态。

应用场景

在微服务架构中，断路器模式广泛用于防止服务之间的级联故障。以下是应用断路器模式的一些示例：

  1. 订单系统：假设订单系统依赖库存服务，如果库存服务出现故障，订单系统可以使用断路器模式进行保护。

  2. 支付系统：支付服务可能需要调用第三方服务，断路器模式可以防止第三方服务故障影响整个支付流程。

与重试模式的区别

在分布式系统和微服务架构中，处理服务之间的通信故障是非常关键的。断路器模式和重试模式是两种常用的故障处理方案，这两种模式的目标和适用场景有所不同，理解它们的区别对于构建健壮的系统至关重要。

断路器模式和重试模式在处理操作失败方面有着不同的目的：

  1. 目的不同：

    • 断路器模式 的目的是防止应用程序执行可能会失败的操作。它通过监控请求的失败情况，及时切断不稳定的调用，以保护系统稳定运行。
    • 重试模式 使应用程序能够在操作失败后重新尝试执行该操作，期望最终能够成功。这种模式假设故障是暂时的，可以通过多次尝试来解决。

  2. 工作机制：

    • 断路器模式：当检测到一段时间内某操作的失败次数超过预设的阈值时，断路器会打开，新的请求将被短路并直接失败。经过一段时间后，断路器进入半开状态，允许部分请求通过以测试外部服务是否恢复。如果恢复正常，则断路器关闭；否则，重新打开。
    • 重试模式：在操作失败后，应用程序会自动重新尝试执行该操作，设定的重试次数和间隔时间可以通过配置来调整。重试模式试图通过多次尝试请求来克服暂时的故障。

  3. 故障处理策略：

    • 断路器模式：通过中断请求保护系统，通常会提供降级回退服务。否则，可能返回错误来保护系统。

    • 重试模式：不断尝试请求，直到成功或达到最大重试次数；通常不会提供降级服务，直接返回错误。

Spring Cloud Netflix Hystrix

Spring Cloud Netflix Hystrix 是 Spring Cloud 微服务生态系统中的一个子项目，用于实现分布式系统中的断路器模式（Circuit Breaker Pattern）。Hystrix 是由 Netflix 开发并开源的一个库，它能够帮助开发人员在构建分布式系统时应对服务之间调用的失败和延迟，以增强系统的容错能力和稳定性，主要特性如下：

  1. 断路器：Hystrix 实现了断路器模式，当一个服务发生故障时，Hystrix 通过断路器切断服务调用链，防止故障进一步传播。
  2. 资源隔离：Hystrix 提供了以线程池、信号量等方式实现资源隔离，防止单个服务的故障牵连到全局资源。
  3. 熔断(Fallback)与恢复：Hystrix 能监控服务调用，当发现调用失败率超过预设值时，断路器会打开。经过一定时间后会尝试恢复服务调用。
  4. 降级服务：当服务发生故障或调用超时时，Hystrix 能返回一个默认的降级处理结果，而不是让整个系统崩溃。
  5. 实时监控和告警：Hystrix 提供了仪表盘功能，可以对微服务进行实时监控，帮助开发人员及时发现和解决问题。

示例代码

以下是在 Spring Boot 中使用Hystrix实现断路器模式的完整示例。

项目结构

circuit-breaker-example/
├── src/
│   ├── main/
│   │   ├── java/
│   │   │   ├── com/
│   │   │   │   ├── example/
│   │   │   │   │   ├── CircuitBreakerExampleApplication.java
│   │   │   │   │   ├── config/
│   │   │   │   │   │   └── RestTemplateConfig.java
│   │   │   │   │   ├── controller/
│   │   │   │   │   │   └── PaymentController.java
│   │   │   │   │   ├── service/
│   │   │   │   │   │   └── PaymentService.java
│   ├── resources/
│   │   ├── application.properties
├── pom.xml

引入依赖

在 pom.xml 中添加 Spring Cloud Netflix Hystrix 相关依赖：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>

配置参数

在 application.properties 配置文件中，设置 Hystrix 相关参数：

# Hystrix command 默认执行超时时间，单位毫秒
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=2000

添加 RestTemplate Bean

配置 RestTemplate Bean，以便在服务类中进行依赖注入：

package com.example.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

@Configuration
public class RestTemplateConfig {

    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

创建服务层并使用断路器

创建一个示例服务 PaymentService，在服务方法上添加 @HystrixCommand 注解，并指定降级方法。

package com.example.service;

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

@Service
public class PaymentService {

    private final RestTemplate restTemplate;

    public PaymentService(RestTemplate restTemplate) {
        this.restTemplate = restTemplate;
    }

    @HystrixCommand(fallbackMethod = "defaultPayment")
    public String makePayment() {
        return this.restTemplate.getForObject("http://inventory-service/payment", String.class);
    }

    public String defaultPayment() {
        return "Payment service is unavailable. Please try again later.";
    }
}

创建控制层

创建一个简单的控制器 PaymentController，暴露支付接口：

package com.example.controller;

import com.example.service.PaymentService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class PaymentController {

    @Autowired
    private PaymentService paymentService;

    @GetMapping("/payment")
    public String getPayment() {
        return paymentService.makePayment();
    }
}

主类启用 Hystrix

在主类上添加 @EnableCircuitBreaker 注解：

package com.example;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;

@SpringBootApplication
@EnableCircuitBreaker // 启用断路器
public class CircuitBreakerExampleApplication {
    public static void main(String[] args) {
        SpringApplication.run(CircuitBreakerExampleApplication.class, args);
    }
}

总结

cloud-native-definition-1

断路器模式通过在服务间调用失败时切断请求，从而有效地防止级联故障，提升系统的稳定性和容错能力。在微服务架构中，断路器模式是保护服务正常运行的关键设计模式。Spring Boot 提供了丰富的工具和库(Spring Cloud Netflix Hystrix )，使得断路器模式的实现更加简单和高效。希望本文能帮助您更好地理解断路器模式及其在实际中的应用，为系统设计和实现提供参考。

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

Yelp 数据集进行用户画像， 使用聚类做推荐

Yelp 数据集进行用户画像， 使用聚类做推荐

使用 Yelp 数据集进行用户画像&#xff08;User Profiling&#xff09;是一项有趣的任务&#xff0c;可以理解用户的偏好、行为和特征。以下是总结的一个基本的步骤&#xff0c;帮助构建用户画像 pandas 加载数据&#xff1a; import pandas as pd# 加载数据 users pd.read_…
阅读更多...
DDRPHY数字IC后端设计实现系列专题之后端设计导入，IO Ring设计

DDRPHY数字IC后端设计实现系列专题之后端设计导入，IO Ring设计

本章详细分析和论述了 LPDDR3 物理层接口模块的布图和布局规划的设计和实 现过程&#xff0c;包括设计环境的建立&#xff0c;布图规划包括模块尺寸的确定&#xff0c;IO 单元、宏单元以及 特殊单元的摆放。由于布图规划中的电源规划环节较为重要&#xff0c; 影响芯片的布线资…
阅读更多...
前端路由如何从0开始配置？vue-router 的使用

前端路由如何从0开始配置？vue-router 的使用

在 Web 开发中&#xff0c;路由是指根据 URL 的不同部分将请求分发到不同的处理函数或页面的过程。路由是单页应用&#xff08;SPA, Single Page Application&#xff09;和服务器端渲染&#xff08;SSR, Server-Side Rendering&#xff09;应用中的一个重要概念。 在开发中如何…
阅读更多...
强化学习的数学原理-06随即近似理论和随机梯度下降

强化学习的数学原理-06随即近似理论和随机梯度下降

文章目录 Robbins-Monro algorithmStochastic gradient descentBGD、MBGD、 and SGDSummary Robbins-Monro algorithm 迭代式求平均数的算法 S t o c h a s t i c a p p r o x i m a t i o n ( S A ) Stochastic \; approximation \;(SA) Stochasticapproximation(SA)&#xf…
阅读更多...
Apache Hive 通过Docker快速入门

Apache Hive 通过Docker快速入门

QuickStarted 介绍 在伪分布式模式下在 docker 容器内运行 Apache Hive&#xff0c;以便为 Hive 提供以下快速启动/调试/准备测试环境 快速入门 步骤 1&#xff1a;拉取镜像 从 DockerHub 拉取镜像&#xff1a;https://hub.docker.com/r/apache/hive/tags。以下是最新的镜像…
阅读更多...
【K8S系列】Kubernetes 中 NodePort 类型的 Service 无法访问的问题【已解决】

【K8S系列】Kubernetes 中 NodePort 类型的 Service 无法访问的问题【已解决】

在 Kubernetes 中&#xff0c;NodePort 类型的 Service 允许用户通过每个节点的 IP 地址和指定的端口访问应用程序。如果 NodePort 类型的 Service 无法通过节点的 IP 地址和指定端口进行访问&#xff0c;可能会导致用户无法访问应用。本文将详细分析该问题的常见原因及其解决方…
阅读更多...
逻辑卷动态扩容与缩容-----

逻辑卷动态扩容与缩容-----

一、创建逻辑卷 需求&#xff1a;创建一个2.5G大小的逻辑卷 思路&#xff1a; 1. 物理的设备 2. 将物理设备做成物理卷 pv 3. 创建卷组并将物理卷加入其中 vg 4. 创建逻辑卷 lv 5. 格式化逻辑卷 mkfs.ext4 6. 挂载使用 mount 步骤&#xff1a; 1. 物理设备【如何来分区】…
阅读更多...
开关灯问题（c语言）

开关灯问题（c语言）

样例&#xff1a;10 10 &#xff0c;输出&#xff1a;1&#xff0c;4&#xff0c;9 5 5 &#xff0c;输出&#xff1a;1&#xff0c;4 代码如下 #include<stdio.h> //引入bool值的概念 #include<stdbool.h> int main() {int n 0;//n为灯的数量int m 0;…
阅读更多...
扫雷游戏（C语言详解）

扫雷游戏（C语言详解）

扫雷游戏&#xff08;C语言详解&#xff09; 放在最前面的1、前言&#xff08;扫雷游戏的简介&#xff09;2、扫雷游戏的规则&#xff08;简易版&#xff09;3、代码实现&#xff08;3.1&#xff09;提醒一下&#xff1a;( i ) 提醒1&#xff1a;( ii ) 提醒2&#xff1a; &…
阅读更多...
在面试了些外包以后，我有了些自己的思考

在面试了些外包以后，我有了些自己的思考

大家好&#xff0c;我是洋子&#xff0c;最近公司在降本增效&#xff0c;需要把外包从北京迁移到陕西的某新一线城市&#xff0c;其实就是变相裁员&#xff0c;减少外包的成本&#xff0c;裁掉现有的员工&#xff0c;重新招聘新人 在整个测试行业&#xff0c;外包测试的比重是…
阅读更多...
论文 | Ignore Previous Prompt: Attack Techniques For Language Models

论文 | Ignore Previous Prompt: Attack Techniques For Language Models

这篇论文探讨了针对大型语言模型&#xff08;LLM&#xff09;的“提示注入”攻击&#xff0c;并提出了一种名为 PROMPTINJECT 的框架来研究这类攻击。 论文的主要内容包括&#xff1a;1. 提示注入攻击&#xff1a; 论文定义了“提示注入”的概念&#xff0c;即通过在用…
阅读更多...
Django-中间件

Django-中间件

定义&#xff1a; 编写中间件&#xff1a; 注册中间件&#xff1a; 添加中间件&#xff1a; 1.在项目目录下添加一个文件夹&#xff08;名字随意&#xff09;&#xff0c;然后文件夹下创建.py文件 2.将中间件添加到setting文件中 MIDDLEWARE [django.middleware.security.Se…
阅读更多...
MBR20100CT-ASEMI半塑封肖特基二极管MBR20100CT

MBR20100CT-ASEMI半塑封肖特基二极管MBR20100CT

编辑&#xff1a;ll MBR20100CT-ASEMI半塑封肖特基二极管MBR20100CT 型号&#xff1a;MBR20100CT 品牌&#xff1a;ASEMI 封装&#xff1a;TO-220 安装方式&#xff1a;插件 批号&#xff1a;最新 最大平均正向电流&#xff08;IF&#xff09;&#xff1a;20A 最大循环…
阅读更多...
操作数据表

操作数据表

创建表 创建表语法&#xff1a; CREATE TABLE table_name ( field1 datatype [COMMENT 注释内容], field2 datatype [COMMENT 注释内容], field3 datatype ); 注意&#xff1a; 1. 蓝色字体为关键字 2. CREATE TABLE 是创建数据表的固定关键字&#xff0c;表…
阅读更多...
一、ARMv8寄存器之通用、状态、特殊寄存器

一、ARMv8寄存器之通用、状态、特殊寄存器

ARMV8核心寄存器数量是非常大的&#xff0c;为了更好的学习&#xff0c;可以划分为以下几大类&#xff1a; 通用寄存器。这类寄存器主要是用来暂存数据和参与运算。通过load\store指令操作。状态寄存器。AArch64体系结构使用PSTATE寄存器表示当前处理器状态。特殊寄存器。有专门…
阅读更多...
WPF+MVVM案例实战（六）- 自定义分页控件实现

WPF+MVVM案例实战（六）- 自定义分页控件实现

文章目录 1、项目准备2、功能实现1、分页控件 DataPager 实现2、分页控件数据模型与查询行为3、数据界面实现 3、运行效果4、源代码获取 1、项目准备 打开项目 Wpf_Examples&#xff0c;新建 PageBarWindow.xaml 界面、PageBarViewModel.cs ,在用户控件库 UserControlLib中创建…
阅读更多...
【Docker】构建Linux云桌面环境

【Docker】构建Linux云桌面环境

目录 一、说明 二、离线安装Docker 1&#xff09;将下载的包上传到服务器上去 2&#xff09;安装docker 3) 启动docker 4&#xff09;配置加速器 三、安装云桌面镜像 四、启动云桌面 方式一&#xff1a;docker命令直接运行 方式二&#xff1a;docker-compose方式 五…
阅读更多...
Easysearch 与 LLM 融合打造知识库系统

Easysearch 与 LLM 融合打造知识库系统

文章目录 一、LangChain 简介二、RAG 产生的背景及其局限性三、RAG 工作流程四、 Easysearch 结合 LLM 实现 RAG&#xff08;1&#xff09;Easysearch 简介&#xff08;2&#xff09;结合实现RAG 五、 Easysearch 结合 LLM 实现 RAG 的优势&#xff08;1&#xff09;提高检索准…
阅读更多...
驱动-----adc

驱动-----adc

在key1.c的基础上进行对adc1.c进行编写 首先将文件里面的key全部改为adc 再修改一下设备号 按键和adc的区别是什么，按键只需要按一下就触发了，并且不需要返回一个值出来， adc要初始化，启动，返回值 以下是裸机adc的代码： #include <s3c2440.h> #include "ad…
阅读更多...
快速生成高质量提示词，Image to Prompt 更高效

快速生成高质量提示词，Image to Prompt 更高效

抖知书老师推荐&#xff1a; 随着 AI 技术的不断发展&#xff0c;视觉信息与语言信息之间的转换变得越来越便捷。在如今的数字化生活中&#xff0c;图像与文字的交互需求愈发旺盛&#xff0c;很多人都希望能轻松将图像内容直接转化为文本描述。今天我们来推荐一款实用的 AI 工…
阅读更多...
最新文章

Copyright @ 2022~2023