From 942de9c430502ff987d42eecff2e9a3c729c7f6b Mon Sep 17 00:00:00 2001 From: yukaidi Date: Fri, 29 May 2026 02:11:35 +0800 Subject: [PATCH] =?UTF-8?q?fix(core):=20ConfigRetriever=20=E6=88=90?= =?UTF-8?q?=E5=8A=9F=E8=B7=AF=E5=BE=84=E4=B9=9F=E8=B0=83=E7=94=A8=20close(?= =?UTF-8?q?)=20=E9=98=B2=E6=AD=A2=E8=B5=84=E6=BA=90=E6=B3=84=E6=BC=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit readConfig() 中 onSuccess 回调未关闭 ConfigRetriever, 文件监听器和底层资源无法释放,现在成功和失败路径均调用 close()。 --- core/src/main/java/cn/qaiu/vx/core/util/ConfigUtil.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/core/src/main/java/cn/qaiu/vx/core/util/ConfigUtil.java b/core/src/main/java/cn/qaiu/vx/core/util/ConfigUtil.java index 1d5cb50..fbcc5b3 100644 --- a/core/src/main/java/cn/qaiu/vx/core/util/ConfigUtil.java +++ b/core/src/main/java/cn/qaiu/vx/core/util/ConfigUtil.java @@ -62,7 +62,10 @@ public class ConfigUtil { // 异步获取配置 // 成功直接完成 promise retriever.getConfig() - .onSuccess(promise::complete) + .onSuccess(config -> { + promise.complete(config); + retriever.close(); + }) .onFailure(err -> { // 配置读取失败,直接返回失败 Future promise.fail(new RuntimeException(