【Java设计模式】断路器模式：增强系统弹性

2024-08-30 12:28
文章标签 java 系统 设计模式 模式 断路器 增强 弹性

本文主要是介绍【Java设计模式】断路器模式：增强系统弹性，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

文章目录

  • 【Java设计模式】断路器模式：增强系统弹性
    • 一、概述
    • 二、断路器设计模式的别名
    • 三、断路器设计模式的意图
    • 四、断路器模式的详细解释及实际示例
    • 五、Java中断路器模式的编程示例
    • 六、何时在Java中使用断路器模式
    • 七、断路器模式在Java中的实际应用
    • 八、断路器模式的优点和权衡
    • 九、源码下载

【Java设计模式】断路器模式：增强系统弹性

一、概述

在Java设计中，断路器模式是一种确保微服务和分布式系统容错性和弹性的关键模式。本文将详细介绍断路器模式的意图、解释、编程示例、适用场景、实际应用、优点和权衡。同时，还将提供示例代码的下载链接，方便读者进行学习和实践。

二、断路器设计模式的别名

  • Fault Tolerance Switch（容错开关）

三、断路器设计模式的意图

断路器模式是一种重要的Java设计模式，有助于确保微服务和分布式系统的容错性和弹性。通过使用断路器，能够防止系统反复尝试执行可能失败的操作，使其从故障中恢复，并防止级联故障。

四、断路器模式的详细解释及实际示例

  1. 实际示例：
    • 考虑一个电子商务网站的实际例子，该网站依赖多个外部支付网关来处理交易。如果其中一个支付网关变得无响应或缓慢，断路器模式可以用于检测故障并防止系统反复尝试使用有问题的网关。相反，它可以快速切换到替代支付网关或向用户显示错误消息，确保网站的其余部分保持功能正常和响应迅速。这样可以避免资源耗尽，并通过允许通过其他可用服务处理交易来提供更好的用户体验。通过这种方式，断路器模式处理外部API故障，确保系统保持功能正常。
  2. 通俗解释：
    • 断路器允许优雅地处理失败的远程服务。当我们应用程序的所有部分高度解耦，并且一个组件的故障并不意味着其他部分将停止工作时，它特别有用。
  3. 维基百科解释：
    • 断路器是现代软件开发中使用的一种设计模式。它用于检测故障并封装防止故障不断重复发生的逻辑，在维护、临时外部系统故障或意外系统困难期间。

五、Java中断路器模式的编程示例

这个Java示例展示了断路器模式如何管理远程服务故障并维护系统稳定性。
想象一个网络应用程序，它使用本地文件/图像和远程服务来获取数据。远程服务可能会变得缓慢或无响应，这可能会导致应用程序由于线程饥饿而挂起。断路器模式可以帮助检测到此类故障，并允许应用程序优雅地降级。

  1. 模拟延迟的远程服务
// DelayedRemoteService模拟一个在一定延迟后响应的远程服务。
var delayedService = new DelayedRemoteService(serverStartTime, 5);
  1. 设置断路器
// DefaultCircuitBreaker包装远程服务并监视故障。
var delayedServiceCircuitBreaker = new DefaultCircuitBreaker(delayedService, 3000, 2, 2000 * 1000 * 1000);
  1. 监控服务来处理请求
// MonitoringService负责调用远程服务。
var monitoringService = new MonitoringService(delayedServiceCircuitBreaker, quickServiceCircuitBreaker);
// 从本地资源获取响应
LOGGER.info(monitoringService.localResourceResponse());
// 从延迟服务获取响应2次，以达到故障阈值
LOGGER.info(monitoringService.delayedServiceResponse());
LOGGER.info(monitoringService.delayedServiceResponse());
  1. 处理断路器状态
// 在超过故障阈值限制后，获取延迟服务断路器的当前状态（此时应为OPEN）
LOGGER.info(delayedServiceCircuitBreaker.getState());
// 同时，延迟服务不可用，从健康的快速服务获取响应
LOGGER.info(monitoringService.quickServiceResponse());
LOGGER.info(quickServiceCircuitBreaker.getState());
  1. 从故障中恢复
