ahdoawhfo/netdisk-fast-download
1
0
Fork 0
mirror of https://github.com/qaiu/netdisk-fast-download.git synced 2026-06-10 23:47:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(performance): CommonUtil initConfig 改为异步非阻塞读取

Browse Source
This commit is contained in:
yukaidi
2026-05-29 00:33:27 +08:00
parent 0dfee8ab22
commit 6dfa770137
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
core/src/main/java/cn/qaiu/vx/core/util/CommonUtil.java
View File

@@ -100,18 +100,21 @@ public class CommonUtil {
} }
/** /**
* 处理其他配置 * 处理其他配置（异步非阻塞方式）
* *
* @param configName configName * @param configName configName
*/ */
public static void initConfig(String configName, Class<?> tClass) { public static void initConfig(String configName, Class<?> tClass) {
URL resource = tClass.getResource("/conf/" + configName); URL resource = tClass.getResource("/conf/" + configName);
if (resource == null) throw new RuntimeException("路径不存在"); if (resource == null) throw new RuntimeException("路径不存在");
Buffer buffer = VertxHolder.getVertxInstance().fileSystem().readFileBlocking(resource.getPath()); VertxHolder.getVertxInstance().fileSystem().readFile(resource.getPath())
JsonObject entries = new JsonObject(buffer); .onSuccess(buffer -> {
Map<String, Object> map = entries.getMap(); JsonObject entries = new JsonObject(buffer);
LocalConstant.put(configName, map); Map<String, Object> map = entries.getMap();
LOGGER.info("读取配置{}成功", configName); LocalConstant.put(configName, map);
LOGGER.info("读取配置{}成功", configName);
})
.onFailure(err -> LOGGER.error("读取配置{}失败", configName, err));
} }
public static <T> Set<T> sortClassSet(Set<Class<? extends T>> set) { public static <T> Set<T> sortClassSet(Set<Class<? extends T>> set) {