用了很多年Dubbo，連Dubbo線程池監(jiān)控都不知道，覺得自己很厲害？
前言
micrometer 中自帶了很多其他框架的指標(biāo)信息，可以很方便的通過 prometheus 進行采集和監(jiān)控，常用的有 JVM 的信息，Http 請求的信息，Tomcat 線程的信息等。
對于一些比較活躍的框架，有些還是不支持的，比如 Dubbo。如果想監(jiān)控 Dubbo 的一些指標(biāo)，比如線程池的狀況，我們需要手動去擴展，輸出對應(yīng)的線程池指標(biāo)才行。
在這種情況下，肯定是沒什么思路的，因為你不知道怎么去擴展，下面給大家介紹去做一件事情之前的思考，方式方法很重要。
- Dubbo 有沒有現(xiàn)成的實現(xiàn)?
- 參考 micrometer 中指標(biāo)的實現(xiàn)，依葫蘆畫瓢？
Dubbo 有沒有現(xiàn)成的實現(xiàn)?
完整的實現(xiàn)應(yīng)該沒有，至少我還沒用過，也沒有那種去搜索引擎一搜就大把結(jié)果的現(xiàn)狀，于是我在 Dubbo 的 Github 上找到了一個相關(guān)的項目 dubbo-spring-boot-actuator。
https://github.com/apache/dubbo-spring-boot-project/tree/master/dubbo-spring-boot-actuator
dubbo-spring-boot-actuator 看名稱就知道，提供了 Dubbo 相關(guān)的各種信息端點和健康檢查。從這里面也許能發(fā)現(xiàn)點有用的代碼。
果不其然，在介紹頁面中看到了想要的內(nèi)容，線程池的指標(biāo)數(shù)據(jù)，只不過是拼接成了字符串顯示而已。
"threadpool": {
"source": "management.health.dubbo.status.extras",
"status": {
"level": "OK",
"message": "Pool status:OK, max:200, core:200, largest:0, active:0, task:0, service port: 12345",
"description": null
}
}
然后就去翻 dubbo-spring-boot-actuator 的代碼了，沒找到線程池這塊的代碼。后面在 dubbo.jar 中找到了 ThreadPoolStatusChecker 這個類，核心邏輯在這里面。現(xiàn)在已經(jīng)解決了第一個問題，就是獲取到 Dubbo 的線程池對象。
參考 micrometer 中指標(biāo)的實現(xiàn)，依葫蘆畫瓢？
線程池對象能拿到了，各種數(shù)據(jù)也就能獲取了。接下來的問題就是如何暴露出去給 prometheus 采集。
兩種方式，一種是自定義一個新的端點暴露，一種是直接在已有的 prometheus 端點中增加指標(biāo)數(shù)據(jù)的輸出，也就是依葫蘆畫瓢。
看源碼中已經(jīng)有很多 Metrics 的實現(xiàn)了，我們也實現(xiàn)一個 Dubbo 線程池的 Metrics 即可。
上圖框起來的就是一個已經(jīng)存在的線程池 Metrics，可以直接復(fù)用代碼。
實現(xiàn)的主要邏輯就是實現(xiàn)一個 MeterBinder 接口，然后將你需要的指標(biāo)進行輸出即可。于是打算在 bindTo 方法中獲取 Dubbo 的線程池對象，然后輸出指標(biāo)。經(jīng)過測試，在 MeterBinder 實例化的時候 Dubbo 還沒初始化好，拿不到線程池對象，綁定后無法成功輸出指標(biāo)。
后面還是打算采用定時采樣的方式來輸出，自定義一個后臺線程，定時去輸出數(shù)據(jù)?？梢杂?Timer，我這圖簡單就直接 while 循環(huán)了。
/**
* Dubbo線程池指標(biāo)
*
* @author yinjihuan
*/
@Configuration
public class DubboThreadMetrics {
@Autowired
private MeterRegistry meterRegistry;
private final IterableTAG = Collections.singletonList(Tag.of("thread.pool.name", "dubboThreadPool"));
@PostConstruct
public void init() {
new Thread(() -> {
while (true) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
DataStore dataStore = ExtensionLoader.getExtensionLoader(DataStore.class).getDefaultExtension();
Map executors = dataStore.get(Constants.EXECUTOR_SERVICE_COMPONENT_KEY);
for (Map.Entry entry : executors.entrySet()) {
ExecutorService executor = (ExecutorService) entry.getValue();
if (executor instanceof ThreadPoolExecutor) {
ThreadPoolExecutor tp = (ThreadPoolExecutor) executor;
Gauge.builder("dubbo.thread.pool.core.size", tp, ThreadPoolExecutor::getCorePoolSize)
.description("核心線程數(shù)")
.baseUnit("threads")
.register(meterRegistry);
Gauge.builder("dubbo.thread.pool.largest.size", tp, ThreadPoolExecutor::getLargestPoolSize)
.description("歷史最高線程數(shù)")
.baseUnit("threads")
.register(meterRegistry);
Gauge.builder("dubbo.thread.pool.max.size", tp, ThreadPoolExecutor::getMaximumPoolSize)
.description("最大線程數(shù)")
.baseUnit("threads")
.register(meterRegistry);
Gauge.builder("dubbo.thread.pool.active.size", tp, ThreadPoolExecutor::getActiveCount)
.description("活躍線程數(shù)")
.baseUnit("threads")
.register(meterRegistry);
Gauge.builder("dubbo.thread.pool.thread.count", tp, ThreadPoolExecutor::getPoolSize)
.description("當(dāng)前線程數(shù)")
.baseUnit("threads")
.register(meterRegistry);
Gauge.builder("dubbo.thread.pool.queue.size", tp, e -> e.getQueue().size())
.description("隊列大小")
.baseUnit("threads")
.register(meterRegistry);
Gauge.builder("dubbo.thread.pool.taskCount", tp, ThreadPoolExecutor::getTaskCount)
.description("任務(wù)總量")
.baseUnit("threads")
.register(meterRegistry);
Gauge.builder("dubbo.thread.pool.completedTaskCount", tp, ThreadPoolExecutor::getCompletedTaskCount)
.description("已完成的任務(wù)量")
.baseUnit("threads")
.register(meterRegistry);
}
}
}
}).start();
}
}
指標(biāo)信息：
配置線程池圖表
創(chuàng)建一個新的 dashboard 配置圖表，然后新建 panel 配置指標(biāo)信息
圖片
左側(cè)配指標(biāo)信息，右側(cè)選擇對應(yīng)的圖表格式。需要注意的是，如果有多個服務(wù)實例，Metrics 這邊最好是根據(jù)服務(wù)實例來顯示，需要在指標(biāo)后面增加條件，如下：
dubbo_thread_pool_max_size_theads{application="$application", instance=~"$instance"}
圖片
免責(zé)聲明：本文內(nèi)容由21ic獲得授權(quán)后發(fā)布，版權(quán)歸原作者所有，本平臺僅提供信息存儲服務(wù)。文章僅代表作者個人觀點，不代表本平臺立場，如有問題，請聯(lián)系我們，謝謝！
下載文檔
