給你介紹下，Hippo4J 動態(tài)線程池基礎架構(gòu)

很多小伙伴知道小編從今年六月份開始，陸陸續(xù)續(xù)開始提交 Hippo4J 動態(tài)線程池項目

經(jīng)過 200+ 的 Commit，也是快要能發(fā)布 1.0.0 正式版本，今天就寫一篇文章正式介紹下 Hippo4J 的項目架構(gòu)

Hippo4J GitHub^[1]：https://github.com/acmenlt/dynamic-threadpool

小伙伴如果訪問 GitHub 速度慢，可以通過改 Host 的方式提高訪問速度，修改 Host 方案^[2]

1. 架構(gòu)設計

簡單來說，Hippo4J 從部署的角度上分為兩種角色：Server 端和 Client 端

Server 端是 Hippo4J 項目打包出的 Java 進程，功能包括用戶權限、線程池監(jiān)控以及執(zhí)行持久化的動作

Client 端指的是我們 SpringBoot 應用，通過引入 Hippo4J Starter Jar 包負責與 Server 端進行交互

比如拉取 Server 端線程池數(shù)據(jù)、動態(tài)更新線程池配置以及采集上報線程池運行時數(shù)據(jù)等

2. 基礎組件

2.1 配置中心（Config）

配置中心位于 Server 端，它的主要作用是監(jiān)控 Server 端線程池配置變更，實時通知到 Client 實例執(zhí)行線程池變更流程

代碼設計基于 Nacos 1.x 版本的 長輪詢以及異步 Servlet 機制 實現(xiàn)

2.2 注冊中心（Discovery）

負責管理 Client 端（單機或集群）注冊到 Server 端的實例，包括不限于實例注冊、續(xù)約、過期剔除 等操作，代碼基于 Eureka 源碼實現(xiàn)

上面的配置中心很容易理解，動態(tài)線程池參數(shù)變更的根本。但是注冊中心是用來做什么的？

注冊中心管理 Client 端注冊的實例，通過這些實例可以 實時獲取線程池的運行時參數(shù)信息

目前的設計是如此，不排除后續(xù)基于 Discovery 做更多的擴展

2.3 控制臺（Console）

對接前端項目，包括不限于以下模塊管理

2.4 抽象工具（Tools）

顧名思義就是將某些工具單獨抽象出來，并以 Module 的形式進行展現(xiàn)，這樣的拆分方式有兩點好處：一是更符合職責分離特性，二是需要用到某塊功能，做到拿來即用

目前已集成兩塊內(nèi)容：

1. log-record-tool：基于 mzt-biz-log^[3] 的操作日志變更記錄組件
2. open-change-tool：監(jiān)控 Hippo4J 項目在 GitHub 的 Star Fork 變更，默認五分鐘內(nèi)有變更則通知

3. 消息通知（Notify）

Hippo4J 內(nèi)置了很多需要通知的事件，比如：線程池參數(shù)變更通知、線程池活躍度報警、拒絕策略執(zhí)行報警以及阻塞隊列容量報警等

目前 Notify 已經(jīng)接入了釘釘，后續(xù)持續(xù)集成企業(yè)微信、郵件、短信等通知渠道；并且，Notify 模塊提供了消息事件的 SPI 方案，可以接受三方自定義的推送

4. Hippo4j-Spring-Boot-Starter

熟悉 SpringBoot 的小伙伴對 Starter 應該不會陌生。Hippo4J 提供以 Starter Jar 包的形式嵌套在應用內(nèi)，負責與 Server 端完成交互

Starter Jar 包推送到 Maven 公共倉庫，目前公共倉庫已存在 0.0.2 版本的 Jar

5. SpringBoot 快速開始

5.1 Server 端啟動

導入 Hippo4J 初始化 SQL 語句^[4]

Hippo4J^[5] 代碼拉至本地，啟動 Server^[6] 模塊下 ServerApplication 應用類

5.2 SpringBoot 引入 Hippo4j Starter

SpringBoot 應用引入 Hippo4j Starter Jar。備注：0.0.2 版本僅是過渡期版本，正式請等待發(fā)布 1.0.0

<dependency>
????<groupId>io.github.acmenltgroupId>
????<artifactId>hippo4j-spring-boot-starterartifactId>
????<version>0.0.2version>
dependency>

SpringBoot 應用添加 Hippo4J 相關配置文件：