// 等待延迟服务恢复响应
try {LOGGER.info("等待延迟服务恢复响应");Thread.sleep(5000);
} catch (InterruptedException e) {LOGGER.error("发生错误：", e);
}
// 检查延迟断路器的状态，应为HALF_OPEN
LOGGER.info(delayedServiceCircuitBreaker.getState());
// 从延迟服务获取响应，此时应已恢复健康
LOGGER.info(monitoringService.delayedServiceResponse());
// 由于获取到成功的响应，它应再次变为CLOSED。
LOGGER.info(delayedServiceCircuitBreaker.getState());
  1. 完整示例
public static void main(String[] args) {var serverStartTime = System.nanoTime();var delayedService = new DelayedRemoteService(serverStartTime, 5);var delayedServiceCircuitBreaker = new DefaultCircuitBreaker(delayedService, 3000, 2,2000 * 1000 * 1000);var quickService = new QuickRemoteService();var quickServiceCircuitBreaker = new DefaultCircuitBreaker(quickService, 3000, 2,2000 * 1000 * 1000);// 创建监控服务对象，该对象进行本地和远程调用var monitoringService = new MonitoringService(delayedServiceCircuitBreaker,quickServiceCircuitBreaker);// 从本地资源获取响应LOGGER.info(monitoringService.localResourceResponse());// 从延迟服务获取响应2次，以达到故障阈值LOGGER.info(monitoringService.delayedServiceResponse());LOGGER.info(monitoringService.delayedServiceResponse());// 在超过故障阈值限制后，获取延迟服务断路器的当前状态（此时应为OPEN）LOGGER.info(delayedServiceCircuitBreaker.getState());// 同时，延迟服务不可用，从健康的快速服务获取响应LOGGER.info(monitoringService.quickServiceResponse());LOGGER.info(quickServiceCircuitBreaker.getState());// 等待延迟服务恢复响应try {LOGGER.info("等待延迟服务恢复响应");Thread.sleep(5000);} catch (InterruptedException e) {LOGGER.error("发生错误：", e);}// 检查延迟断路器的状态，应为HALF_OPENLOGGER.info(delayedServiceCircuitBreaker.getState());// 从延迟服务获取响应，此时应已恢复健康LOGGER.info(monitoringService.delayedServiceResponse());// 由于获取到成功的响应，它应再次变为CLOSED。LOGGER.info(delayedServiceCircuitBreaker.getState());
}

示例总结：

  • 用参数timeout、failureThreshold和retryTimePeriod初始化断路器。
  • 开始处于closed状态。
  • 成功调用时，重置状态。
  • 失败超过阈值时，转换为open状态以防止进一步调用。
  • 在重试超时后，转换为half - open状态以测试服务。
  • 在half - open状态下成功时，转换回closed。失败时，返回open。
    程序输出：
16:59:19.767 [main] INFO com.iluwatar.circuitbreaker.App -- 本地服务正在工作
16:59:19.769 [main] INFO com.iluwatar.circuitbreaker.App -- 延迟服务已关闭
16:59:19.769 [main] INFO com.iluwatar.circuitbreaker.App -- 延迟服务已关闭
16:59:19.769 [main] INFO com.iluwatar.circuitbreaker.App -- OPEN
16:59:19.769 [main] INFO com.iluwatar.circuitbreaker.App -- 快速服务正在工作
16:59:19.769 [main] INFO com.iluwatar.circuitbreaker.App -- CLOSED
16:59:19.769 [main] INFO com.iluwatar.circuitbreaker.App -- 等待延迟服务恢复响应
16:59:24.779 [main] INFO com.iluwatar.circuitbreaker.App -- HALF_OPEN
16:59:24.780 [main] INFO com.iluwatar.circuitbreaker.App -- 延迟服务正在工作
16:59:24.780 [main] INFO com.iluwatar.circuitbreaker.App -- CLOSED

这个示例展示了断路器模式如何通过管理远程服务故障来帮助维护应用程序的稳定性和弹性。

六、何时在Java中使用断路器模式

断路器模式适用于以下情况：

  1. 在分布式系统中，单个服务故障可能导致级联的系统范围故障。
  2. 对于与可能变得无响应或缓慢的第三方服务或数据库交互的应用程序。
  3. 在微服务架构中，一个服务的故障可能影响其他服务的可用性。

七、断路器模式在Java中的实际应用

  1. 云服务，用于优雅地处理外部服务的故障。
  2. 电子商务平台，用于管理高交易量和对外部API的依赖。
  3. 微服务架构，用于维护系统稳定性和响应能力。
  4. Spring Circuit Breaker模块
  5. Netflix Hystrix API

