NodeJS 熔断机制

CircuitBreaker--熔断器设计模式

熔断器模式可以防止应用程序不断地尝试执行可能会失败的操作,使得应用程序继续执行而不用等待修正错误,或者浪费CPU时间去等到长时间的超时产生。熔断器模式也可以使应用程序能够诊断错误是否已经修正,如果已经修正,应用程序会再次尝试调用操作。

翻译:Kyle 作者:Abhinav Dhasmana 原文:https://itnext.io/understand-circuitbreaker-design-pattern-with-simple-practical-example-92a752615b42

image

问题描述

我们有一个serviceA有两个API

  • /data 依赖于 serviceB
  • /data2 不依赖于外部服务

image

让我们尝试实现这个场景,看看它如何影响我们的整个系统。完整的源代码可以在Github上找到。

没有断路器

serviceB实施如下。API对前5分钟的请求,将延迟5s响应。它在端口8000上运行。

server.route({
  method: 'GET',
  path: '/flakycall',
  handler: async (request, h) => {
    const currentTime = Date.now();
    if ((currentTime - serverStartTime) < (1000 * 60 * 5)) {
      const result = await new Promise((resolve) => {
        setTimeout(() => {
          resolve('This is a delayed repsonse');
        }, 5000);
      });
      return h.response(result);
    }
    return h.response('This is immediate response');
  },
});
<center>serviceB:模拟延迟响应</center>

serviceA 将向serviceB发出http请求

server.route({
  method: 'GET',
  path: '/data2',
  handler: (request, h) => {
    try {
      return h.response('data2');
    } catch (err) {
      throw Boom.clientTimeout(err);
    }
  },
});

server.route({
  method: 'GET',
  path: '/data',
  handler: async (request, h) => {
    try {
      const response = await axios({
        url: 'http://0.0.0.0:8000/flakycall',
        timeout: 6000,
        method: 'get',

      });
      return h.response(response.data);
    } catch (err) {
      throw Boom.clientTimeout(err);
    }
  },
});
<center>ServiceA:调用受影响的serviceA</center>

我们将使用jMeter模拟负载 。在几秒钟内,serviceA将资源短缺。所有请求都在等待http请求完成。第一个API会开始抛出错误,它最终将会崩溃,因为它会达到最大堆的上限。

