hippo4j

Hippo-4J 通过对 JDK 线程池增强，以及扩展三方框架底层线程池等功能，为业务系统提高线上运行保障能力

springboot java dynamic thread-pool monitor blocking-queue rocketmq dynamic-threadpool resizable

Go to file

chen.ma 2a8f7537b9 feature: 控制台模块添加用户权限功能.		3 years ago
common	optimize: 删除 Result fail 字段.	3 years ago
config	feature: 变更租户、项目和线程池配置表名称.	3 years ago
console	feature: 控制台模块添加用户权限功能.	3 years ago
discovery	Change the directory and use revision.	3 years ago
dynamic-threadpool-spring-boot-starter	feature: 开发线程池报警频率限制, 默认推送间隔五分钟(可通过配置修改).	3 years ago
example	feature: 开发线程池报警频率限制, 默认推送间隔五分钟(可通过配置修改).	3 years ago
server	feature: 添加用户权限 Mapper 扫描包目录.	3 years ago
tools	feature: 抽象通用组件, 源码阅读者可以很方便集成到各自项目.	3 years ago
.gitignore	first commit	4 years ago
LICENSE	Change license.	3 years ago
README.md	Update README.md	3 years ago
pom.xml	feature: 根 Pom 添加 Auth 模块.	3 years ago

README.md

Unescape Escape

🔥 动态线程池（DTP）系统，包含 Server 端及 SpringBoot Client 端需引入的 Starter.

为什么写这个项目？

美团线程池文章介绍中，因为业务对线程池参数没有合理配置，触发过几起生产事故，进而引发了一系列思考。最终决定封装线程池动态参数调整，扩展线程池监控以及消息报警等功能

在开源平台找了挺多动态线程池项目，从功能性以及健壮性而言，个人感觉不满足企业级应用

因为对动态线程池比较感兴趣，加上想写一个有意义的项目，所以决定自己来造一个轻量级的轮子

想给项目起一个简单易记的名字，类似于 Eureka、Nacos、Redis；后来和朋友商量，决定以动物命名：Hippo

它解决了什么问题？

线程池在业务系统应该都有使用到，帮助业务流程提升效率以及管理线程，多数场景应用于大量的异步任务处理

虽然线程池提供了我们许多便利，但也并非尽善尽美，比如下面这些问题就无法很好解决

如果线程池的配置涉及到上述问题，那么就有可能需要发布业务系统来解决；如果发布后参数仍不合理，继续发布......

Hippo 很好解决了这个问题，它将业务中所有线程池统一管理，遇到上述问题不需要发布系统就可以替换线程池参数

它有什么特性？

应用系统中线程池并不容易管理。参考美团的设计，Hippo 按照租户、项目、线程池的维度划分。再加上系统权限，让不同的开发、管理人员负责自己系统的线程池操作

举个例子，小编在一家公司的公共组件团队，团队中负责消息、短链接网关等项目。公共组件是租户，消息或短链接就是项目

模块	模块名称	注释
dynamic-threadpool-auth	用户权限	-
dynamic-threadpool-common	公共模块	-
dynamic-threadpool-config	配置中心	提供线程池准实时更新功能
dynamic-threadpool-console	控制台	对接前端项目
dynamic-threadpool-discovery	注册中心	提供线程池项目实例注册、续约、下线等功能
dynamic-threadpool-spring-boot-starter	SpringBoot Starter	-
dynamic-threadpool-example	示例项目	-
dynamic-threadpool-server	服务端	Server 集成各组件
dynamic-threadpool-tools	抽象工具类	操作日志等组件

Hippo 除去动态修改线程池，还包含实时查看线程池运行时指标、负载报警、配置日志管理等

如何运行 Demo？

目前动态线程池功能已经完成，可以直接把代码拉到本地运行。导入 Hippo 初始化 SQL 语句

启动 dynamic-threadpool-server 模块下 ServerApplication 应用类
启动 dynamic-threadpool-example 模块下 ExampleApplication 应用类

通过接口修改线程池中的配置。HTTP POST 路径：http://localhost:6691/v1/cs/configs ，Body 请求体如下：

{
    "ignore": "tenantId、itemId、tpId 代表唯一线程池，请不要修改",
    "tenantId": "prescription",
    "itemId": "dynamic-threadpool-example",
    "tpId": "message-produce",
    "coreSize": 10,
    "maxSize": 15,
    "queueType": 9,
    "capacity": 100,
    "keepAliveTime": 10,
    "rejectedType": 3,
    "isAlarm": 0,
    "capacityAlarm": 81,
    "livenessAlarm": 82
}

接口调用成功后，观察 dynamic-threadpool-example 控制台日志输出，日志输出包括不限于此信息即为成功

[🔥 MESSAGE-PRODUCE] Changed thread pool. coreSize :: [11=>10], maxSize :: [15=>15], queueType :: [9=>9]
capacity :: [100=>100], keepAliveTime :: [10000=>10000], rejectedType :: [7=>7]

现阶段已集成钉钉消息推送，后续会持续接入企业微信、邮箱、飞书、短信等通知渠道。可以通过添加钉钉群体验消息推送，群号：31764717