fix : organize the toolkit, add references and reference sources

hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/ArrayUtil.java

@@ -22,7 +22,8 @@ import cn.hippo4j.common.function.Matcher;
 import java.lang.reflect.Array;
 
 /**
- * Array util.
+ * Array util.<br>
+ * Refer to cn.hutool.core.util.ArrayUtil:<br>
  */
 public class ArrayUtil {
 

hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/BeanUtil.java

@@ -22,7 +22,6 @@ import com.github.dozermapper.core.DozerBeanMapperBuilder;
 import com.github.dozermapper.core.Mapper;
 import lombok.AccessLevel;
 import lombok.NoArgsConstructor;
-import org.springframework.beans.BeanUtils;
 
 import java.beans.IntrospectionException;
 import java.beans.PropertyDescriptor;
@@ -30,7 +29,8 @@ import java.lang.reflect.Method;
 import java.util.*;
 
 /**
- * Bean util.
+ * Bean util.<br>
+ * use com.github.dozermapper
  */
 @NoArgsConstructor(access = AccessLevel.PRIVATE)
 public class BeanUtil {
@@ -73,6 +73,13 @@ public class BeanUtil {
                 .orElse(null);
     }
 
+    /**
+     * map to bean
+     *
+     * @param map         source data
+     * @param clazz       type
+     * @param toCamelCase key convert
+     */
     public static <T> T mapToBean(Map<String, Object> map, Class<T> clazz, boolean toCamelCase) {
         if (clazz == null) {
             return null;

hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/CollectionUtil.java

@@ -21,7 +21,8 @@ import java.util.*;
 import java.util.stream.Collectors;
 
 /**
- * Collection util.
+ * Collection util.<br>
+ * Refer to cn.hutool.core.collection.CollUtil:<br>
  */
 public class CollectionUtil {
 

hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/ContentUtil.java

@@ -46,14 +46,13 @@ public class ContentUtil {
     }
 
     public static String getGroupKey(ThreadPoolParameter parameter) {
-        StringBuilder stringBuilder = new StringBuilder();
+        return StringUtil.createBuilder()
-        String resultStr = stringBuilder.append(parameter.getTpId())
+                .append(parameter.getTpId())
                 .append(Constants.GROUP_KEY_DELIMITER)
                 .append(parameter.getItemId())
                 .append(Constants.GROUP_KEY_DELIMITER)
                 .append(parameter.getTenantId())
                 .toString();
-        return resultStr;
     }
 
     public static String getGroupKey(String... parameters) {

hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/DateUtil.java

@@ -23,9 +23,7 @@ import lombok.NoArgsConstructor;
 import java.text.SimpleDateFormat;
 import java.time.LocalDateTime;
 import java.time.ZoneId;
-import java.time.ZoneOffset;
 import java.util.Date;
-import java.util.SimpleTimeZone;
 import java.util.TimeZone;
 
 /**

hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/FileUtil.java

@@ -23,7 +23,6 @@ import org.springframework.core.io.ClassPathResource;
 
 import java.io.*;
 import java.nio.charset.Charset;
-import java.nio.file.Files;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -52,36 +51,24 @@ public class FileUtil {
         return resultReadStr;
     }
 
+    /**
+     * According to the line read
+     *
+     * @param path    the path
+     * @param charset the charset
+     */
     public static List<String> readLines(String path, Charset charset) {
         List<String> strList = new ArrayList<>();
-        InputStreamReader inputStreamReader = null;
-        BufferedReader bufferedReader = null;
         ClassPathResource classPathResource = new ClassPathResource(path);
-        try {
+        try (
-            inputStreamReader = new InputStreamReader(classPathResource.getInputStream(), charset);
+                InputStreamReader in = new InputStreamReader(classPathResource.getInputStream(), charset);
-            bufferedReader = new BufferedReader(inputStreamReader);
+                BufferedReader reader = new BufferedReader(in)) {
             String line;
-            while ((line = bufferedReader.readLine()) != null) {
+            while ((line = reader.readLine()) != null) {
                 strList.add(line);
             }
         } catch (IOException e) {
-            e.printStackTrace();
+            throw new IllegalException("file read error", e);
-            throw new IllegalException("file read error");
-        } finally {
-            if (inputStreamReader != null) {
-                try {
-                    inputStreamReader.close();
-                } catch (IOException e) {
-                    throw new IllegalException("file read error");
-                }
-            }
-            if (bufferedReader != null) {
-                try {
-                    bufferedReader.close();
-                } catch (IOException e) {
-                    throw new IllegalException("file read error");
-                }
-            }
         }
         return strList;
     }

hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/GroupKey.java

@@ -24,6 +24,7 @@ import static cn.hippo4j.common.constant.Constants.GROUP_KEY_DELIMITER;
 
 /**
  * Group key.
+ * Refer to com.alibaba.nacos.client.config.common.GroupKey:<br>
  */
 public class GroupKey {
 

hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/IdUtil.java

@@ -47,10 +47,28 @@ public class IdUtil {
     }
 
     /**
-     * toString
+     * Returns a {@code String} object representing this {@code UUID}.
      *
-     * @param uuid UUID
+     * <p> The UUID string representation is as described by this BNF:
-     * @return UUID String
+     * <blockquote><pre>
+     * {@code
+     * UUID                   = <time_low> "-" <time_mid> "-"
+     *                          <time_high_and_version> "-"
+     *                          <variant_and_sequence> "-"
+     *                          <node>
+     * time_low               = 4*<hexOctet>
+     * time_mid               = 2*<hexOctet>
+     * time_high_and_version  = 2*<hexOctet>
+     * variant_and_sequence   = 2*<hexOctet>
+     * node                   = 6*<hexOctet>
+     * hexOctet               = <hexDigit><hexDigit>
+     * hexDigit               =
+     *       "0" | "1" | "2" | "3" | "4" | "5" | "6" | "7" | "8" | "9"
+     *       | "a" | "b" | "c" | "d" | "e" | "f"
+     *       | "A" | "B" | "C" | "D" | "E" | "F"
+     * }</pre></blockquote>
+     *
+     * @return  A string representation of this {@code UUID}
      */
     public static String toString(UUID uuid, boolean isSimple) {
         long mostSigBits = uuid.getMostSignificantBits();

hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/Joiner.java

@@ -23,7 +23,8 @@ import java.util.Iterator;
 import java.util.Objects;
 
 /**
- * reference google guava
+ * reference google guava<br>
+ * com.google.common.base.Joiner
  */
 public class Joiner {
 

hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/MapUtil.java

@@ -17,10 +17,7 @@
 
 package cn.hippo4j.common.toolkit;
 
-import java.util.Collection;
+import java.util.*;
-import java.util.Dictionary;
-import java.util.Map;
-import java.util.Objects;
 import java.util.function.BiFunction;
 import java.util.function.Predicate;
 
@@ -151,6 +148,41 @@ public class MapUtil {
         return val;
     }
 
+    /**
+     * Fuzzy matching based on Key.
+     *
+     * @param sourceMap
+     * @param filters
+     * @return
+     */
+    public static List<String> parseMapForFilter(Map<String, ?> sourceMap, String filters) {
+        List<String> resultList = new ArrayList<>();
+        if (CollectionUtil.isEmpty(sourceMap)) {
+            return resultList;
+        }
+        sourceMap.forEach((key, val) -> {
+            if (checkKey(key, filters)) {
+                resultList.add(key);
+            }
+        });
+        return resultList;
+    }
+
+    /**
+     * Match the characters you want to query.
+     *
+     * @param key
+     * @param filters
+     * @return
+     */
+    private static boolean checkKey(String key, String filters) {
+        if (key.indexOf(filters) > -1) {
+            return true;
+        } else {
+            return false;
+        }
+    }
+
     /**
      * remove value, Thread safety depends on whether the Map is a thread-safe Map.
      *

hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/Md5Util.java

@@ -28,6 +28,7 @@ import java.util.List;
 
 /**
  * MD5 util.
+ * Refer to com.alibaba.nacos.common.util.Md5Utils:<br>
  */
 public class Md5Util {
 
@@ -96,16 +97,12 @@ public class Md5Util {
             sb.append(Constants.WORD_SEPARATOR);
             sb.append(dataIdGroupId[1]);
             // if have tenant, then set it
-            if (dataIdGroupId.length == DATA_ID_GROUP_ID_THREE_LEN) {
+            boolean b = (dataIdGroupId.length == DATA_ID_GROUP_ID_THREE_LEN
-                if (StringUtil.isNotBlank(dataIdGroupId[2])) {
+                    || dataIdGroupId.length == DATA_ID_GROUP_ID_FOUR_LEN)
-                    sb.append(Constants.WORD_SEPARATOR);
+                    && StringUtil.isNotBlank(dataIdGroupId[2]);
-                    sb.append(dataIdGroupId[2]);
+            if (b) {
-                }
+                sb.append(Constants.WORD_SEPARATOR);
-            } else if (dataIdGroupId.length == DATA_ID_GROUP_ID_FOUR_LEN) {
+                sb.append(dataIdGroupId[2]);
-                if (StringUtil.isNotBlank(dataIdGroupId[2])) {
-                    sb.append(Constants.WORD_SEPARATOR);
-                    sb.append(dataIdGroupId[2]);
-                }
             }
             sb.append(Constants.LINE_SEPARATOR);
         }

hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/ReflectUtil.java

@@ -29,10 +29,13 @@ import java.util.Arrays;
 import java.util.Map;
 import java.util.Objects;
 import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.ThreadPoolExecutor;
 
 /**
- * Reflect util.
+ * Reflect util.<br>
+ * Refer to cn.hutool.core.util.ReflectUtil:<br>
+ * {@link this#getFieldsDirectly(Class, boolean)} <br>
+ * {@link this#setFieldValue(Object, Field, Object)} <br>
+ * {@link this#getDefaultValue(Class)} <br>
  */
 @NoArgsConstructor(access = AccessLevel.PRIVATE)
 public class ReflectUtil {

hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/StringUtil.java

@@ -21,7 +21,11 @@ import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 
 /**
- * String util.
+ * String util.<br>
+ * Refer to cn.hutool.core.util.StrUtil:<br>
+ * {@link this#toSymbolCase(CharSequence, char)}<br>
+ * {@link this#toCamelCase(CharSequence, char)}<br>
+ * {@link this#subBefore(String, String)}<br>
  */
 public class StringUtil {
 
@@ -53,8 +57,9 @@ public class StringUtil {
 
     /**
      * Returns {@code true} if the given string is null or is the empty string.
-     *
+     * <p>
      * this method has been deprecated, use isEmpty() instead.
+     *
      * @param str
      * @return
      */
@@ -302,7 +307,8 @@ public class StringUtil {
      * StringUtils.split("abc def", " ")  = ["abc", "def"]
      * StringUtils.split("ab:cd:ef", ":") = ["ab", "cd", "ef"]
      * </pre>
-     * @param str the String to parse, may be null
+     *
+     * @param str            the String to parse, may be null
      * @param separatorChars the characters used as the delimiters,
      * @return an array of parsed Strings
      */

hippo4j-common/src/test/java/cn/hippo4j/common/toolkit/MapUtilTest.java

@@ -15,10 +15,8 @@
  * limitations under the License.
  */
 
-package cn.hippo4j.config.toolkit;
+package cn.hippo4j.common.toolkit;
 
-import cn.hippo4j.common.toolkit.Assert;
-import cn.hippo4j.common.toolkit.CollectionUtil;
 import org.junit.Test;
 
 import java.util.HashMap;
@@ -66,9 +64,9 @@ public class MapUtilTest {
 
     @Test
     public void computeIfAbsentNotExistKeyTest() {
-        Map<Object, Object> map = new HashMap<>();
+        Map<String, Object> map = new HashMap<>();
         map.put("abc", "123");
-        BiFunction<String, String, String> mappingFunction = (a, b) -> a + b;
+        BiFunction<String, String, Object> mappingFunction = (a, b) -> a + b;
         try {
             MapUtil.computeIfAbsent(map, null, mappingFunction, "param1", "param2");
         } catch (Exception e) {
@@ -93,9 +91,9 @@ public class MapUtilTest {
 
     @Test
     public void computeIfAbsentNotExistParam1Test() {
-        Map<Object, Object> map = new HashMap<>();
+        Map<String, Object> map = new HashMap<>();
         map.put("abc", "123");
-        BiFunction<String, String, String> mappingFunction = (a, b) -> a + b;
+        BiFunction<String, String, Object> mappingFunction = (a, b) -> a + b;
         try {
             MapUtil.computeIfAbsent(map, "abc", mappingFunction, null, "param2");
         } catch (Exception e) {
@@ -107,9 +105,9 @@ public class MapUtilTest {
 
     @Test
     public void computeIfAbsentNotExistParam2Test() {
-        Map<Object, Object> map = new HashMap<>();
+        Map<String, Object> map = new HashMap<>();
         map.put("abc", "123");
-        BiFunction<String, String, String> mappingFunction = (a, b) -> a + b;
+        BiFunction<String, String, Object> mappingFunction = (a, b) -> a + b;
         try {
             MapUtil.computeIfAbsent(map, "abc", mappingFunction, "param1", null);
         } catch (Exception e) {
@@ -121,18 +119,18 @@ public class MapUtilTest {
 
     @Test
     public void computeIfAbsentValNotNullTest() {
-        Map<Object, Object> map = new HashMap<>();
+        Map<String, Object> map = new HashMap<>();
         map.put("abc", "123");
-        BiFunction<String, String, String> mappingFunction = (a, b) -> a + b;
+        BiFunction<String, String, Object> mappingFunction = (a, b) -> a + b;
         Object ret = MapUtil.computeIfAbsent(map, "abc", mappingFunction, "param1", "param2");
         Assert.isTrue(Objects.equals("123", String.valueOf(ret)));
     }
 
     @Test
     public void computeIfAbsentValIsNullTest() {
-        Map<Object, Object> map = new HashMap<>();
+        Map<String, Object> map = new HashMap<>();
         map.put("abc", "123");
-        BiFunction<String, String, String> mappingFunction = (a, b) -> a + b;
+        BiFunction<String, String, Object> mappingFunction = (a, b) -> a + b;
         Object ret = MapUtil.computeIfAbsent(map, "xyz", mappingFunction, "param1", "param2");
         Assert.isTrue(Objects.equals("param1param2", String.valueOf(ret)));
     }

hippo4j-core/src/main/java/cn/hippo4j/core/proxy/RejectedProxyUtil.java

@@ -17,6 +17,9 @@
 
 package cn.hippo4j.core.proxy;
 
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+
 import java.lang.reflect.Proxy;
 import java.util.concurrent.RejectedExecutionHandler;
 import java.util.concurrent.atomic.AtomicLong;
@@ -24,6 +27,7 @@ import java.util.concurrent.atomic.AtomicLong;
 /**
  * Rejected proxy util.
  */
+@NoArgsConstructor(access = AccessLevel.PRIVATE)
 public class RejectedProxyUtil {
 
     /**
@@ -35,11 +39,10 @@ public class RejectedProxyUtil {
      * @return
      */
     public static RejectedExecutionHandler createProxy(RejectedExecutionHandler rejectedExecutionHandler, String threadPoolId, AtomicLong rejectedNum) {
-        RejectedExecutionHandler rejectedProxy = (RejectedExecutionHandler) Proxy
+        return (RejectedExecutionHandler) Proxy
                 .newProxyInstance(
                         rejectedExecutionHandler.getClass().getClassLoader(),
                         new Class[]{RejectedExecutionHandler.class},
                         new RejectedProxyInvocationHandler(rejectedExecutionHandler, threadPoolId, rejectedNum));
-        return rejectedProxy;
     }
 }

hippo4j-core/src/main/java/cn/hippo4j/core/toolkit/SystemClock.java

@@ -22,7 +22,8 @@ import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicLong;
 
 /**
- * System clock.
+ * System clock.<br>
+ * Refer to cn.hutool.core.date.SystemClock<br>
  */
 public class SystemClock {
 

hippo4j-core/src/main/java/cn/hippo4j/core/toolkit/inet/DynamicThreadPoolAnnotationUtil.java

@@ -18,6 +18,8 @@
 package cn.hippo4j.core.toolkit.inet;
 
 import cn.hippo4j.common.config.ApplicationContextHolder;
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
 import org.springframework.beans.factory.ListableBeanFactory;
 import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
 import org.springframework.beans.factory.support.RootBeanDefinition;
@@ -39,24 +41,23 @@ import java.util.Optional;
  * @author chen.ma
  * @date 2022/1/5 21:15
  */
+@NoArgsConstructor(access = AccessLevel.PRIVATE)
 public class DynamicThreadPoolAnnotationUtil {
 
     /**
      * 根据 {@param beanName} 查询注解 {@param annotationType} 是否存在.
      *
-     * @param beanName
+     * @param beanName       bean name
-     * @param annotationType
+     * @param annotationType annotation class
-     * @param <A>
+     * @param <A>            the Annotation type
-     * @return
      */
     public static <A extends Annotation> A findAnnotationOnBean(String beanName, Class<A> annotationType) {
         AbstractApplicationContext context = (AbstractApplicationContext) ApplicationContextHolder.getInstance();
         ConfigurableListableBeanFactory beanFactory = context.getBeanFactory();
-        A annotation = Optional.ofNullable(beanFactory)
+        return Optional.of(beanFactory)
                 .map(each -> (RootBeanDefinition) beanFactory.getMergedBeanDefinition(beanName))
-                .map(definition -> definition.getResolvedFactoryMethod())
+                .map(RootBeanDefinition::getResolvedFactoryMethod)
                 .map(factoryMethod -> AnnotationUtils.getAnnotation(factoryMethod, annotationType))
                 .orElse(null);
-        return annotation;
     }
 }

hippo4j-core/src/main/java/cn/hippo4j/core/toolkit/inet/InetUtils.java

@@ -35,7 +35,8 @@ import java.util.concurrent.Future;
 import java.util.concurrent.TimeUnit;
 
 /**
- * Inet utils.
+ * Inet utils.<br>
+ * Refer to org.springframework.cloud.commons.util.InetUtils<br>
  */
 public class InetUtils implements Closeable {
 
@@ -80,7 +81,7 @@ public class InetUtils implements Closeable {
                     this.log.trace("Testing interface: " + ifc.getDisplayName());
                     if (ifc.getIndex() < lowest || result == null) {
                         lowest = ifc.getIndex();
-                    } else if (result != null) {
+                    } else {
                         continue;
                     }
                     // @formatter:off

hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/NotifyCenter.java

@@ -17,12 +17,12 @@
 
 package cn.hippo4j.config.notify;
 
+import cn.hippo4j.common.toolkit.MapUtil;
 import cn.hippo4j.config.event.AbstractEvent;
+import cn.hippo4j.config.event.AbstractSlowEvent;
 import cn.hippo4j.config.notify.listener.AbstractSmartSubscriber;
 import cn.hippo4j.config.notify.listener.AbstractSubscriber;
 import cn.hippo4j.config.toolkit.ClassUtil;
-import cn.hippo4j.config.toolkit.MapUtil;
-import cn.hippo4j.config.event.AbstractSlowEvent;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.Map;

hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/service/ConfigCacheService.java

@@ -22,17 +22,12 @@ import cn.hippo4j.common.constant.Constants;
 import cn.hippo4j.common.design.observer.AbstractSubjectCenter;
 import cn.hippo4j.common.design.observer.Observer;
 import cn.hippo4j.common.design.observer.ObserverMessage;
-import cn.hippo4j.common.toolkit.CollectionUtil;
+import cn.hippo4j.common.toolkit.*;
-import cn.hippo4j.common.toolkit.JSONUtil;
-import cn.hippo4j.common.toolkit.Joiner;
-import cn.hippo4j.common.toolkit.Md5Util;
-import cn.hippo4j.common.toolkit.StringUtil;
 import cn.hippo4j.config.event.LocalDataChangeEvent;
 import cn.hippo4j.config.model.CacheItem;
 import cn.hippo4j.config.model.ConfigAllInfo;
 import cn.hippo4j.config.notify.NotifyCenter;
 import cn.hippo4j.config.service.biz.ConfigService;
-import cn.hippo4j.config.toolkit.MapUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.util.StringUtils;
 

hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/service/LongPollingService.java

@@ -17,17 +17,13 @@
 
 package cn.hippo4j.config.service;
 
-import cn.hippo4j.common.toolkit.CollectionUtil;
+import cn.hippo4j.common.toolkit.*;
-import cn.hippo4j.common.toolkit.JSONUtil;
-import cn.hippo4j.common.toolkit.Md5Util;
-import cn.hippo4j.common.toolkit.StringUtil;
 import cn.hippo4j.common.web.base.Results;
 import cn.hippo4j.config.event.AbstractEvent;
 import cn.hippo4j.config.event.LocalDataChangeEvent;
 import cn.hippo4j.config.notify.NotifyCenter;
 import cn.hippo4j.config.notify.listener.AbstractSubscriber;
 import cn.hippo4j.config.toolkit.ConfigExecutor;
-import cn.hippo4j.config.toolkit.MapUtil;
 import cn.hippo4j.config.toolkit.Md5ConfigUtil;
 import cn.hippo4j.config.toolkit.RequestUtil;
 import lombok.SneakyThrows;

hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/toolkit/MapUtil.java

@@ -1,82 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package cn.hippo4j.config.toolkit;
-
-import cn.hippo4j.common.toolkit.CollectionUtil;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
-import java.util.function.BiFunction;
-
-/**
- * Map util.
- */
-public class MapUtil {
-
-    public static Object computeIfAbsent(Map target, Object key, BiFunction mappingFunction, Object param1, Object param2) {
-        Objects.requireNonNull(target, "target");
-        Objects.requireNonNull(key, "key");
-        Objects.requireNonNull(mappingFunction, "mappingFunction");
-        Objects.requireNonNull(param1, "param1");
-        Objects.requireNonNull(param2, "param2");
-        Object val = target.get(key);
-        if (val == null) {
-            Object ret = mappingFunction.apply(param1, param2);
-            target.put(key, ret);
-            return ret;
-        }
-        return val;
-    }
-
-    /**
-     * Fuzzy matching based on Key.
-     *
-     * @param sourceMap
-     * @param filters
-     * @return
-     */
-    public static List<String> parseMapForFilter(Map<String, ?> sourceMap, String filters) {
-        List<String> resultList = new ArrayList<>();
-        if (CollectionUtil.isEmpty(sourceMap)) {
-            return resultList;
-        }
-        sourceMap.forEach((key, val) -> {
-            if (checkKey(key, filters)) {
-                resultList.add(key);
-            }
-        });
-        return resultList;
-    }
-
-    /**
-     * Match the characters you want to query.
-     *
-     * @param key
-     * @param filters
-     * @return
-     */
-    private static boolean checkKey(String key, String filters) {
-        if (key.indexOf(filters) > -1) {
-            return true;
-        } else {
-            return false;
-        }
-    }
-}

hippo4j-spring-boot/hippo4j-config-spring-boot-starter/src/main/java/cn/hippo4j/config/springboot/starter/refresher/AbstractConfigThreadPoolDynamicRefresh.java

@@ -36,11 +36,7 @@ import java.util.concurrent.ExecutorService;
  * Abstract core thread-pool dynamic refresh.
  */
 @Slf4j
-public abstract class AbstractConfigThreadPoolDynamicRefresh
+public abstract class AbstractConfigThreadPoolDynamicRefresh implements ThreadPoolDynamicRefresh, ThreadPoolInitRefresh, InitializingBean {
-        implements
-            ThreadPoolDynamicRefresh,
-            ThreadPoolInitRefresh,
-            InitializingBean {
 
     private final BootstrapConfigPropertiesBinderAdapt bootstrapConfigPropertiesBinderAdapt;