-
@@ -36,53 +33,57 @@
-## 这个项目做什么？ +## 为什么写这个项目？ -动态线程池（Dynamic-ThreadPool），下面简称 DTP 系统 +[美团线程池文章](https://tech.meituan.com/2020/04/02/java-pooling-pratice-in-meituan.html "美团线程池文章") 介绍中，因为业务对线程池参数没有合理配置，触发过几起生产事故，进而引发了一系列思考。最终决定封装线程池动态参数调整，扩展线程池监控以及消息报警等功能 -[美团线程池文章](https://tech.meituan.com/2020/04/02/java-pooling-pratice-in-meituan.html) 介绍中，因为业务对线程池参数没有合理配置，触发过几起生产事故，进而引发了一系列思考。最终决定封装线程池动态参数调整，扩展线程池监控以及消息报警等功能 +在开源平台找了挺多动态线程池项目，从功能性以及健壮性而言，个人感觉不满足企业级应用 -笔者不喜欢重复造轮子，因为美团并没有开源动态线程池系统，所以选择造一个轻量级的轮子 +因为对动态线程池比较感兴趣，加上想写一个有意义的项目，所以决定自己来造一个轻量级的轮子 +想给项目起一个简单易记的名字，类似于 Eureka、Nacos、Redis；后来和朋友商量，决定以动物命名：**Hippo（河马）** + +```java +├── dynamic-threadpool +│ ├── dynamic-threadpool-common -- 公共模块 +│ ├── dynamic-threadpool-config -- 配置中心 +│ ├── dynamic-threadpool-console -- 控制台 +│ ├── dynamic-threadpool-discovery -- 注册中心 +│ ├── dynamic-threadpool-spring-boot-starter -- Client 依赖组件 +│ ├── dynamic-threadpool-example -- 示例项目 +│ └── dynamic-threadpool-server -- 服务端 +│ └── dynamic-threadpool-tools -- 抽象工具类 +```
## 它解决了什么问题？ -线程池在业务系统应该都有使用到，帮助业务流程提升效率以及管理线程 - -但是线程池也并非尽善尽美。比如下面这些问题就无法很好解决： +线程池在业务系统应该都有使用到，帮助业务流程提升效率以及管理线程，多数场景应用于大量的异步任务处理 -1. 核心线程过小，阻塞队列过小，最大线程过小，**导致接口频繁抛出拒绝策略异常** -2. 核心线程过小，阻塞队列过小，最大线程过大，**导致线程调度开销增大，处理速度下降** -3. 核心线程过小，阻塞队列过大，导致任务堆积，**接口响应或者程序执行时间拉长** -4. 核心线程过大，**导致线程池内空闲线程过多，过多的占用系统资源**，造成资源浪费 +虽然线程池提供了我们许多便利，但也并非尽善尽美，比如下面这些问题就无法很好解决 -如果线程池的配置涉及到上述问题，那么就有可能需要发布业务系统来解决；如果发布后参数仍不合理，继续发布...... + -DTP 系统很好解决了这个问题，它将业务中所有线程池统一管理，遇到上述问题不需要发布系统就可以替换线程池参数 +
-另外，支持看线程池运行实时状态。如果监控发现线程池负载、队列负载以及拒绝策略指标异常，判断参数是否合理，可以及时排查问题以及修复 +如果线程池的配置涉及到上述问题，那么就有可能需要发布业务系统来解决；如果发布后参数仍不合理，继续发布...... +Hippo 很好解决了这个问题，它将业务中所有线程池统一管理，遇到上述问题不需要发布系统就可以替换线程池参数 +
## 它有什么特性？ -应用系统中线程池并不容易管理。为此，DTP 项目按照租户、项目、线程池的维度划分。再加上系统权限，让不同的开发、管理人员负责自己系统的线程池操作 - -举个例子，笔者在一家公司的公共组件团队，团队中负责消息、短链接网关等项目。公共组件是租户，消息或短链接就是项目 - -从功能性上来说，DTP 系统是对标美团文章中所介绍的。所以，DTP 系统除去动态修改线程池，还包含实时查看线程池运行时指标、负载报警、配置日志管理等。具体功能如下图 - - - +应用系统中线程池并不容易管理。参考美团的设计，Hippo 按照租户、项目、线程池的维度划分。再加上系统权限，让不同的开发、管理人员负责自己系统的线程池操作 +举个例子，小编在一家公司的公共组件团队，团队中负责消息、短链接网关等项目。公共组件是租户，消息或短链接就是项目 -笔者并没有接触过美团线程池的具体功能，只是在文章上看了功能介绍，所以在完成路径上会有所差池 - +Hippo 除去动态修改线程池，还包含实时查看线程池运行时指标、负载报警、配置日志管理等。具体功能如下图 +
@@ -90,14 +91,12 @@ DTP 系统很好解决了这个问题，它将业务中所有线程池统一管 目前动态线程池功能已经完成，可以直接把代码拉到本地运行。项目中数据库是作者 ECS Docker 搭建，大家直接使用即可 -1. 启动 dynamic-threadpool-server 模块下 ServerApplication 应用类 -2. 启动 dynamic-threadpool-example 模块下 ExampleApplication 应用类 - - +1. 启动 `dynamic-threadpool-server` 模块下 ServerApplication 应用类 +2. 启动 `dynamic-threadpool-example` 模块下 ExampleApplication 应用类
-通过接口修改线程池中的配置。HTTP POST 路径：http://localhost:6691/v1/cs/configs ，Body 请求体如下： +通过接口修改线程池中的配置。HTTP POST 路径：http://localhost:6691/v1/cs/configs，Body 请求体如下： ```json { @@ -119,7 +118,6 @@ DTP 系统很好解决了这个问题，它将业务中所有线程池统一管
- 接口调用成功后，观察 dynamic-threadpool-example 控制台日志输出，日志输出包括不限于此信息即为成功 ```tex @@ -129,7 +127,7 @@ capacity :: [100=>100], keepAliveTime :: [10000=>10000], rejectedType :: [7=>7]
-现阶段仅集成钉钉消息推送，后续会持续接入企业微信、邮箱、飞书、短信等通知渠道 +现阶段已集成钉钉消息推送，后续会持续接入企业微信、邮箱、飞书、短信等通知渠道。可以通过添加钉钉群体验消息推送，群号：31764717