八、断路器模式的优点和权衡

优点：

  1. 防止系统执行可能失败的徒劳操作，从而节省资源。
  2. 有助于在部分系统故障期间维护应用程序的系统稳定性和性能。
  3. 通过避免用重复请求淹没故障服务，促进更快的系统恢复。

权衡：

  1. 系统的复杂性增加，因为该模式需要额外的逻辑来检测故障和管理断路器的状态。
  2. 如果配置不当，可能导致系统降级，因为合法请求可能会在电路打开时被阻止。
  3. 需要仔细调整阈值和超时周期，以在响应能力和保护之间取得平衡。

九、源码下载

断路器模式示例代码下载

通过本文的介绍，相信大家对Java中的断路器模式有了更深入的了解。在实际开发中，合理运用断路器模式可以提高系统的容错性和弹性，确保系统在面对故障时能够保持稳定运行。

这篇关于【Java设计模式】断路器模式：增强系统弹性的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1120816。

相关文章

JVM 的类初始化机制

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时，有没有考虑过 JVM 是如何把静态的字节码（byte code）转化为运行时对象的呢，这个问题看似简单，但清楚的同学相信也不会太多，这篇文章首先介绍 JVM 类初始化的机制，然后给出几个易出错的实例来分析，帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段，分别是：loading 、Linking、initialization
阅读更多...
Spring Security 基于表达式的权限控制

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权，允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true （Spring security默认会带有ROLE_前缀）,去
阅读更多...
浅析Spring Security认证过程

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程，特意画了如下的类图，包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口，接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti
阅读更多...
Spring Security--Architecture Overview

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类，它们之间的依赖，构建起了整个框架。想要理解整个架构，最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文（security context）的信息。当前操作的用户是谁，该用户是否已经被认证，他拥有哪些角色权限…这些都被保
阅读更多...
Spring Security基于数据库验证流程详解

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明（认真看哦） AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证，则会调用 #attemptAuthentica
阅读更多...
Spring Security 从入门到进阶系列教程

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门（一）：登录与退出》 《Spring-Security-入门（二）：基于数据库验证》 《Spring-Security-入门（三）：密码加密》 《Spring-Security-入门（四）：自定义-Filter》 《Spring-Security-入门（五）：在 Sprin
阅读更多...
Java架构师知识体认识

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物
阅读更多...
不懂推荐算法也能设计推荐系统

不懂推荐算法也能设计推荐系统

本文以商业化应用推荐为例，告诉我们不懂推荐算法的产品，也能从产品侧出发， 设计出一款不错的推荐系统。 相信很多新手产品，看到算法二字，多是懵圈的。 什么排序算法、最短路径等都是相对传统的算法（注：传统是指科班出身的产品都会接触过）。但对于推荐算法，多数产品对着网上搜到的资源，都会无从下手。特别当某些推荐算法 和 “AI”扯上关系后，更是加大了理解的难度。 但，不了解推荐算法，就无法做推荐系
阅读更多...
基于人工智能的图像分类系统

基于人工智能的图像分类系统

目录 引言项目背景环境准备 硬件要求软件安装与配置系统设计 系统架构关键技术代码示例 数据预处理模型训练模型预测应用场景结论 1. 引言 图像分类是计算机视觉中的一个重要任务，目标是自动识别图像中的对象类别。通过卷积神经网络（CNN）等深度学习技术，我们可以构建高效的图像分类系统，广泛应用于自动驾驶、医疗影像诊断、监控分析等领域。本文将介绍如何构建一个基于人工智能的图像分类系统，包括环境
阅读更多...
水位雨量在线监测系统概述及应用介绍

水位雨量在线监测系统概述及应用介绍

在当今社会，随着科技的飞速发展，各种智能监测系统已成为保障公共安全、促进资源管理和环境保护的重要工具。其中，水位雨量在线监测系统作为自然灾害预警、水资源管理及水利工程运行的关键技术，其重要性不言而喻。 一、水位雨量在线监测系统的基本原理 水位雨量在线监测系统主要由数据采集单元、数据传输网络、数据处理中心及用户终端四大部分构成，形成了一个完整的闭环系统。 数据采集单元：这是系统的“眼睛”，
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2