key) {
- Assert.notNull(key, "key function must not be null");
+ Preconditions.checkNotNull(key, "key function must not be null");
if (CollectionUtils.isEmpty(coll)) {
return Collections.emptyMap();
}
@@ -87,8 +88,8 @@ public static
Map toMap(Collection coll, Function
key) {
public static Map toMap(Collection list,
Function key,
Function value) {
- Assert.notNull(key, "Key function must not be null");
- Assert.notNull(value, "Value function must not be null");
+ Preconditions.checkNotNull(key, "Key function must not be null");
+ Preconditions.checkNotNull(value, "Value function must not be null");
if (CollectionUtils.isEmpty(list)) {
return Collections.emptyMap();
}
@@ -108,7 +109,7 @@ public static Map toMap(Collection list,
public static Map> toListMap(Collection ids,
Collection list,
Function key) {
- Assert.notNull(key, "mapping function must not be null");
+ Preconditions.checkNotNull(key, "mapping function must not be null");
if (CollectionUtils.isEmpty(ids) || CollectionUtils.isEmpty(list)) {
return Collections.emptyMap();
}
@@ -117,4 +118,4 @@ public static Map> toListMap(Collection ids,
return resultMap;
}
-}
+}
\ No newline at end of file
From bfe8fdaac36a69e93ba3240c9b2a60efdaf9d933 Mon Sep 17 00:00:00 2001
From: itcast <17338548613@163.com>
Date: Tue, 16 Jul 2024 15:50:25 +0800
Subject: [PATCH 009/101] =?UTF-8?q?refactor=EF=BC=9A=E6=9B=BF=E6=8D=A2Spri?=
=?UTF-8?q?ng=20ReflectionUtils=E4=B8=BAApacheCommons=20Lang=E7=9A=84Field?=
=?UTF-8?q?Utils?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../dynamictp/common/util/ReflectionUtil.java | 37 ++++++++++++-------
1 file changed, 23 insertions(+), 14 deletions(-)
diff --git a/common/src/main/java/org/dromara/dynamictp/common/util/ReflectionUtil.java b/common/src/main/java/org/dromara/dynamictp/common/util/ReflectionUtil.java
index 520ddb666..68f90f6b7 100644
--- a/common/src/main/java/org/dromara/dynamictp/common/util/ReflectionUtil.java
+++ b/common/src/main/java/org/dromara/dynamictp/common/util/ReflectionUtil.java
@@ -18,8 +18,10 @@
package org.dromara.dynamictp.common.util;
import lombok.val;
+import org.apache.commons.lang3.reflect.FieldUtils;
import org.springframework.util.ReflectionUtils;
+
import java.lang.reflect.Field;
import java.util.Objects;
@@ -38,11 +40,12 @@ public static Object getFieldValue(String fieldName, Object targetObj) {
if (Objects.isNull(field)) {
return null;
}
- val fieldObj = ReflectionUtils.getField(field, targetObj);
- if (Objects.isNull(fieldObj)) {
+ try {
+ val fieldObj = FieldUtils.readField(field, targetObj, true);
+ return fieldObj;
+ } catch (IllegalAccessException e) {
return null;
}
- return fieldObj;
}
public static Object getFieldValue(Class> targetClass, String fieldName, Object targetObj) {
@@ -50,37 +53,43 @@ public static Object getFieldValue(Class> targetClass, String fieldName, Objec
if (Objects.isNull(field)) {
return null;
}
- val fieldObj = ReflectionUtils.getField(field, targetObj);
- if (Objects.isNull(fieldObj)) {
+ try {
+ val fieldObj = FieldUtils.readField(field, targetObj, true);
+ return fieldObj;
+ } catch (IllegalAccessException e) {
return null;
}
- return fieldObj;
}
- public static void setFieldValue(String fieldName, Object targetObj, Object targetVal)
- throws IllegalAccessException {
+ public static void setFieldValue(String fieldName, Object targetObj, Object targetVal) {
val field = getField(targetObj.getClass(), fieldName);
if (Objects.isNull(field)) {
return;
}
- field.set(targetObj, targetVal);
+ try {
+ FieldUtils.writeField(field, targetObj, targetVal, true);
+ } catch (IllegalAccessException e) {
+ e.printStackTrace();
+ }
}
- public static void setFieldValue(Class> targetClass, String fieldName, Object targetObj, Object targetVal)
- throws IllegalAccessException {
+ public static void setFieldValue(Class> targetClass, String fieldName, Object targetObj, Object targetVal) {
val field = getField(targetClass, fieldName);
if (Objects.isNull(field)) {
return;
}
- field.set(targetObj, targetVal);
+ try {
+ FieldUtils.writeField(field, targetObj, targetVal, true);
+ } catch (IllegalAccessException e) {
+ e.printStackTrace();
+ }
}
public static Field getField(Class> targetClass, String fieldName) {
- Field field = ReflectionUtils.findField(targetClass, fieldName);
+ Field field = FieldUtils.getField(targetClass, fieldName, true);
if (Objects.isNull(field)) {
return null;
}
- ReflectionUtils.makeAccessible(field);
return field;
}
}
From 9af03b21944193d7e767a0f13d9661737a20c543 Mon Sep 17 00:00:00 2001
From: itcast <17338548613@163.com>
Date: Tue, 16 Jul 2024 15:53:19 +0800
Subject: [PATCH 010/101] =?UTF-8?q?refactor=EF=BC=9A=E6=9B=BF=E6=8D=A2Spri?=
=?UTF-8?q?ng=20ReflectionUtils=E4=B8=BAApacheCommons=20Lang=E7=9A=84Field?=
=?UTF-8?q?Utils?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../java/org/dromara/dynamictp/common/util/ReflectionUtil.java | 2 --
1 file changed, 2 deletions(-)
diff --git a/common/src/main/java/org/dromara/dynamictp/common/util/ReflectionUtil.java b/common/src/main/java/org/dromara/dynamictp/common/util/ReflectionUtil.java
index 68f90f6b7..c964686a7 100644
--- a/common/src/main/java/org/dromara/dynamictp/common/util/ReflectionUtil.java
+++ b/common/src/main/java/org/dromara/dynamictp/common/util/ReflectionUtil.java
@@ -19,8 +19,6 @@
import lombok.val;
import org.apache.commons.lang3.reflect.FieldUtils;
-import org.springframework.util.ReflectionUtils;
-
import java.lang.reflect.Field;
import java.util.Objects;
From 44560fa5a4a58970b24ab8010ccee46ccd83c4bd Mon Sep 17 00:00:00 2001
From: itcast <17338548613@163.com>
Date: Tue, 16 Jul 2024 16:05:38 +0800
Subject: [PATCH 011/101] =?UTF-8?q?refactor=EF=BC=9A=E6=9B=BF=E6=8D=A2Spri?=
=?UTF-8?q?ng=20NonNull=E4=B8=BAlombok=E7=9A=84NonNull?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../org/dromara/dynamictp/core/executor/eager/TaskQueue.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/java/org/dromara/dynamictp/core/executor/eager/TaskQueue.java b/core/src/main/java/org/dromara/dynamictp/core/executor/eager/TaskQueue.java
index 9dd3331d2..42eb8af67 100644
--- a/core/src/main/java/org/dromara/dynamictp/core/executor/eager/TaskQueue.java
+++ b/core/src/main/java/org/dromara/dynamictp/core/executor/eager/TaskQueue.java
@@ -18,7 +18,7 @@
package org.dromara.dynamictp.core.executor.eager;
import org.dromara.dynamictp.common.queue.VariableLinkedBlockingQueue;
-import org.springframework.lang.NonNull;
+import lombok.NonNull;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.TimeUnit;
From a7f4e3607229a7ca338534ad12792257e9e429f5 Mon Sep 17 00:00:00 2001
From: itcast <17338548613@163.com>
Date: Tue, 16 Jul 2024 16:08:48 +0800
Subject: [PATCH 012/101] =?UTF-8?q?refactor=EF=BC=9A=E6=9B=BF=E6=8D=A2Spri?=
=?UTF-8?q?ng=20CollectionUtils=E4=B8=BAApache=20Commons=20Collections?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../org/dromara/dynamictp/core/handler/CollectorHandler.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/java/org/dromara/dynamictp/core/handler/CollectorHandler.java b/core/src/main/java/org/dromara/dynamictp/core/handler/CollectorHandler.java
index 8275a3bc0..2ea3665d9 100644
--- a/core/src/main/java/org/dromara/dynamictp/core/handler/CollectorHandler.java
+++ b/core/src/main/java/org/dromara/dynamictp/core/handler/CollectorHandler.java
@@ -26,7 +26,7 @@
import org.dromara.dynamictp.core.monitor.collector.MetricsCollector;
import org.dromara.dynamictp.core.monitor.collector.MicroMeterCollector;
import org.dromara.dynamictp.core.monitor.collector.jmx.JMXCollector;
-import org.springframework.util.CollectionUtils;
+import org.apache.commons.collections4.CollectionUtils;
import java.util.List;
import java.util.Map;
From 636a79b63b1b8c181e77a708ec96e1f7244704aa Mon Sep 17 00:00:00 2001
From: itcast <17338548613@163.com>
Date: Tue, 16 Jul 2024 16:13:10 +0800
Subject: [PATCH 013/101] =?UTF-8?q?refactor=EF=BC=9A=E6=9B=BF=E6=8D=A2Spri?=
=?UTF-8?q?ng=20BeanUtils=E4=B8=BAApache=20Commons=20BeanUtils?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../core/monitor/collector/MicroMeterCollector.java | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
diff --git a/core/src/main/java/org/dromara/dynamictp/core/monitor/collector/MicroMeterCollector.java b/core/src/main/java/org/dromara/dynamictp/core/monitor/collector/MicroMeterCollector.java
index 37b7f1d48..b834cea26 100644
--- a/core/src/main/java/org/dromara/dynamictp/core/monitor/collector/MicroMeterCollector.java
+++ b/core/src/main/java/org/dromara/dynamictp/core/monitor/collector/MicroMeterCollector.java
@@ -23,7 +23,7 @@
import org.dromara.dynamictp.common.em.CollectorTypeEnum;
import org.dromara.dynamictp.common.entity.ThreadPoolStats;
import org.dromara.dynamictp.common.util.CommonUtil;
-import org.springframework.beans.BeanUtils;
+import org.apache.commons.beanutils.BeanUtils;
import java.util.ArrayList;
import java.util.List;
@@ -61,7 +61,11 @@ public void collect(ThreadPoolStats threadPoolStats) {
if (Objects.isNull(oldStats)) {
GAUGE_CACHE.put(threadPoolStats.getPoolName(), threadPoolStats);
} else {
- BeanUtils.copyProperties(threadPoolStats, oldStats);
+ try {
+ BeanUtils.copyProperties(oldStats, threadPoolStats);
+ } catch (Exception e) {
+ log.error("Error copying properties", e);
+ }
}
gauge(GAUGE_CACHE.get(threadPoolStats.getPoolName()));
}
From 00fc0460ef63a2bec06516dd37a0174f06d079e5 Mon Sep 17 00:00:00 2001
From: itcast <17338548613@163.com>
Date: Tue, 16 Jul 2024 16:17:54 +0800
Subject: [PATCH 014/101] =?UTF-8?q?refactor=EF=BC=9A=E6=9B=BF=E6=8D=A2Spri?=
=?UTF-8?q?ng=20BeanUtils=E4=B8=BAApache=20Commons=20BeanUtils?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../dynamictp/core/support/ExecutorWrapper.java | 11 ++++++++---
1 file changed, 8 insertions(+), 3 deletions(-)
diff --git a/core/src/main/java/org/dromara/dynamictp/core/support/ExecutorWrapper.java b/core/src/main/java/org/dromara/dynamictp/core/support/ExecutorWrapper.java
index 2b8745ff7..7ddc2f3ba 100644
--- a/core/src/main/java/org/dromara/dynamictp/core/support/ExecutorWrapper.java
+++ b/core/src/main/java/org/dromara/dynamictp/core/support/ExecutorWrapper.java
@@ -27,8 +27,9 @@
import org.dromara.dynamictp.core.notifier.capture.CapturedExecutor;
import org.dromara.dynamictp.core.notifier.manager.AlarmManager;
import org.dromara.dynamictp.core.support.task.wrapper.TaskWrapper;
-import org.springframework.beans.BeanUtils;
+import org.apache.commons.beanutils.BeanUtils;
+import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.concurrent.Executor;
@@ -81,7 +82,7 @@ public class ExecutorWrapper {
/**
* Aware names
*/
- private Set awareNames = Sets.newHashSet();
+ private Set awareNames = new HashSet<>();
private ExecutorWrapper() {
}
@@ -139,7 +140,11 @@ public static ExecutorWrapper of(DtpExecutor executor) {
*/
public ExecutorWrapper capture() {
ExecutorWrapper executorWrapper = new ExecutorWrapper();
- BeanUtils.copyProperties(this, executorWrapper);
+ try {
+ BeanUtils.copyProperties(executorWrapper, this);
+ } catch (Exception e) {
+ throw new RuntimeException("Failed to copy properties", e);
+ }
executorWrapper.executor = new CapturedExecutor(this.getExecutor());
return executorWrapper;
}
From 3a97955ceafe10878339cb9f3e13067975ef1d6a Mon Sep 17 00:00:00 2001
From: itcast <17338548613@163.com>
Date: Tue, 16 Jul 2024 16:21:32 +0800
Subject: [PATCH 015/101] =?UTF-8?q?refactor=EF=BC=9A=E6=9B=BF=E6=8D=A2Spri?=
=?UTF-8?q?ng=20Assert=E4=B8=BAGuava=E7=9A=84Preconditions?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../org/dromara/dynamictp/core/support/ThreadPoolBuilder.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/core/src/main/java/org/dromara/dynamictp/core/support/ThreadPoolBuilder.java b/core/src/main/java/org/dromara/dynamictp/core/support/ThreadPoolBuilder.java
index 5465a69e7..ca2f82e93 100644
--- a/core/src/main/java/org/dromara/dynamictp/core/support/ThreadPoolBuilder.java
+++ b/core/src/main/java/org/dromara/dynamictp/core/support/ThreadPoolBuilder.java
@@ -37,7 +37,7 @@
import org.dromara.dynamictp.core.executor.priority.PriorityDtpExecutor;
import org.dromara.dynamictp.core.reject.RejectHandlerGetter;
import org.dromara.dynamictp.core.support.task.wrapper.TaskWrapper;
-import org.springframework.util.Assert;
+import com.google.common.base.Preconditions;
import java.util.List;
import java.util.Objects;
@@ -578,7 +578,7 @@ public ExecutorService buildWithTtl() {
* @return the newly created DtpExecutor instance
*/
private DtpExecutor buildDtpExecutor(ThreadPoolBuilder builder) {
- Assert.notNull(builder.threadPoolName, "The thread pool name must not be null.");
+ Preconditions.checkNotNull(builder.threadPoolName, "The thread pool name must not be null.");
DtpExecutor dtpExecutor = createInternal(builder);
dtpExecutor.setThreadPoolName(builder.threadPoolName);
dtpExecutor.allowCoreThreadTimeOut(builder.allowCoreThreadTimeOut);
From 2e79723b70bf9314de28d844367afb38b297cb6a Mon Sep 17 00:00:00 2001
From: itcast <17338548613@163.com>
Date: Wed, 17 Jul 2024 14:48:30 +0800
Subject: [PATCH 016/101] =?UTF-8?q?refactor=EF=BC=9A=E6=9B=BF=E6=8D=A2Spri?=
=?UTF-8?q?ng=20Yaml=E4=B8=BASnakeYAML?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../parser/config/YamlConfigParser.java | 19 +++++++++++--------
1 file changed, 11 insertions(+), 8 deletions(-)
diff --git a/common/src/main/java/org/dromara/dynamictp/common/parser/config/YamlConfigParser.java b/common/src/main/java/org/dromara/dynamictp/common/parser/config/YamlConfigParser.java
index af7fd6d2d..7bb19f7b4 100644
--- a/common/src/main/java/org/dromara/dynamictp/common/parser/config/YamlConfigParser.java
+++ b/common/src/main/java/org/dromara/dynamictp/common/parser/config/YamlConfigParser.java
@@ -17,12 +17,10 @@
package org.dromara.dynamictp.common.parser.config;
+import org.apache.commons.lang3.StringUtils;
import org.dromara.dynamictp.common.em.ConfigFileTypeEnum;
import com.google.common.collect.Lists;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.beans.factory.config.YamlPropertiesFactoryBean;
-import org.springframework.core.io.ByteArrayResource;
-
+import org.yaml.snakeyaml.Yaml;
import java.util.Collections;
import java.util.List;
import java.util.Map;
@@ -45,12 +43,17 @@ public List types() {
@Override
public Map