博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
SpringCloud学习笔记(12)----Spring Cloud Netflix之Hystrix断路器的流程和原理
阅读量:5339 次
发布时间:2019-06-15

本文共 2032 字,大约阅读时间需要 6 分钟。

    

工作流程(参考:https://github.com/Netflix/Hystrix/wiki/How-it-Works)

  1、 创建一个HystrixCommand或HystrixObservableCommand实例

    第一步就是构建一个HystrixCommand或HystrixObservableCommand实例来向其他的组件发出操作请求,通过构造方法创建实例。

    HystrixCommand:返回一个单响应

    HystrixObservableCommand: 返回一个观察者发出的响应

  2. 这里 有 4个 方法,前两只适用于HystrixCommand不适用于HystrixObservableCommand

    execute():阻塞型方法,返回单个结果(或抛出异常)

    queue(): 异步方法,返回一个Future对象,可以从中取出单个结果(或抛出异常)

    observe(): 返回Observable对象

    toObserve(): 返回Observable对象

  3. 缓存判断

    检查缓存内是否有对应指令的结果,如果有的话,将缓存的结果直接以Observable对象形式返回。

  4. 断路器判断

   检查 Circuit Breakerr的状态如果 Circuit Breaker的状态为开启 Hystrix将不会执行对应指令,而是直接进入失败处理状态(图中 8)。如果Circuit Breaker的状态为关闭,Hystrix会继续执行(图 5)

  5. 线程池、任务队列、信号量的检查 

   确认是否有足够的资源执行操作指令。当线程池和队列(或者是信号量不使用隔离模式的时候 资源满的时候 ,Hystrix将不会执行对应指令并且会直接进入失败处理状态 (图 8)

  6. HystrixObservableCommand.construct()和HystrixCommand.run()

   如果资源充足,Hystrix将会执行操作指令,操作指令的调用最终都会到这两个方法:

   HystrixCommand.run():返回一个响应或者抛出一个异常。

   HystrixObservableCommand.construct(): 返回一个可观测的发出响应(s)或发送一个onError通知

   如果执行指令的时间超时,执行线程会抛出TimeException异常。Hystrix会抛弃结果并直接进入失败状态。如果执行指令成功,Hystrix会进行一系列的数据记录,然后返回执行的结果。

  7. 统计断路器的健康情况

    Hystrix会根据记录的数据来计算失败比率,一旦失败比率达到某一阀值将自动开启Circuit Breaker

  8. 回退

   如果我们再Command中实现了HystrixCommand..getFallback方法(或HystrixObservableCommand.resumeWithFallback())方法,Hystrix会返回对应方法的结果,如果没有实现这些方法,Hystrix仍然会返回一个空的Observable对象,并且可以通过onError来终止并处理错误。

  调用不同的方法放回不同的结果:

  execute(): 将会抛出异常

  queue(): 将会返回一个Future对象,如果调用它的get()方法将会抛出异常。

  observe()和toObservable():都会返回上述的Observable对象

  9. 返回成功

   如果Hystrix执行成功,返回的响应取决于在步骤2中调用命令。

   execute():阻塞型方法,返回单个结果(或抛出异常)

   queue(): 异步方法,返回一个Future对象,可以从中取出单个结果(或抛出异常)

   observe(): 返回Observable对象

   toObserve(): 返回Observable对象

断路器工作原理

  

  断路器开启或者关闭的条件:

     1、 当满足一定的阀值时候 (默认 10 秒内 超过 20 个请求 次数 )

     2、 当失败率达到一定的时候( 默认 10 秒内超过 秒内超过 50%50%50%的请求失败 )

     3、 到达以上阀值 ,断路器将会开启

     4、 当开启的时候 ,所有请求 都不会进行转发

     5、 一段时间之后( 默认是 5秒),这个时候断路器是半开状态, 会让其中一请求进行转发。如果成功断路器会关闭,若失败继续开启。重复 4和 5。

HystrixCircuitBreaker接口

  

 

原文

转载于:https://www.cnblogs.com/xiaoshen666/p/10844202.html

你可能感兴趣的文章
golang里面检测对象是否实现了接口的方法
查看>>
freeswitch编译
查看>>
Validate Binary Search Tree
查看>>
Largest Divisible Subset
查看>>
win8改win7笔记
查看>>
MYSQL 数据导入导出LOAD DATA AND OUTFILE
查看>>
mysql中两表更新时产生的奇葩问题,产生死锁!
查看>>
Python正则表达式
查看>>
celery使用
查看>>
如何在win2003下安装sql2008[多次安装sql2008失败者必看]
查看>>
[C++]C++学习笔记(四)
查看>>
Vue 不睡觉教程1-从最土开始
查看>>
IT技术栈、JAVA技术栈、游戏开发技术栈
查看>>
19.2 TCP程序设计基础
查看>>
5.爬虫 requests库讲解 高级用法
查看>>
对json数据的遍历
查看>>
传美云商系统软件方案详解
查看>>
php 切割图片
查看>>
【转】机器学习资料推荐
查看>>
centos6.9 改系统语言成中文简体
查看>>