spring:
??profiles:
????active:?dev
??application:
????name:?dynamic-threadpool-example
??dynamic:
????thread-pool:
??????notifys:
????????-?type:?DING
??????????url:?https://oapi.dingtalk.com/robot/send?access_token=
??????????#?此處可以選擇自己的釘釘群
??????????token:?4a582a588a161d6e3a1bd1de7eea9ee9f562cdfcbe56b6e72029e7fd512b2eae
??????????#?通知時?@?人員
??????????receives:?'15601166691'
??????#?報警發(fā)送間隔
??????alarm-interval:?30
??????#?服務端地址
??????server-addr:?http://localhost:6691
??????#?租戶?id,?對應?tenant?表
??????namespace:?prescription
??????#?項目?id,?對應?item?表
??????item-id:?${spring.application.name}

添加線程池配置類，動態(tài)線程池支持兩種創(chuàng)建方式

1. DynamicThreadPoolWrapper 包裝器創(chuàng)建，指定線程池標識
2. @DynamicThreadPool 注解修飾 Spring Bean

Spring 后置處理器會掃描這兩種方式創(chuàng)建的 Bean，拿到線程池 ID 調(diào)用 Server 端獲取配置

如果獲取 Server 端配置失敗，根據(jù)默認線程池創(chuàng)建實例

@Configuration
public?class?ThreadPoolConfig?{
????public?static?final?String?MESSAGE_PRODUCE?=?"message-produce";
????public?static?final?String?MESSAGE_CONSUME?=?"message-consume";

????@Bean
????//?{@link?DynamicThreadPoolWrapper}?完成?Server?端訂閱配置功能.
????public?DynamicThreadPoolWrapper?messageCenterDynamicThreadPool()?{
????????return?new?DynamicThreadPoolWrapper(MESSAGE_CONSUME);
????}

????@Bean
????@DynamicThreadPool
????//?通過?{@link?DynamicThreadPool}?修飾?{@link?DynamicThreadPoolExecutor}?完成?Server?端訂閱配置功能.
????//?由動態(tài)線程池注解修飾后,?IOC?容器中保存的是?{@link?DynamicThreadPoolExecutor}
????public?ThreadPoolExecutor?dynamicThreadPoolExecutor()?{
????????return?ThreadPoolBuilder.builder().threadFactory(MESSAGE_PRODUCE).dynamicPool().build();
????}
}

啟動 SpringBoot 應用后，動態(tài)線程池的準備工作就算完成了

5.3 測試線程池動態(tài)變更

通過接口修改線程池中的配置。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
}

接口調(diào)用成功后，觀察 IDEA Client 控制臺日志輸出，日志輸出包括不限于此信息即為成功

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

另外，當 Client 集群部署時，可以選擇修改所有實例或某一實例。修改請求路徑：http://localhost:6691/v1/cs/configs?identify=xxx ，Body 體同上

identify 參數(shù)如何獲??？每一臺 Client 端都會分配到獨一無二的值，并在啟動時進行打印

Client?identity?::?xxxxxx

identify 參數(shù)不傳或為空，會修改該線程池 Client 集群下該線程池所有實例參數(shù)

5.4 報警通知

如果加入了釘釘群（號碼：31764717）的小伙伴，此時就能收到一條釘釘機器人的推送通知，示例如下：

? ? ? ?

? ? ? ? ?

7. 最后

在 GitHub 上，檢驗項目的質(zhì)量如何，Star 數(shù)占了一定因素；從上次 Hippo4J 登上 GitHub Trending 至今，已收獲 400+ Star 數(shù)，進而證明了 Hippo4J 的項目質(zhì)量

隨著時間的推移，更多的小伙伴關注到 Hippo4J 項目，提出了相關的功能建議，以及希望參與項目共建，整體顯得朝氣蓬勃

下圖來自小伙伴的問題以及建議，提的內(nèi)容都非常好 ??????

如果說看了上面的介紹，讓你對 Hippo4J 產(chǎn)生了興趣，通過以下方式聯(lián)系到小編，不僅可以解答你對 Hippo4J 項目的疑惑，同時也接受正向的功能建議

一直以來，Hippo4J 目標一直都是企業(yè)級應用，小編也不斷在向這個方向?qū)R，發(fā)布 1.0 的時間不會太遠

屏幕前的小伙伴，如果覺得項目功能規(guī)劃、代碼設計還不錯的話，辛苦點個 ?? Star ，方便后續(xù)查看

對于這個項目，是否有什么不一樣看法，歡迎在評論區(qū)一起溝通交流～

參考