image
<center>jMeter报告API失败</center>
<---最后几个GC --->
[90303:0x102801600] 90966 ms:标记扫描1411.7(1463.4) - > 1411.3(1447.4)MB,1388.3 / 0.0 ms(自标记开始以0步开始+ 0.0 ms,最大步长0.0 ms,标记开始后的停机时间1388 ms)旧空间GC请求
[90303:0x102801600] 92377 ms:标记扫描1411.3(1447.4) - > 1411.7(1447.4)MB,1410.9 / 0.0 ms最后请求旧空间GC
<--- JS stacktrace --->
==== JS堆栈跟踪=========================================
安全上下文:0x2c271c925ee1 <JSObject> 
1:clone [/Users/abhinavdhasmana/Documents/Personal/sourcecode/circuitBreaker/client/node_modules/hoek/lib/index.js:~20] [pc = 0x10ea64e3ebcb](this = 0x2c2775156bd9 <Object map = 0x2c276089fe19>,obj = 0x2c277be1e761 <WritableState map = 0x2c27608b1329>,see = 0x2c2791b76f41 <Map map = 0x2c272c2848d9>)
2:clone [/ Users / abhinavdhasmana // circuitBreaker / client / node_modul ...

现在,我们有两个不工作的的服务,而不是一个。这将在整个系统中升级,从而导致整个基础设施将会崩溃。

为什么我们需要一个断路器

如果我们serviceB失败了,serviceA应该仍然尝试从中恢复并尝试执行以下操作之一:

  • 自定义回退:尝试从其他来源获取相同的数据。如果不可能,请使用自己的缓存值。
  • 快速失败:如果serviceA知道失败serviceB了,那么就没有必要等待超时并消耗自己的资源。它应该尽快返回“知道” serviceB已关闭
  • 不要崩溃:正如我们在这种情况下看到的那样,serviceA不应该崩溃。
  • 自动修复:定期检查是否serviceB再次起作用。
  • 其他API应该有效:所有其他API应该继续工作。

什么是断路器设计?

背后的想法很简单:

  • 一旦serviceA“知道” serviceB失败,就没有必要提出要求serviceBserviceA 应该尽快返回缓存数据或超时错误。这是电路的开路状态
  • 一旦serviceA“知道” serviceB了,我们就可以关闭电路,以便serviceB再次提出请求。
  • 定期进行新的调用以serviceB查看是否成功返回结果。这种状态是HALF-OPEN。
image
<center>断路器处于打开位置</center>

这就是我们的电路状态图的样子


image
<center>断路器状态图</center>

使用断路器实现

让我们实现一个circuitBreaker进行GET http调用的方法。我们的简单需要三个参数circuitBreaker

  • 在打开电路之前应该发生多少次故障。
  • 一旦电路处于OPEN状态,我们应该重试失败的服务的时间段是多少?
  • 在我们的例子中,API请求的超时。
    有了这些信息,我们就可以创建我们的circuitBreaker课程。
class CircuitBreaker {
  constructor(timeout, failureThreshold, retryTimePeriod) {
    // We start in a closed state hoping that everything is fine
    this.state = 'CLOSED';
    // Number of failures we receive from the depended service before we change the state to 'OPEN'
    this.failureThreshold = failureThreshold;
    // Timeout for the API request.
    this.timeout = timeout;
    // Time period after which a fresh request be made to the dependent
    // service to check if service is up.
    this.retryTimePeriod = retryTimePeriod;
    this.lastFailureTime = null;
    this.failureCount = 0;
  }
}
<center>circuitBreaker类及其构造函数</center>

接下来,让我们实现一个可以调用API的函数serviceB 。

async call(urlToCall) {
    // Determine the current state of the circuit.
    this.setState();
    switch (this.state) {
      case 'OPEN':
      // return  cached response if no the circuit is in OPEN state
        return { data: 'this is stale response' };
      // Make the API request if the circuit is not OPEN
      case 'HALF-OPEN':
      case 'CLOSED':
        try {
          const response = await axios({
            url: urlToCall,
            timeout: this.timeout,
            method: 'get',
          });
          // Yay!! the API responded fine. Lets reset everything.
          this.reset();
          return response;
        } catch (err) {
          // Uh-oh!! the call still failed. Lets update that in our records.
          this.recordFailure();
          throw new Error(err);
        }
      default:
        console.log('This state should never be reached');
        return 'unexpected state in the state machine';
    }
  }
<center>circuitBreaker调用函数</center>

让我们实现所有相关的功能。

// reset all the parameters to the initial state when circuit is initialized
  reset() {
    this.failureCount = 0;
    this.lastFailureTime = null;
    this.state = 'CLOSED';
  }

  // Set the current state of our circuit breaker.
  setState() {
    if (this.failureCount > this.failureThreshold) {
      if ((Date.now() - this.lastFailureTime) > this.retryTimePeriod) {
        this.state = 'HALF-OPEN';
      } else {
        this.state = 'OPEN';
      }
    } else {
      this.state = 'CLOSED';
    }
  }

  recordFailure() {
    this.failureCount += 1;
    this.lastFailureTime = Date.now();
  }
<center>circuitBreaker.js具有关于状态,失败和重置的所有功能</center>

下一步是修改我们的serviceA 。我们将把我们的调用包装在circuitBreaker刚刚创建的内部。

let numberOfRequest = 0;

server.route({
  method: 'GET',
  path: '/data2',
  handler: (request, h) => {
    try {
      return h.response('data2');
    } catch (err) {
      throw Boom.clientTimeout(err);
    }
  },
});

const circuitBreaker = new CircuitBreaker(3000, 5, 2000);


server.route({
  method: 'GET',
  path: '/data',
  handler: async (request, h) => {
    numberOfRequest += 1;
    try {
      console.log('numberOfRequest received on client:', numberOfRequest);
      const response = await circuitBreaker.call('http://0.0.0.0:8000/flakycall');
      // console.log('response is ', response.data);
      return h.response(response.data);
    } catch (err) {
      throw Boom.clientTimeout(err);
    }
  },
});

与以前的代码相关的此代码中需要注意的重要更改:

  • 我们正在初始化circuitBreaker const circuitBreaker = new CircuitBreaker(3000, 5, 2000);
  • 我们通过断路器调用API const response = await circuitBreaker.call(‘http://0.0.0.0:8000/flakycall');

搞定!现在让我们再次运行我们的JMeter的测试,可以我们看到我们serviceA没有崩溃,我们的错误率有了显著下降。

image

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,362评论 5 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,330评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,247评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,560评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,580评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,569评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,929评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,587评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,840评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,596评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,678评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,366评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,945评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,929评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,165评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 43,271评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,403评论 2 342

推荐阅读更多精彩内容