动态线程池框架 DynamicTP

B站影视 日本电影 2025-03-10 09:04 2

摘要:在微服务架构中,线程池作为服务器的核心组件,对于系统的性能和稳定性起着至关重要的作用。传统的线程池配置通常是静态的,这意味着一旦设定,其核心参数(如核心线程数、最大线程数、队列大小等)很难在运行时根据业务的动态变化进行调整。这可能导致在高负载时线程池资源紧张,

在微服务架构中,线程池作为服务器的核心组件,对于系统的性能和稳定性起着至关重要的作用。传统的线程池配置通常是静态的,这意味着一旦设定,其核心参数(如核心线程数、最大线程数、队列大小等)很难在运行时根据业务的动态变化进行调整。这可能导致在高负载时线程池资源紧张,而在低负载时又会造成资源的浪费。为了解决这些问题,DynamicTP 框架应运而生,它为我们提供了强大的动态线程池管理能力,同时还具备完善的监控和告警功能,能够极大地提升系统的性能和稳定性。

DynamicTP 是一个开源的动态线程池框架,它允许开发人员在运行时动态调整线程池的各项参数,并且可以对线程池的运行状态进行实时监控和告警。它基于 Java 的内置线程池机制,如 ThreadPoolExecutor,并在此基础上进行扩展和优化,为开发者提供了更加灵活和智能的线程池管理方案。

官网:https://dynamictp.cn/guide/introduction/background.html

SpringBoot1x、2x 用此依赖

org.dromara.dynamictp dynamic-tp-spring-boot-starter-common 1.1.9.1

下述配置项的值都是随便填写的,请不要直接使用该值,根据自己项目做调整

spring: dynamic: tp: enabled: true # 是否启用 dynamictp,默认true enabledCollect: true # 是否开启监控指标采集,默认true collectorTypes: micrometer,logging # 监控数据采集器类型(logging | micrometer | internal_logging | JMX),默认micrometer logPath: /home/logs/dynamictp/user-center/ # 监控日志数据路径,默认 ${user.home}/logs,采集类型非logging不用配置 monitorInterval: 5 # 监控时间间隔(报警检测、指标采集),默认5s platforms: # 通知报警平台配置 - platform: wechat platformId: 1 # 平台id,自定义 urlKey: 3a700-127-4bd-a798-c53d8b69c # webhook 中的 key receivers: test1,test2 # 接受人企微账号 - platform: ding platformId: 2 # 平台id,自定义 urlKey: f80dad441fcd655438f4a08dcd6a # webhook 中的 access_token secret: SECb5441fa6f375d5b9d21 # 安全设置在验签模式下才的秘钥,非验签模式没有此值 receivers: 18888888888 # 钉钉账号手机号 - platform: lark platformId: 3 urlKey: 0d944ae7-b24a-40 # webhook 中的 token secret: 3a750012874bdac5c3d8b69c # 安全设置在签名校验模式下才的秘钥,非验签模式没有此值 receivers: test1,test2 # 接受人username / openid - platform: email platformId: 4 receivers: 123456@qq.com,789789@qq.com # 收件人邮箱,多个用逗号隔开 executors: # 动态线程池配置,都有默认值,采用默认值的可以不配置该项,减少配置量 - threadPoolName: dtpExecutor1 # 线程池名称,必填 threadPoolAliasName: 测试线程池 # 线程池别名,可选 executorType: common # 线程池类型 common、eager、ordered、scheduled、priority,默认 common corePoolSize: 6 # 核心线程数,默认1 maximumPoolSize: 8 # 最大线程数,默认cpu核数 queueCapacity: 2000 # 队列容量,默认1024 queueType: VariableLinkedBlockingQueue # 任务队列,查看源码QueueTypeEnum枚举类,默认VariableLinkedBlockingQueue rejectedHandlerType: CallerRunsPolicy # 拒绝策略,查看RejectedTypeEnum枚举类,默认AbortPolicy keepAliveTime: 60 # 空闲线程等待超时时间,默认60 threadNamePrefix: test # 线程名前缀,默认dtp allowCoreThreadTimeOut: false # 是否允许核心线程池超时,默认false waitForTasksToCompleteOnShutdown: true # 参考spring线程池设计,优雅关闭线程池,默认true awaitTerminationSeconds: 5 # 优雅关闭线程池时,阻塞等待线程池中任务执行时间,默认3,单位(s) preStartAllCoreThreads: false # 是否预热所有核心线程,默认false runTimeout: 200 # 任务执行超时阈值,单位(ms),默认0(不统计) queueTimeout: 100 # 任务在队列等待超时阈值,单位(ms),默认0(不统计) taskWrapperNames: ["ttl", "mdc"] # 任务包装器名称,继承TaskWrapper接口 notifyEnabled: true # 是否开启报警,默认true platformIds: [1,2] # 报警平台id,不配置默认拿上层platforms配置的所有平台 notifyItems: # 报警项,不配置自动会按默认值(查看源码NotifyItem类)配置(变更通知、容量报警、活性报警、拒绝报警、任务超时报警) - type: change enabled: true - type: capacity # 队列容量使用率,报警项类型,查看源码 NotifyTypeEnum枚举类 enabled: true threshold: 80 # 报警阈值,默认70,意思是队列使用率达到70%告警 platformIds: [2] # 可选配置,本配置优先级 > 所属线程池platformIds > 全局配置platforms interval: 120 # 报警间隔(单位:s),默认120 - type: liveness # 线程池活性 enabled: true threshold: 80 # 报警阈值,默认 70,意思是活性达到70%告警 - type: reject # 触发任务拒绝告警 enabled: true threshold: 100 # 默认阈值10 - type: run_timeout # 任务执行超时告警 enabled: true threshold: 100 # 默认阈值10 - type: queue_timeout # 任务排队超时告警 enabled: true threshold: 100 # 默认阈值10

依赖注入方式使用,优先推荐依赖注入方式,不能使用依赖注入的场景可以使用方式2

@Resourceprivate ThreadPoolExecutor dtpExecutor1;public void exec { dtpExecutor1.execute( -> System.out.println("test"));}

从 DtpRegistry 注册器获取(接口场景可用)

public static void main(String args) { DtpExecutor dtpExecutor = DtpRegistry.getDtpExecutor("dtpExecutor1"); dtpExecutor.execute( -> System.out.println("test"));}

DynamicTP 框架为微服务架构中的线程池管理提供了强大的支持,通过其动态调整参数、监控和告警功能,开发者可以更好地应对复杂多变的业务场景,提升系统的性能和稳定性。在实际开发中,合理使用 DynamicTP 可以有效避免线程池资源的浪费和性能瓶颈,是构建高性能微服务的有力工具。 请注意,在使用 DynamicTP 时,需要根据实际业务需求和系统负载,合理设置线程池的初始参数和告警阈值,以充分发挥其优势。

来源:散文随风想

相关推荐