关于java:动态线程池框架DynamicTp监控及源码解析篇

大家好，动静线程池我的项目 DynamicTp 开源一个多月，目前 400 多 star，阐明还是比拟受欢迎的，当初曾经有一些小伙伴在接入应用或者行将接入应用了，为了我的项目当前更好的倒退迭代，打算出几篇文章来对 DynamicTp 做一些更具体的介绍，有趣味的小伙伴欢送一起参加进来欠缺迭代我的项目。

背景啥的能够看前一篇文章介绍
美团动静线程池实际思路，开源了

感激 star，欢送 pr，业务之余给开源奉献一份力量

gitee 地址：https://gitee.com/yanhom/dynamic-tp

github 地址：https://github.com/lyh200/dynamic-tp

美团动静线程池实际思路，开源了

动静线程池（DynamicTp）之动静调整 Tomcat、Jetty、Undertow 线程池参数篇

1.adapter 模块：次要是适配一些第三方组件的线程池治理，目前曾经实现的有 SpringBoot 内置的三大 web 容器（Tomcat、Jetty、Undertow）的线程池治理，后续可能接入其余罕用组件的线程池治理。

2.common 模块：次要是一些各个模板都会用到的类，解耦依赖，复用代码，大家日常开发中可能也常常会这样做。

3.core 模块：该框架的外围代码都在这个模块里，包含动静调整参数，监控报警，以及串联整个我的项目流程都在此。

4.example 模块：提供一个简略应用示例，不便使用者参照

5.logging 模块：用于配置框架外部日志的输入，目前次要用于输入线程池监控指标数据到指定文件

6.starter 模块：集成各个配置核心实现动静更新配置，目前曾经集成 Nacos、Apollo 两个支流配置核心，使用者也能够参照扩大其余配置核心实现，客户端应用也只需引入相应 starter 依赖就行。

能够看出，我的项目还是比较简单的，相当轻量。配置解析、报警平台、配置核心、监控数据输入、回绝策略等都提供有 SPI 接口供使用者扩大，高度可定制化（自定义实现也能够提 PR 合并到我的项目中供别人应用）。

集体还是有比拟强的代码洁癖的，所以代码这块也还是比拟洁净的（根本没有 warning 提醒），也大量应用一些设计模式优化代码构造，可读性还是比拟强的，能够一起交流学习。

1. 扩大配置解析

目前反对的配置文件格式有 yaml 和 properties，如果要扩大其余类型，参考其余两个实现继承 AbstractConfigParser 类，实现相应办法就行。

2. 扩大报警平台

目前反对的报警平台有钉钉和企业微信，如果要扩大其余平台，参考其余两个实现继承 AbstractNotifier 类，实现相应办法就行。

3. 扩大监控数据输入

目前监控指标数据反对以 JsonLog 输入到指定地位和 MicroMeter 采集两种形式，如果要扩大其余实现，参考其余两个实现继承 AbstractCollector 类，实现相应办法，而后把配置文件中的 collectorType 字段配置该类型就行

4. 扩大配置核心

目前反对的配置核心有 Nacos 和 Apollo 两种，如果要扩大其余实现，比方 ZK、Consul 等能够参考其余两个实现继承 AbstractRefresher 类，实现相应办法就行

对源码感兴趣的敌人能够从 DtpRegistry 这个类动手去读

围绕注册、获取、刷新这三个外围 api 去跟代码

注册有两处，都是在 spring 容器启动时在 Bean 创立的不同阶段执行，对 spring 不相熟的小伙伴轻易能够去浏览下 spring 创立 bean 的源码，代码里也大量应用了 spring 的事件机制做代码解耦

1.spring 容器启动时 DtpPostProcessor 会去注册在代码中通过 @Bean 申明的线程池实例

2.afterPropertiesSet 办法会拉去配置核心配置的线程池而后实例化

刷新

配置核心的 listener 监听到配置文件的变动后，解析配置文件，而后告诉 DtpRegistry 去更新线程池配置，完之后发送变更告诉到配置的平台

监控

服务启动后启动一个定时器去做监控报警，能够看 DtpMonitor 这个类

报警

报警这块代码做了一些形象设计，使用了像模板办法模式等，代码可读性还是挺强的

看完代码之后你就会发现其实我的项目挺简略的，然而实用啊，外围代码也就是在除夕那三天写的。

倡议在配置核心单开一个配置文件，配置文件名称配置到相应字段上。

因为代码始终在迭代中，公布的 maven 依赖可能不是最新的，线上要应用时能够找我确认下依赖版本。

具体应用步骤上篇文章有讲，能够去看
美团动静线程池实际思路，开源了

这个我的项目我感觉最大的长处也就是轻量，因为各个公司应用的组件体系都可能不太一样，所以留有足够多的扩大点让本人来扩大。上面一节次要介绍集成 prometheus+grafana 做监控

这块要讲的是集成 prometheus+grafana 做监控，当时你得装置好 prometheus+grafana，这个就不开展讲了，网上教程很多，测试应用能够间接用 docker 装置，非常简单。

1. 首先配置文件中开启 micrometer 数据采集

   enabledCollect: true
   collectorType: micrometer

2. 我的项目中引入 prometheus 依赖，留神可能有版本不兼容问题，我测试遇到过

  <dependency>
      <groupId>io.micrometer</groupId>
      <artifactId>micrometer-registry-prometheus</artifactId>
      <version>1.8.3</version>
  </dependency>

3. 开启 prometheus 指标采集端点

management:
  metrics:
    export:
      prometheus: 
        enabled: true
  endpoints:
    web:
      exposure:
        include: '*'   # 线上最初不要 *

4. 配置 prometheus 数据采集 job，这块能够去理解下他的 SD 机制（Service Discovery），也就是主动到配置核心发现服务，看你所用的配置核心支不反对这种形式，能够去官网查看，如同是不反对 nacos 的，但能够去 github 看有没有他人提供的实现，ZK，Eureka、Consul 这些是反对的。这里应用 static_configs 形式，简略的指定地址的动态配置

- job_name: 'dynamic-tp'
    metrics_path: '/actuator/prometheus'
    static_configs:
      - targets: ['192.168.2.104:9098']

job 配置后 prometheus 治理台看到如下图所示，阐明曾经开始失常采集指标配置

5. 而后就是配置 grafana 数据可视化，配置如下图，须要该 panel 配置 Json 的能够加我发你，到这里监控就搭建起来了，其实也很简略，而后就能够实时监控线程池数据指标变动了

对我的项目有什么想法或者倡议，能够加我微信交换，或者创立 issues，一起欠缺我的项目

公众号：CodeFox

微信：yanhom1314

关于java:动态线程池框架DynamicTp监控及源码解析篇

我的项目地址

系列文章

代码构造

对于扩大

源码怎么读

接入应用

监控

分割我