聊聊dubbo-go的gracefulShutdownFilter
序
本文主要研究一下dubbo-go的gracefulShutdownFilter
gracefulShutdownFilter
dubbo-go-v1.4.2/filter/filter_impl/graceful_shutdown_filter.go
type gracefulShutdownFilter struct {
activeCount int32
shutdownConfig *config.ShutdownConfig
}
- gracefulShutdownFilter定义了activeCount、shutdownConfig属性
init
dubbo-go-v1.4.2/filter/filter_impl/graceful_shutdown_filter.go
func init() {
var consumerFiler = &gracefulShutdownFilter{
shutdownConfig: config.GetConsumerConfig().ShutdownConfig,
}
var providerFilter = &gracefulShutdownFilter{
shutdownConfig: config.GetProviderConfig().ShutdownConfig,
}
extension.SetFilter(constant.CONSUMER_SHUTDOWN_FILTER, func() filter.Filter {
return consumerFiler
})
extension.SetFilter(constant.PROVIDER_SHUTDOWN_FILTER, func() filter.Filter {
return providerFilter
})
}
- init方法分别创建并设置了CONSUMER_SHUTDOWN_FILTER、PROVIDER_SHUTDOWN_FILTER
Invoke
dubbo-go-v1.4.2/filter/filter_impl/graceful_shutdown_filter.go
func (gf *gracefulShutdownFilter) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result {
if gf.rejectNewRequest() {
logger.Info("The application is closing, new request will be rejected.")
return gf.getRejectHandler().RejectedExecution(invoker.GetUrl(), invocation)
}
atomic.AddInt32(&gf.activeCount, 1)
return invoker.Invoke(ctx, invocation)
}
- Invoke方法先判断gracefulShutdownFilter的rejectNewRequest是否为true,若为true则执行getRejectHandler().RejectedExecution,否则执行atomic.AddInt32及invoker.Invoke(ctx, invocation)
OnResponse
dubbo-go-v1.4.2/filter/filter_impl/graceful_shutdown_filter.go
func (gf *gracefulShutdownFilter) OnResponse(ctx context.Context, result protocol.Result, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result {
atomic.AddInt32(&gf.activeCount, -1)
// although this isn't thread safe, it won't be a problem if the gf.rejectNewRequest() is true.
if gf.shutdownConfig != nil && gf.activeCount <= 0 {
gf.shutdownConfig.RequestsFinished = true
}
return result
}
- OnResponse方法先执行atomic.AddInt32(&gf.activeCount, -1),之后判断gf.activeCount是否小于等于0,是的话则标记gf.shutdownConfig.RequestsFinished为true
rejectNewRequest
dubbo-go-v1.4.2/filter/filter_impl/graceful_shutdown_filter.go
func (gf *gracefulShutdownFilter) rejectNewRequest() bool {
if gf.shutdownConfig == nil {
return false
}
return gf.shutdownConfig.RejectRequest
}
- rejectNewRequest方法在shutdownConfig为nil是返回false,否则返回gf.shutdownConfig.RejectRequest的值
getRejectHandler
dubbo-go-v1.4.2/filter/filter_impl/graceful_shutdown_filter.go
func (gf *gracefulShutdownFilter) getRejectHandler() filter.RejectedExecutionHandler {
handler := constant.DEFAULT_KEY
if gf.shutdownConfig != nil && len(gf.shutdownConfig.RejectRequestHandler) > 0 {
handler = gf.shutdownConfig.RejectRequestHandler
}
return extension.GetRejectedExecutionHandler(handler)
}
- getRejectHandler方法在gf.shutdownConfig不为nil且gf.shutdownConfig.RejectRequestHandler长度大于0时设置handler值为gf.shutdownConfig.RejectRequestHandler,之后根据该值执行extension.GetRejectedExecutionHandler
小结
gracefulShutdownFilter定义了activeCount、shutdownConfig属性;其Invoke方法先判断gracefulShutdownFilter的rejectNewRequest是否为true,若为true则执行getRejectHandler().RejectedExecution,否则执行atomic.AddInt32及invoker.Invoke(ctx, invocation);其OnResponse方法先执行atomic.AddInt32(&gf.activeCount, -1),之后判断gf.activeCount是否小于等于0,是的话则标记gf.shutdownConfig.RequestsFinished为true
doc
- graceful_shutdown_filter
- 高性能JavaScript-JS脚本加载与执行对性能的影响
- CSS3伪类和伪元素的特性和区别
- Kafka剖析系列之Benchmark
- 初探React与D3的结合-或许是visualization的新突破?
- Redis 在Centos Linux 上的启动脚本
- 理解JavaScript的临时包装对象
- JavaScript实现私有属性
- 使用LRU算法缓存图片,android 3.0
- 深入理解JavaScript原型:prototype,__proto__和constructor
- Comparable 与 Comparator 浅析
- 必应首页平铺背景图片的实现方案
- 我们是如何优化HAProxy以让其支持200万个并发SSL连接的?
- 【译】《Understanding ECMAScript6》- 第八章-Module
- 【译】《Understanding ECMAScript6》- 第七章-Promise
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- Spring Boot 系列:日志动态配置详解
- Js电子时钟
- 函数的定义和调用
- this指向
- 严格模式
- 闭包与高阶函数
- IDEA设置maven修改settings.xml配置文件无法加载仓库
- 在Linux下如何根据域名自签发OpenSSL证书与常用证书转换 修改openssl.cnf配置文件创建根证书自签发泛域名证书将crt转pem格式生成 p12 格式的
- CAS 原子操作
- FlutterDojo设计之道—状态管理之路(七)
- Kubernetes K8S之存储ConfigMap详解 通过目录创建通过文件创建通过命令行创建通过yaml文件创建当前存在的ConfigMap使用ConfigMap
- Material Components——Shape的处理
- pandas系列 - (一)明细数据汇总简单场景应用
- Spring系列 SpringMVC的请求与数据响应
- PHP代码审计03之实例化任意对象漏洞