业务开发中的双重请求,优雅降级,熔断机制

360影视 2025-01-05 12:37 2

摘要:工作原理:同时发起本地和远程两个请求,谁先返回结果就优先使用谁的。如果本地请求优先返回且成功,放弃远程请求的结果;如果远程请求先返回,则直接使用远程结果。如果本地请求失败,通常继续等待远程请求完成。优点:提高响应速度:因为同时发起两个请求,不论是本地还是远程的

双重请求模式和优雅降级是两种用于提高应用的响应速度和用户体验的设计模式。

1. 双重请求模式(Dual Request Mode)

双重请求模式是指同时发起两个请求(通常是本地和远程请求),优先使用先返回的响应。这种模式通常用于需要保证速度的场景,比如内容加载或翻译应用。

工作原理:

同时发起本地和远程两个请求,谁先返回结果就优先使用谁的。

如果本地请求优先返回且成功,放弃远程请求的结果;如果远程请求先返回,则直接使用远程结果。

如果本地请求失败,通常继续等待远程请求完成。

优点:

提高响应速度:因为同时发起两个请求,不论是本地还是远程的,优先响应的结果将立即使用,从而减少等待时间。

提升用户体验:避免单一请求失败带来的延迟,让用户在网络质量波动的情况下获得更好的体验。

缺点:

增加请求数量:双重请求可能会增加服务器负担,尤其是网络请求较为昂贵的情况下。

较高的资源消耗:对设备(尤其是移动设备)电量和数据消耗有一定影响。

