2026/4/20 15:19:55
网站建设
项目流程
白云网站制作,wordpress注册文件下载,给网站做网站,wordpress icp备案在哪个文件中使用线程池 ThreadPoolExecutor 过程中你是否有以下痛点呢#xff1f;代码中创建了一个 ThreadPoolExecutor#xff0c;但是不知道那几个核心参数设置多少比较合适凭经验设置参数值#xff0c;上线后发现需要调整#xff0c;改代码重启服务#xff0c;非常麻烦线程池相对开…使用线程池ThreadPoolExecutor过程中你是否有以下痛点呢代码中创建了一个ThreadPoolExecutor但是不知道那几个核心参数设置多少比较合适凭经验设置参数值上线后发现需要调整改代码重启服务非常麻烦线程池相对开发人员来说是个黑盒运行情况不能及时感知到直到出现问题如果你有以上痛点动态可监控线程池DynamicTp或许能帮助到你。最近建了一些工作内推群各大城市都有欢迎各位HR和找工作的小伙伴进群交流群里目前已经收集了不少的工作内推岗位。扫码下发二维码加苏三的微信备注所在城市即可进群。背景如果看过ThreadPoolExecutor的源码大概可以知道它对核心参数基本都有提供set/get方法以及一些扩展方法可以在运行时动态修改、获取相应的值。现在大多数的互联网项目其实都会微服务化部署有一套自己的服务治理体系微服务组件中的分布式配置中心扮演的就是动态修改配置 实时生效的角色。那么我们是否可以结合配置中心来做运行时线程池参数的动态调整呢答案是肯定的而且配置中心相对都是高可用的 使用它也不用过于担心配置推送出现问题这类事儿而且也能减少研发动态线程池组件的难度和工作量。综上可以总结出以下的背景广泛性在 Java 开发中想要提高系统性能线程池已经是一个 90%以上的人都会选择使用的基础工具不确定性项目中可能会创建很多线程池既有 IO 密集型的也有 CPU 密集型的但线程池的参数并不好确定需要有套机制在运行过程中动态去调整参数无感知性线程池运行过程中的各项指标一般感知不到需要有套监控报警机制在事前、事中就能让开发人员感知到线程池的运行状况及时处理高可用性配置变更需要及时推送到客户端需要有高可用的配置管理推送服务配置中心是现在大多数互联网系统都会使用的组件与之结合可以大幅度减少开发量及接入难度简介基于以上背景分析我们对线程池ThreadPoolExecutor做一些扩展增强主要实现以下目标实现对运行中线程池参数的动态修改实时生效实时监控线程池的运行状态触发设置的报警策略时报警报警信息推送办公平台定时采集线程池指标数据配合像 grafana 这种可视化监控平台做大盘监控经过多个版本的迭代目前最新版本 v1.0.9 具有以下特性代码零侵入所有配置都放在配置中心对业务代码零侵入轻量简单基于 SpringBoot 实现引入starter接入只需简单 4 步就可完成顺利 3 分钟搞定高可扩展框架核心功能都提供 SPI 接口供用户自定义个性化实现配置中心、配置文件解析、通知告警、监控数据采集、任务包装等等线上大规模应用参考美团线程池实践美团内部已经有该理论成熟的应用经验多平台通知报警」提供多种报警维度配置变更通知、活性报警、容量阈值报警、拒绝触发报警、任务执行或等待超时报警已支持企业微信、钉钉、飞书、邮件报警同时提供 SPI 接口可自定义扩展实现监控定时采集线程池指标数据支持通过MicroMeter、JsonLog日志输出、Endpoint三种方式可通过 SPI 接口自定义扩展实现任务增强提供任务包装功能实现TaskWrapper接口即可如MdcTaskWrapper、TtlTaskWrapper、SwTraceTaskWrapper可以支持线程池上下文信息传递兼容性JUC 普通线程池和 Spring 中的ThreadPoolTaskExecutor也可以被框架监控Bean定义时加DynamicTp注解即可可靠性框架提供的线程池实现 Spring 生命周期方法可以在 Spring 容器关闭前尽可能多的处理队列中的任务多模式参考 Tomcat 线程池提供了 IO 密集型场景使用的EagerDtpExecutor线程池支持多配置中心基于主流配置中心实现线程池参数动态调整实时生效已支持Nacos、Apollo、Zookeeper、Consul、Etcd同时也提供 SPI 接口可自定义扩展实现中间件线程池管理集成管理常用第三方组件的线程池已集成Tomcat、Jetty、Undertow、Dubbo、RocketMq、Hystrix、Grpc等组件的线程池管理调参、监控报警架构设计框架功能大体可以分为以下几个模块配置变更监听模块服务内部线程池管理模块三方组件线程池管理模块监控模块通知告警模块代码结构adapter 模块主要是适配一些第三方组件的线程池管理目前已经实现的有 SpringBoot 内置的三大 web 容器Tomcat、Jetty、Undertow、Dubbo、RocketMq、Hystrix、Grpc的线程池管理 后续会接入其他常用组件的线程池管理。common 模块主要是一些各个模板都会用到的类解耦依赖复用代码大家日常开发中可能也经常会这样做。core 模块该框架的核心代码都在这个模块里包括动态调整参数监控报警以及串联整个项目流程都在此。example 模块提供一个简单使用示例方便使用者参照extension 模块放一些扩展功能实现比如基于 redis 的流控扩展、邮件发送扩展、skywalking上下文传递扩展等logging 模块用于配置框架内部日志的输出目前主要用于输出线程池监控指标数据到指定文件starter模块提供独立功能模块的依赖封装、自动配置等相关。配置变更监听模块1.监听特定配置中心的指定配置文件已实现Nacos、Apollo、Zookeeper、Consul、Etcd可通过内部提供的SPI接口扩展其他实现。2.解析配置文件内容内置实现yml、properties、json配置文件的解析可通过内部提供的 SPI 接口扩展其他实现3.通知线程池管理模块实现参数的刷新服务内部线程池管理模块1.服务启动时从配置中心拉取配置生成线程池实例注册到内部线程池注册中心以及 Spring 容器中2.接受配置监听模块的刷新事件实现线程池参数的刷新3.代码中通过依赖注入推荐或者DtpRegistry.getDtpExecutor()方法根据线程池名称来获取线程池实例三方组件线程池管理1.服务启动获取第三方中间件的线程池被框架管理起来2.接受参数刷新、指标收集、通知报警事件进行相应的处理监控模块实现监控指标采集以及输出默认提供以下三种方式也可通过内部提供的 SPI 接口扩展其他实现默认实现 JsonLog 输出到磁盘可以自己采集解析日志存储展示MicroMeter采集引入MicroMeter相关依赖暴露相关端点采集指标数据结合Grafana做监控大盘暴雷自定义Endpoint端点dynamic-tp可通过 http 方式实时访问通知告警模块对接办公平台实现通知告警功能已支持钉钉、企微、飞书、邮件可通过内部提供的 SPI 接口扩展其他实现通知告警类型如下线程池主要参数变更通知阻塞队列容量达到设置的告警阈值线程池活性达到设置的告警阈值触发拒绝策略告警格式A/BA该报警项前后两次报警区间累加数量B该报警项累计总数任务执行超时告警格式A/BA该报警项前后两次报警区间累加数量B该报警项累计总数任务等待超时告警格式A/BA该报警项前后两次报警区间累加数量B该报警项累计总数