通知限流
通知限流dynamictp大约 2 分钟
推送限流
默认通知告警是基于单机模式的,服务集群每个节点都会产生通知告警信息进行推送,在集群机器数量很多的情况下同时可能会产生大量的通知告警信息,影响使用体验。
1.0.8 版本开始支持集群限流,基于 redis 实现的滑动窗口限流,会限制实际进行推送的节点个数,使用引入以下依赖
SpringBoot1x、2x 用此依赖
<dependency>
<groupId>org.dromara.dynamictp</groupId>
<artifactId>dynamic-tp-spring-boot-starter-extension-limiter-redis</artifactId>
<version>1.2.2</version>
</dependency>
SpringBoot3x 用此依赖
<dependency>
<groupId>org.dromara.dynamictp</groupId>
<artifactId>dynamic-tp-spring-boot-starter-extension-limiter-redis</artifactId>
<version>1.2.2-x</version>
</dependency>
- 通知项配置 clusterLimit 字段
dynamictp:
executors: # 动态线程池配置,省略其他项,具体看上述配置文件
- threadPoolName: dtpExecutor1
taskWrapperNames: ["ttl", "mdc", "swTrace"] # 任务包装器名称,继承TaskWrapper接口
notifyItems: # 报警项,不配置自动会按默认值配置(变更通知、容量报警、活性报警、拒绝报警、任务超时报警)
- type: change # 线程池核心参数变更通知
silencePeriod: 120 # 通知静默时间(单位:s),默认值1,0表示不静默
clusterLimit: 1 # 一个报警窗口内,只允许该配置数量的机器进行推送通知,默认值=1
- type: capacity # 队列容量使用率,报警项类型,查看源码 NotifyTypeEnum枚举类
threshold: 80 # 报警阈值,意思是队列使用率达到70%告警;默认值=70
count: 2 # 在一个统计周期内,如果触发阈值的数量达到 count,则触发报警;默认值=1
period: 30 # 报警统计周期(单位:s),默认值=120
silencePeriod: 0 # 报警静默时间(单位:s),0表示不静默,默认值=120
clusterLimit: 1 # 一个报警窗口内,只允许该配置数量的机器进行推送通知,默认值=1
- 此功能实现使用了责任链设计模式,如果项目中没有引入 redis,也可以自定义限流器,实现 NotifyFilter 接口即可,具体参考 NotifyRedisRateLimiterFilter 的实现