示例代码(基于双重请求模式)async function dualRequestTranslate(text) {const localRequest = localTranslate(text);const remoteRequest = serverTranslate(text);return Promise.race([localRequest, remoteRequest]).then((result) => result).catch(async => {// 如果本地请求失败,则等待远程请求的结果return await remoteRequest;});}

备用(Failover)模式是一种关键的高可用性技术,用于确保系统在出现故障时能够自动切换到备用资源或服务,以保证系统的连续性。Failover 模式常用于数据库、服务器、网络连接等对系统稳定性至关重要的组件和服务。

备用模式的工作原理

备用模式的核心思想是在主要服务出现故障时,自动切换到备用服务或资源。这种切换通常是自动完成的,不需要人为干预,从而减少停机时间。

备用模式一般分为以下几种实现方式:

主动-被动(Active-Passive)备用模式:

工作原理:在这种模式下,主服务处于活跃状态,备用服务处于待命状态。只有当主服务出现问题时,系统才会切换到备用服务。

特点:备用服务处于休眠状态,直到需要时才被激活,能够节省资源。此模式最常见于数据库和服务器备份。

缺点:备用资源在大部分时间闲置,资源利用率较低。

主动-主动(Active-Active)备用模式:

工作原理:在这种模式下,多个服务或资源处于活跃状态,互相支持并提供负载均衡。如果一个服务出现故障,另一个活跃的服务可以立即承担其负载。

特点:这种模式提高了资源利用率,并支持更好的负载均衡和扩展性,适合高需求、高并发的场景。

缺点:实现成本高,管理复杂,且需要复杂的同步和负载均衡机制。

多重备用(Multiple Failover)模式:

工作原理:有多个备用资源,形成级联的备用顺序。当主资源故障时,系统会依次尝试切换到下一个备用资源。

特点:提供更高的冗余度,适合对高可用性要求极高的系统。

缺点:增加了系统复杂度和资源需求,成本较高。

地理冗余备用:

工作原理:在不同的地理位置部署备份资源。主资源故障时,系统可以切换到其他地理位置的资源,常用于容灾(Disaster Recovery)场景。

特点:适用于灾难恢复、跨地区的容错保护。

缺点:延迟较高,且同步复杂,需要高成本的网络和存储支持。

备用模式的实现方法

备用模式的实现通常依赖监控、故障检测和自动切换机制。以下是一些实现备用模式的常见方式:

健康检查与故障检测:

备用系统需要实时监测主服务的健康状况,比如检测响应时间、CPU负载、错误率等。发现故障后,备用系统会进行故障切换。

实现方式包括心跳检测、Ping 检查、连接监控等。

自动切换机制:

当主服务被检测到不可用时,系统会自动切换到备用服务。例如在数据库系统中,可以使用 VIP(虚拟 IP)切换,将流量重定向到备用数据库。

数据同步:

在主动-被动模式中,备用资源通常需要保持与主资源一致的数据状态,因此需要实时的数据同步机制。数据库系统会使用主从复制、双向复制等方式保持数据一致性。

示例代码

以下是一个简单的示例,展示了如何在 Node.js 中实现一个备用模式。这里通过调用主 API,如果主 API 不可用,就切换到备用 API。

const axios = require('axios');class FailoverRequest {constructor(primaryUrl, secondaryUrl) {this.primaryUrl = primaryUrl;this.secondaryUrl = secondaryUrl;}async makeRequest {try {// 尝试调用主服务const response = await axios.get(this.primaryUrl);console.log("Primary service responded successfully");return response.data;} catch (error) {console.warn("Primary service failed, switching to secondary");try {// 主服务不可用,尝试调用备用服务const response = await axios.get(this.secondaryUrl);console.log("Secondary service responded successfully");return response.data;} catch (error) {console.error("Both primary and secondary services failed");throw new Error("All services are down");}}}}// 使用示例const failoverRequest = new FailoverRequest("https://primary-service.com/api","https://secondary-service.com/api");failoverRequest.makeRequest.then((data) => console.log("Data received:", data)).catch((error) => console.error("Request failed:", error.message));备用模式的优缺点

优点:

提升系统的高可用性:在主资源故障时自动切换到备用资源,减少停机时间。

提高用户体验:在故障发生时用户体验不会中断。

支持业务连续性:在紧急情况下,备用模式可以让系统保持正常运行,适合金融、电商等高可用性要求的业务。

缺点:

成本高:备用资源在大部分时间可能闲置,尤其是主动-被动模式会导致资源利用率低。

实现复杂:需要实现数据同步、健康监控和自动切换机制,系统的复杂度增加。

数据一致性问题:在某些场景中,备用系统的数据可能不完全同步,切换时可能会出现数据不一致。

备用模式的应用场景

数据库备份:在数据库系统中,主数据库故障时,备用数据库可以接管请求,保证数据服务的连续性。

Web 服务器集群:在 Web 应用中,可以使用备用服务器,在主服务器不可用时继续为用户提供服务。

云服务高可用性:许多云服务提供跨区域的备份服务,可以在区域性故障时快速切换到其他区域。

负载均衡与自动故障转移:在分布式架构中,备用模式与负载均衡结合使用,实现故障自动转移,提升整体系统可靠性。

备用模式在关键应用场景下尤为重要,它为系统提供了稳定性和容灾能力,是保障高可用系统不可或缺的一环。

2. 优雅降级(Graceful Degradation)

优雅降级是一种应用设计模式,确保应用在高性能或新功能不支持时,仍能提供基本功能,避免因单一模块失败而影响整体体验。优雅降级是为高需求而设计,同时确保在不可用或受限环境中能有效“降级”运行。

工作原理:

在理想环境下(如强大设备或稳定网络)使用高级功能。

如果某些条件未满足,则逐步降级到基础功能以保持应用可用。

举例:网络视频播放器在带宽不足时从高清降级到标清,或内容加载不完全时显示占位符。

优点:

提高鲁棒性:在各种设备和网络环境下都能正常工作。

良好的用户体验:即使功能降级,用户仍然可以使用基本功能,不至于因缺少支持而体验不佳。

缺点:

增加开发复杂性:需要为各种场景编写不同的逻辑和界面。

可能影响部分用户体验:降级的功能往往不是完整体验,功能会有所妥协。

示例代码(基于优雅降级)async function translateWithGracefulDegradation(text) {try {// 尝试进行高级本地翻译return await advancedLocalTranslate(text);} catch (error) {console.warn("高级翻译不可用,降级到基础翻译", error);try {// 如果高级本地翻译失败,使用基础本地翻译return await basicLocalTranslate(text);} catch (error) {console.warn("本地翻译不可用,降级到服务端翻译", error);// 最后降级到服务端翻译return await serverTranslate(text);}}}总结

双重请求模式主要用于提升响应速度,优先使用先返回的结果,适用于本地和远程请求并发时。

优雅降级则用于提高应用在不同环境下的兼容性,逐步降级到基础功能,在理想条件下保持最佳体验,不理想条件下维持最低可用体验。

3.熔断机制

熔断机制是一种防止系统过载的保护模式,常用于微服务和分布式系统中,以避免系统在大量请求失败的情况下继续发送请求,从而导致更严重的资源消耗和故障。熔断器会检测服务的健康状况,并在服务异常(如响应超时、错误率升高等)时,短暂切断请求流向异常服务,等一段时间后再尝试恢复服务调用。熔断机制不仅有助于保持服务的可用性,还可以提升系统的整体稳定性。

熔断机制的工作原理

关闭状态(Closed):

初始状态下,熔断器处于“关闭状态”,所有请求正常发往目标服务。

如果目标服务返回大量错误(比如超时、500错误等),熔断器会记录失败次数。

当失败次数超过设定的阈值后,熔断器进入“打开状态”。

打开状态(Open):

在打开状态下,熔断器会短暂中断对目标服务的请求,直接返回失败响应。

这种状态相当于保护机制,防止服务进一步恶化。

经过一段冷却时间后,熔断器会进入“半开状态”。

半开状态(Half-Open):

在半开状态下,熔断器会允许少量的请求流向目标服务以测试是否恢复正常。

如果这些请求成功,熔断器会返回到关闭状态,继续正常工作。

如果仍然出现错误,熔断器会重新回到打开状态,继续阻止请求。

熔断机制的实现

以下是一个熔断器的 JavaScript 示例,使用计数器和定时器实现请求状态的监控和自动恢复。

class CircuitBreaker {constructor(requestFn, failureThreshold = 3, cooldownPeriod = 5000) {this.requestFn = requestFn; // 需要熔断保护的请求函数this.failureThreshold = failureThreshold; // 失败次数阈值this.cooldownPeriod = cooldownPeriod; // 熔断恢复时间(毫秒)this.failures = 0; // 当前失败次数this.state = "CLOSED"; // 熔断器初始状态this.nextAttempt = Date.now; // 下次允许的尝试时间}async call(...args) {// 检查熔断器状态if (this.state === "OPEN") {if (Date.now > this.nextAttempt) {this.state = "HALF_OPEN";} else {throw new Error("Circuit is currently open. Request blocked.");}}try {const response = await this.requestFn(...args);this.reset; // 成功后重置熔断器状态return response;} catch (error) {this.recordFailure;throw error;}}// 记录一次失败请求recordFailure {this.failures += 1;if (this.failures >= this.failureThreshold) {this.state = "OPEN";this.nextAttempt = Date.now + this.cooldownPeriod;console.warn("Circuit breaker is now OPEN.");}}// 重置熔断器状态reset {this.failures = 0;this.state = "CLOSED";}}// 使用示例const unstableRequest = async => {// 模拟不稳定请求,有50%几率失败if (Math.random > 0.5) throw new Error("Request failed");return "Request succeeded";};// 创建熔断器实例,阈值为3,冷却期5秒const circuitBreaker = new CircuitBreaker(unstableRequest, 3, 5000);async function runRequest {try {const result = await circuitBreaker.call;console.log(result);} catch (error) {console.error(error.message);}}// 多次调用以测试熔断器行为setInterval(runRequest, 1000);解释代码

熔断器状态:初始状态为“关闭”。如果失败次数达到阈值,将状态设为“打开”,并设置nextAttempt为冷却期结束的时间。

失败次数记录:recordFailure方法会增加失败次数,超过阈值时将熔断器切换到“打开”状态。

重置熔断器:在请求成功后,reset方法会将失败次数重置为0,将熔断器状态设为“关闭”。

半开状态测试:在打开状态的冷却期结束后,熔断器会切换到“半开”状态,允许少量请求来测试服务是否恢复。

熔断机制的优缺点

优点:

提高系统稳定性,避免不断地调用故障服务导致系统负载增加。

增强用户体验,在服务异常时及时返回信息,而不是让用户一直等待。

缺点:

增加了系统复杂性,熔断机制需要精心调试(例如失败阈值、冷却时间等)。

如果熔断器策略不当,可能导致服务恢复后仍然短时间内无法使用。

实际应用场景

微服务架构:在分布式系统中,熔断器防止单个故障服务引发连锁反应导致系统崩溃。

网络请求:当网络或 API 不稳定时,熔断器能避免多次重试导致的更大延迟或网络负载。

关键资源的保护:限制高负载下的数据库访问或缓存调用,以确保系统不因资源过载而崩溃。

熔断机制在需要高可用性和稳定性的场景中尤其有用,能够有效降低因服务故障带来的影响。

各位读者朋友们,周末愉快!!!

来源:蕾蕾课堂

相关推荐