feat: 迁移线程池动态刷新 Config.

config/.gitignore

@@ -0,0 +1,33 @@
+HELP.md
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/

config/pom.xml

@@ -0,0 +1,61 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>io.dynamic-threadpool</groupId>
+        <artifactId>parent</artifactId>
+        <version>1.0.0-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>dynamic-threadpool-config</artifactId>
+    <packaging>jar</packaging>
+
+    <name>${project.artifactId}</name>
+    <description>${project.artifactId}</description>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-boot-starter</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+            <scope>runtime</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>cn.hutool</groupId>
+            <artifactId>hutool-all</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>io.dynamic-threadpool</groupId>
+            <artifactId>dynamic-threadpool-common</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.github.dozermapper</groupId>
+            <artifactId>dozer-core</artifactId>
+        </dependency>
+    </dependencies>
+
+</project>

config/src/main/java/io/dynamic/threadpool/config/config/MyMetaObjectHandler.java

@@ -1,7 +1,7 @@
-package io.dynamic.threadpool.server.config;
+package io.dynamic.threadpool.config.config;
 
 import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
-import io.dynamic.threadpool.server.enums.DelEnum;
+import io.dynamic.threadpool.config.enums.DelEnum;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.ibatis.reflection.MetaObject;
 import org.springframework.stereotype.Component;

config/src/main/java/io/dynamic/threadpool/config/config/MybatisPlusConfig.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.config;
+package io.dynamic.threadpool.config.config;
 
 import com.baomidou.mybatisplus.annotation.DbType;
 import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;

config/src/main/java/io/dynamic/threadpool/config/controller/ConfigController.java

@@ -1,13 +1,13 @@
-package io.dynamic.threadpool.server.controller;
+package io.dynamic.threadpool.config.controller;
 
 import io.dynamic.threadpool.common.constant.Constants;
 import io.dynamic.threadpool.common.web.base.Result;
 import io.dynamic.threadpool.common.web.base.Results;
-import io.dynamic.threadpool.server.model.ConfigAllInfo;
-import io.dynamic.threadpool.server.model.ConfigInfoBase;
-import io.dynamic.threadpool.server.service.biz.ConfigService;
-import io.dynamic.threadpool.server.service.ConfigServletInner;
-import io.dynamic.threadpool.server.toolkit.Md5ConfigUtil;
+import io.dynamic.threadpool.config.model.ConfigAllInfo;
+import io.dynamic.threadpool.config.model.ConfigInfoBase;
+import io.dynamic.threadpool.config.service.biz.ConfigService;
+import io.dynamic.threadpool.config.service.ConfigServletInner;
+import io.dynamic.threadpool.config.toolkit.Md5ConfigUtil;
 import lombok.SneakyThrows;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.util.StringUtils;

config/src/main/java/io/dynamic/threadpool/config/controller/ItemController.java

@@ -1,14 +1,14 @@
-package io.dynamic.threadpool.server.controller;
+package io.dynamic.threadpool.config.controller;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import io.dynamic.threadpool.common.constant.Constants;
 import io.dynamic.threadpool.common.web.base.Result;
 import io.dynamic.threadpool.common.web.base.Results;
-import io.dynamic.threadpool.server.model.biz.item.ItemQueryReqDTO;
-import io.dynamic.threadpool.server.model.biz.item.ItemRespDTO;
-import io.dynamic.threadpool.server.model.biz.item.ItemSaveReqDTO;
-import io.dynamic.threadpool.server.model.biz.item.ItemUpdateReqDTO;
-import io.dynamic.threadpool.server.service.biz.ItemService;
+import io.dynamic.threadpool.config.model.biz.item.ItemQueryReqDTO;
+import io.dynamic.threadpool.config.model.biz.item.ItemRespDTO;
+import io.dynamic.threadpool.config.model.biz.item.ItemSaveReqDTO;
+import io.dynamic.threadpool.config.model.biz.item.ItemUpdateReqDTO;
+import io.dynamic.threadpool.config.service.biz.ItemService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 

config/src/main/java/io/dynamic/threadpool/config/controller/TenantController.java

@@ -1,14 +1,14 @@
-package io.dynamic.threadpool.server.controller;
+package io.dynamic.threadpool.config.controller;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import io.dynamic.threadpool.common.constant.Constants;
 import io.dynamic.threadpool.common.web.base.Result;
 import io.dynamic.threadpool.common.web.base.Results;
-import io.dynamic.threadpool.server.model.biz.tenant.TenantQueryReqDTO;
-import io.dynamic.threadpool.server.model.biz.tenant.TenantRespDTO;
-import io.dynamic.threadpool.server.model.biz.tenant.TenantSaveReqDTO;
-import io.dynamic.threadpool.server.model.biz.tenant.TenantUpdateReqDTO;
-import io.dynamic.threadpool.server.service.biz.TenantService;
+import io.dynamic.threadpool.config.model.biz.tenant.TenantQueryReqDTO;
+import io.dynamic.threadpool.config.model.biz.tenant.TenantRespDTO;
+import io.dynamic.threadpool.config.model.biz.tenant.TenantSaveReqDTO;
+import io.dynamic.threadpool.config.model.biz.tenant.TenantUpdateReqDTO;
+import io.dynamic.threadpool.config.service.biz.TenantService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 

config/src/main/java/io/dynamic/threadpool/config/controller/ThreadPoolController.java

@@ -1,13 +1,13 @@
-package io.dynamic.threadpool.server.controller;
+package io.dynamic.threadpool.config.controller;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import io.dynamic.threadpool.common.constant.Constants;
 import io.dynamic.threadpool.common.web.base.Result;
 import io.dynamic.threadpool.common.web.base.Results;
-import io.dynamic.threadpool.server.model.biz.threadpool.ThreadPoolQueryReqDTO;
-import io.dynamic.threadpool.server.model.biz.threadpool.ThreadPoolRespDTO;
-import io.dynamic.threadpool.server.model.biz.threadpool.ThreadPoolSaveOrUpdateReqDTO;
-import io.dynamic.threadpool.server.service.biz.ThreadPoolService;
+import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolQueryReqDTO;
+import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolRespDTO;
+import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolSaveOrUpdateReqDTO;
+import io.dynamic.threadpool.config.service.biz.ThreadPoolService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 

config/src/main/java/io/dynamic/threadpool/config/enums/DelEnum.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.enums;
+package io.dynamic.threadpool.config.enums;
 
 /**
  * 状态枚举

config/src/main/java/io/dynamic/threadpool/config/event/ConfigDataChangeEvent.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.event;
+package io.dynamic.threadpool.config.event;
 
 import org.springframework.util.StringUtils;
 

config/src/main/java/io/dynamic/threadpool/config/event/Event.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.event;
+package io.dynamic.threadpool.config.event;
 
 import java.io.Serializable;
 import java.util.concurrent.atomic.AtomicLong;

config/src/main/java/io/dynamic/threadpool/config/event/LocalDataChangeEvent.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.event;
+package io.dynamic.threadpool.config.event;
 
 /**
  * Local Data Change Event.

config/src/main/java/io/dynamic/threadpool/config/event/SlowEvent.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.event;
+package io.dynamic.threadpool.config.event;
 
 /**
  * Slow Event.

config/src/main/java/io/dynamic/threadpool/config/mapper/ConfigInfoMapper.java

@@ -1,7 +1,7 @@
-package io.dynamic.threadpool.server.mapper;
+package io.dynamic.threadpool.config.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import io.dynamic.threadpool.server.model.ConfigAllInfo;
+import io.dynamic.threadpool.config.model.ConfigAllInfo;
 import org.apache.ibatis.annotations.Mapper;
 
 /**

config/src/main/java/io/dynamic/threadpool/config/mapper/ItemInfoMapper.java

@@ -1,7 +1,7 @@
-package io.dynamic.threadpool.server.mapper;
+package io.dynamic.threadpool.config.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import io.dynamic.threadpool.server.model.ItemInfo;
+import io.dynamic.threadpool.config.model.ItemInfo;
 import org.apache.ibatis.annotations.Mapper;
 
 /**

config/src/main/java/io/dynamic/threadpool/config/mapper/TenantInfoMapper.java

@@ -1,7 +1,7 @@
-package io.dynamic.threadpool.server.mapper;
+package io.dynamic.threadpool.config.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import io.dynamic.threadpool.server.model.TenantInfo;
+import io.dynamic.threadpool.config.model.TenantInfo;
 import org.apache.ibatis.annotations.Mapper;
 
 /**

config/src/main/java/io/dynamic/threadpool/config/model/CacheItem.java

@@ -1,8 +1,8 @@
-package io.dynamic.threadpool.server.model;
+package io.dynamic.threadpool.config.model;
 
 import io.dynamic.threadpool.common.constant.Constants;
-import io.dynamic.threadpool.server.toolkit.SimpleReadWriteLock;
-import io.dynamic.threadpool.server.toolkit.SingletonRepository;
+import io.dynamic.threadpool.config.toolkit.SimpleReadWriteLock;
+import io.dynamic.threadpool.config.toolkit.SingletonRepository;
 import lombok.Getter;
 import lombok.Setter;
 

config/src/main/java/io/dynamic/threadpool/config/model/ConfigAllInfo.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.model;
+package io.dynamic.threadpool.config.model;
 
 import com.alibaba.fastjson.annotation.JSONField;
 import com.baomidou.mybatisplus.annotation.FieldFill;

config/src/main/java/io/dynamic/threadpool/config/model/ConfigInfo.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.model;
+package io.dynamic.threadpool.config.model;
 
 import lombok.Data;
 

config/src/main/java/io/dynamic/threadpool/config/model/ConfigInfoBase.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.model;
+package io.dynamic.threadpool.config.model;
 
 import com.alibaba.fastjson.annotation.JSONField;
 import com.baomidou.mybatisplus.annotation.IdType;

config/src/main/java/io/dynamic/threadpool/config/model/ItemInfo.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.model;
+package io.dynamic.threadpool.config.model;
 
 import com.baomidou.mybatisplus.annotation.*;
 import lombok.Data;

config/src/main/java/io/dynamic/threadpool/config/model/TenantInfo.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.model;
+package io.dynamic.threadpool.config.model;
 
 import com.baomidou.mybatisplus.annotation.*;
 import lombok.Data;

config/src/main/java/io/dynamic/threadpool/config/model/biz/item/ItemQueryReqDTO.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.model.biz.item;
+package io.dynamic.threadpool.config.model.biz.item;
 
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import lombok.Data;

config/src/main/java/io/dynamic/threadpool/config/model/biz/item/ItemRespDTO.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.model.biz.item;
+package io.dynamic.threadpool.config.model.biz.item;
 
 import lombok.Data;
 

config/src/main/java/io/dynamic/threadpool/config/model/biz/item/ItemSaveReqDTO.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.model.biz.item;
+package io.dynamic.threadpool.config.model.biz.item;
 
 import lombok.Data;
 

config/src/main/java/io/dynamic/threadpool/config/model/biz/item/ItemUpdateReqDTO.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.model.biz.item;
+package io.dynamic.threadpool.config.model.biz.item;
 
 import lombok.Data;
 

config/src/main/java/io/dynamic/threadpool/config/model/biz/tenant/TenantQueryReqDTO.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.model.biz.tenant;
+package io.dynamic.threadpool.config.model.biz.tenant;
 
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import lombok.Data;

config/src/main/java/io/dynamic/threadpool/config/model/biz/tenant/TenantRespDTO.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.model.biz.tenant;
+package io.dynamic.threadpool.config.model.biz.tenant;
 
 import lombok.Data;
 

config/src/main/java/io/dynamic/threadpool/config/model/biz/tenant/TenantSaveReqDTO.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.model.biz.tenant;
+package io.dynamic.threadpool.config.model.biz.tenant;
 
 import lombok.Data;
 

config/src/main/java/io/dynamic/threadpool/config/model/biz/tenant/TenantUpdateReqDTO.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.model.biz.tenant;
+package io.dynamic.threadpool.config.model.biz.tenant;
 
 import lombok.Data;
 

config/src/main/java/io/dynamic/threadpool/config/model/biz/threadpool/ThreadPoolQueryReqDTO.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.model.biz.threadpool;
+package io.dynamic.threadpool.config.model.biz.threadpool;
 
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import lombok.Data;

config/src/main/java/io/dynamic/threadpool/config/model/biz/threadpool/ThreadPoolRespDTO.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.model.biz.threadpool;
+package io.dynamic.threadpool.config.model.biz.threadpool;
 
 import lombok.Data;
 

config/src/main/java/io/dynamic/threadpool/config/model/biz/threadpool/ThreadPoolSaveOrUpdateReqDTO.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.model.biz.threadpool;
+package io.dynamic.threadpool.config.model.biz.threadpool;
 
 import com.alibaba.fastjson.annotation.JSONField;
 import com.baomidou.mybatisplus.annotation.TableField;

config/src/main/java/io/dynamic/threadpool/config/notify/DefaultPublisher.java

@@ -1,8 +1,8 @@
-package io.dynamic.threadpool.server.notify;
+package io.dynamic.threadpool.config.notify;
 
 import cn.hutool.core.collection.ConcurrentHashSet;
-import io.dynamic.threadpool.server.event.Event;
-import io.dynamic.threadpool.server.notify.listener.Subscriber;
+import io.dynamic.threadpool.config.event.Event;
+import io.dynamic.threadpool.config.notify.listener.Subscriber;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.util.CollectionUtils;
 

config/src/main/java/io/dynamic/threadpool/config/notify/DefaultSharePublisher.java

@@ -1,9 +1,9 @@
-package io.dynamic.threadpool.server.notify;
+package io.dynamic.threadpool.config.notify;
 
 import cn.hutool.core.collection.ConcurrentHashSet;
-import io.dynamic.threadpool.server.event.Event;
-import io.dynamic.threadpool.server.event.SlowEvent;
-import io.dynamic.threadpool.server.notify.listener.Subscriber;
+import io.dynamic.threadpool.config.event.Event;
+import io.dynamic.threadpool.config.event.SlowEvent;
+import io.dynamic.threadpool.config.notify.listener.Subscriber;
 
 import java.util.Map;
 import java.util.Set;

config/src/main/java/io/dynamic/threadpool/config/notify/EventPublisher.java

@@ -1,7 +1,7 @@
-package io.dynamic.threadpool.server.notify;
+package io.dynamic.threadpool.config.notify;
 
-import io.dynamic.threadpool.server.event.Event;
-import io.dynamic.threadpool.server.notify.listener.Subscriber;
+import io.dynamic.threadpool.config.event.Event;
+import io.dynamic.threadpool.config.notify.listener.Subscriber;
 
 /**
  * Event publisher.

config/src/main/java/io/dynamic/threadpool/config/notify/NotifyCenter.java

@@ -1,11 +1,11 @@
-package io.dynamic.threadpool.server.notify;
-
-import io.dynamic.threadpool.server.event.Event;
-import io.dynamic.threadpool.server.event.SlowEvent;
-import io.dynamic.threadpool.server.notify.listener.SmartSubscriber;
-import io.dynamic.threadpool.server.notify.listener.Subscriber;
-import io.dynamic.threadpool.server.toolkit.ClassUtil;
-import io.dynamic.threadpool.server.toolkit.MapUtil;
+package io.dynamic.threadpool.config.notify;
+
+import io.dynamic.threadpool.config.event.Event;
+import io.dynamic.threadpool.config.event.SlowEvent;
+import io.dynamic.threadpool.config.notify.listener.SmartSubscriber;
+import io.dynamic.threadpool.config.notify.listener.Subscriber;
+import io.dynamic.threadpool.config.toolkit.ClassUtil;
+import io.dynamic.threadpool.config.toolkit.MapUtil;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.Map;

config/src/main/java/io/dynamic/threadpool/config/notify/listener/SmartSubscriber.java

@@ -1,6 +1,6 @@
-package io.dynamic.threadpool.server.notify.listener;
+package io.dynamic.threadpool.config.notify.listener;
 
-import io.dynamic.threadpool.server.event.Event;
+import io.dynamic.threadpool.config.event.Event;
 
 import java.util.List;
 

config/src/main/java/io/dynamic/threadpool/config/notify/listener/Subscriber.java

@@ -1,6 +1,6 @@
-package io.dynamic.threadpool.server.notify.listener;
+package io.dynamic.threadpool.config.notify.listener;
 
-import io.dynamic.threadpool.server.event.Event;
+import io.dynamic.threadpool.config.event.Event;
 
 import java.util.concurrent.Executor;
 

config/src/main/java/io/dynamic/threadpool/config/service/ConfigCacheService.java

@@ -1,13 +1,13 @@
-package io.dynamic.threadpool.server.service;
+package io.dynamic.threadpool.config.service;
 
 import io.dynamic.threadpool.common.config.ApplicationContextHolder;
 import io.dynamic.threadpool.common.constant.Constants;
 import io.dynamic.threadpool.common.toolkit.Md5Util;
-import io.dynamic.threadpool.server.event.LocalDataChangeEvent;
-import io.dynamic.threadpool.server.model.CacheItem;
-import io.dynamic.threadpool.server.model.ConfigAllInfo;
-import io.dynamic.threadpool.server.notify.NotifyCenter;
-import io.dynamic.threadpool.server.service.biz.ConfigService;
+import io.dynamic.threadpool.config.event.LocalDataChangeEvent;
+import io.dynamic.threadpool.config.model.CacheItem;
+import io.dynamic.threadpool.config.model.ConfigAllInfo;
+import io.dynamic.threadpool.config.notify.NotifyCenter;
+import io.dynamic.threadpool.config.service.biz.ConfigService;
 import org.springframework.util.StringUtils;
 
 import java.util.Objects;

config/src/main/java/io/dynamic/threadpool/config/service/ConfigChangePublisher.java

@@ -1,7 +1,7 @@
-package io.dynamic.threadpool.server.service;
+package io.dynamic.threadpool.config.service;
 
-import io.dynamic.threadpool.server.event.LocalDataChangeEvent;
-import io.dynamic.threadpool.server.notify.NotifyCenter;
+import io.dynamic.threadpool.config.event.LocalDataChangeEvent;
+import io.dynamic.threadpool.config.notify.NotifyCenter;
 
 /**
  * Config Change Publisher.

config/src/main/java/io/dynamic/threadpool/config/service/ConfigServletInner.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.service;
+package io.dynamic.threadpool.config.service;
 
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;

config/src/main/java/io/dynamic/threadpool/config/service/LongPollingService.java

@@ -1,15 +1,15 @@
-package io.dynamic.threadpool.server.service;
+package io.dynamic.threadpool.config.service;
 
 import com.alibaba.fastjson.JSON;
 import io.dynamic.threadpool.common.toolkit.Md5Util;
 import io.dynamic.threadpool.common.web.base.Results;
-import io.dynamic.threadpool.server.event.Event;
-import io.dynamic.threadpool.server.event.LocalDataChangeEvent;
-import io.dynamic.threadpool.server.notify.NotifyCenter;
-import io.dynamic.threadpool.server.notify.listener.Subscriber;
-import io.dynamic.threadpool.server.toolkit.ConfigExecutor;
-import io.dynamic.threadpool.server.toolkit.Md5ConfigUtil;
-import io.dynamic.threadpool.server.toolkit.RequestUtil;
+import io.dynamic.threadpool.config.event.Event;
+import io.dynamic.threadpool.config.event.LocalDataChangeEvent;
+import io.dynamic.threadpool.config.notify.NotifyCenter;
+import io.dynamic.threadpool.config.notify.listener.Subscriber;
+import io.dynamic.threadpool.config.toolkit.ConfigExecutor;
+import io.dynamic.threadpool.config.toolkit.Md5ConfigUtil;
+import io.dynamic.threadpool.config.toolkit.RequestUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;

config/src/main/java/io/dynamic/threadpool/config/service/SwitchService.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.service;
+package io.dynamic.threadpool.config.service;
 
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;

config/src/main/java/io/dynamic/threadpool/config/service/biz/ConfigService.java

@@ -1,6 +1,6 @@
-package io.dynamic.threadpool.server.service.biz;
+package io.dynamic.threadpool.config.service.biz;
 
-import io.dynamic.threadpool.server.model.ConfigAllInfo;
+import io.dynamic.threadpool.config.model.ConfigAllInfo;
 
 /**
  * 服务端配置接口

config/src/main/java/io/dynamic/threadpool/config/service/biz/ConfigServiceImpl.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.service.biz;
+package io.dynamic.threadpool.config.service.biz;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
@@ -7,10 +7,10 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.toolkit.SqlHelper;
 import io.dynamic.threadpool.common.toolkit.ContentUtil;
 import io.dynamic.threadpool.common.toolkit.Md5Util;
-import io.dynamic.threadpool.server.event.LocalDataChangeEvent;
-import io.dynamic.threadpool.server.mapper.ConfigInfoMapper;
-import io.dynamic.threadpool.server.model.ConfigAllInfo;
-import io.dynamic.threadpool.server.service.ConfigChangePublisher;
+import io.dynamic.threadpool.config.event.LocalDataChangeEvent;
+import io.dynamic.threadpool.config.mapper.ConfigInfoMapper;
+import io.dynamic.threadpool.config.model.ConfigAllInfo;
+import io.dynamic.threadpool.config.service.ConfigChangePublisher;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 

config/src/main/java/io/dynamic/threadpool/config/service/biz/ItemService.java

@@ -1,10 +1,10 @@
-package io.dynamic.threadpool.server.service.biz;
+package io.dynamic.threadpool.config.service.biz;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
-import io.dynamic.threadpool.server.model.biz.item.ItemQueryReqDTO;
-import io.dynamic.threadpool.server.model.biz.item.ItemRespDTO;
-import io.dynamic.threadpool.server.model.biz.item.ItemSaveReqDTO;
-import io.dynamic.threadpool.server.model.biz.item.ItemUpdateReqDTO;
+import io.dynamic.threadpool.config.model.biz.item.ItemQueryReqDTO;
+import io.dynamic.threadpool.config.model.biz.item.ItemRespDTO;
+import io.dynamic.threadpool.config.model.biz.item.ItemSaveReqDTO;
+import io.dynamic.threadpool.config.model.biz.item.ItemUpdateReqDTO;
 
 import java.util.List;
 

config/src/main/java/io/dynamic/threadpool/config/service/biz/ItemServiceImpl.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.service.biz;
+package io.dynamic.threadpool.config.service.biz;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -6,15 +6,15 @@ import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.toolkit.SqlHelper;
-import io.dynamic.threadpool.server.enums.DelEnum;
-import io.dynamic.threadpool.server.mapper.ItemInfoMapper;
-import io.dynamic.threadpool.server.model.ItemInfo;
-import io.dynamic.threadpool.server.model.biz.item.ItemQueryReqDTO;
-import io.dynamic.threadpool.server.model.biz.item.ItemRespDTO;
-import io.dynamic.threadpool.server.model.biz.item.ItemSaveReqDTO;
-import io.dynamic.threadpool.server.model.biz.item.ItemUpdateReqDTO;
-import io.dynamic.threadpool.server.model.biz.threadpool.ThreadPoolRespDTO;
-import io.dynamic.threadpool.server.toolkit.BeanUtil;
+import io.dynamic.threadpool.config.enums.DelEnum;
+import io.dynamic.threadpool.config.mapper.ItemInfoMapper;
+import io.dynamic.threadpool.config.model.ItemInfo;
+import io.dynamic.threadpool.config.model.biz.item.ItemQueryReqDTO;
+import io.dynamic.threadpool.config.model.biz.item.ItemRespDTO;
+import io.dynamic.threadpool.config.model.biz.item.ItemSaveReqDTO;
+import io.dynamic.threadpool.config.model.biz.item.ItemUpdateReqDTO;
+import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolRespDTO;
+import io.dynamic.threadpool.config.toolkit.BeanUtil;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;

config/src/main/java/io/dynamic/threadpool/config/service/biz/TenantService.java

@@ -1,10 +1,10 @@
-package io.dynamic.threadpool.server.service.biz;
+package io.dynamic.threadpool.config.service.biz;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
-import io.dynamic.threadpool.server.model.biz.tenant.TenantQueryReqDTO;
-import io.dynamic.threadpool.server.model.biz.tenant.TenantRespDTO;
-import io.dynamic.threadpool.server.model.biz.tenant.TenantSaveReqDTO;
-import io.dynamic.threadpool.server.model.biz.tenant.TenantUpdateReqDTO;
+import io.dynamic.threadpool.config.model.biz.tenant.TenantQueryReqDTO;
+import io.dynamic.threadpool.config.model.biz.tenant.TenantRespDTO;
+import io.dynamic.threadpool.config.model.biz.tenant.TenantSaveReqDTO;
+import io.dynamic.threadpool.config.model.biz.tenant.TenantUpdateReqDTO;
 
 /**
  * 业务接口

config/src/main/java/io/dynamic/threadpool/config/service/biz/TenantServiceImpl.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.service.biz;
+package io.dynamic.threadpool.config.service.biz;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -6,16 +6,16 @@ import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.toolkit.SqlHelper;
-import io.dynamic.threadpool.server.enums.DelEnum;
-import io.dynamic.threadpool.server.mapper.TenantInfoMapper;
-import io.dynamic.threadpool.server.model.TenantInfo;
-import io.dynamic.threadpool.server.model.biz.item.ItemQueryReqDTO;
-import io.dynamic.threadpool.server.model.biz.item.ItemRespDTO;
-import io.dynamic.threadpool.server.model.biz.tenant.TenantQueryReqDTO;
-import io.dynamic.threadpool.server.model.biz.tenant.TenantRespDTO;
-import io.dynamic.threadpool.server.model.biz.tenant.TenantSaveReqDTO;
-import io.dynamic.threadpool.server.model.biz.tenant.TenantUpdateReqDTO;
-import io.dynamic.threadpool.server.toolkit.BeanUtil;
+import io.dynamic.threadpool.config.enums.DelEnum;
+import io.dynamic.threadpool.config.mapper.TenantInfoMapper;
+import io.dynamic.threadpool.config.model.TenantInfo;
+import io.dynamic.threadpool.config.model.biz.item.ItemQueryReqDTO;
+import io.dynamic.threadpool.config.model.biz.item.ItemRespDTO;
+import io.dynamic.threadpool.config.model.biz.tenant.TenantQueryReqDTO;
+import io.dynamic.threadpool.config.model.biz.tenant.TenantRespDTO;
+import io.dynamic.threadpool.config.model.biz.tenant.TenantSaveReqDTO;
+import io.dynamic.threadpool.config.model.biz.tenant.TenantUpdateReqDTO;
+import io.dynamic.threadpool.config.toolkit.BeanUtil;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;

config/src/main/java/io/dynamic/threadpool/config/service/biz/ThreadPoolService.java

@@ -1,9 +1,9 @@
-package io.dynamic.threadpool.server.service.biz;
+package io.dynamic.threadpool.config.service.biz;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
-import io.dynamic.threadpool.server.model.biz.threadpool.ThreadPoolQueryReqDTO;
-import io.dynamic.threadpool.server.model.biz.threadpool.ThreadPoolRespDTO;
-import io.dynamic.threadpool.server.model.biz.threadpool.ThreadPoolSaveOrUpdateReqDTO;
+import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolQueryReqDTO;
+import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolRespDTO;
+import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolSaveOrUpdateReqDTO;
 
 import java.util.List;
 

config/src/main/java/io/dynamic/threadpool/config/service/biz/ThreadPoolServiceImpl.java

@@ -1,15 +1,15 @@
-package io.dynamic.threadpool.server.service.biz;
+package io.dynamic.threadpool.config.service.biz;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.StringUtils;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
-import io.dynamic.threadpool.server.mapper.ConfigInfoMapper;
-import io.dynamic.threadpool.server.model.ConfigAllInfo;
-import io.dynamic.threadpool.server.model.biz.threadpool.ThreadPoolQueryReqDTO;
-import io.dynamic.threadpool.server.model.biz.threadpool.ThreadPoolRespDTO;
-import io.dynamic.threadpool.server.model.biz.threadpool.ThreadPoolSaveOrUpdateReqDTO;
-import io.dynamic.threadpool.server.toolkit.BeanUtil;
+import io.dynamic.threadpool.config.mapper.ConfigInfoMapper;
+import io.dynamic.threadpool.config.model.ConfigAllInfo;
+import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolQueryReqDTO;
+import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolRespDTO;
+import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolSaveOrUpdateReqDTO;
+import io.dynamic.threadpool.config.toolkit.BeanUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 

config/src/main/java/io/dynamic/threadpool/config/toolkit/BeanUtil.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.toolkit;
+package io.dynamic.threadpool.config.toolkit;
 
 import com.github.dozermapper.core.DozerBeanMapperBuilder;
 import com.github.dozermapper.core.Mapper;

config/src/main/java/io/dynamic/threadpool/config/toolkit/ClassUtil.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.toolkit;
+package io.dynamic.threadpool.config.toolkit;
 
 import java.util.Objects;
 

config/src/main/java/io/dynamic/threadpool/config/toolkit/ConfigExecutor.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.toolkit;
+package io.dynamic.threadpool.config.toolkit;
 
 import cn.hutool.core.thread.ThreadFactoryBuilder;
 import io.dynamic.threadpool.common.executor.ExecutorFactory;

config/src/main/java/io/dynamic/threadpool/config/toolkit/MapUtil.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.toolkit;
+package io.dynamic.threadpool.config.toolkit;
 
 import java.util.Map;
 import java.util.Objects;

config/src/main/java/io/dynamic/threadpool/config/toolkit/Md5ConfigUtil.java

@@ -1,9 +1,9 @@
-package io.dynamic.threadpool.server.toolkit;
+package io.dynamic.threadpool.config.toolkit;
 
 import io.dynamic.threadpool.common.toolkit.GroupKey;
 import io.dynamic.threadpool.common.toolkit.Md5Util;
-import io.dynamic.threadpool.server.model.ConfigAllInfo;
-import io.dynamic.threadpool.server.service.ConfigCacheService;
+import io.dynamic.threadpool.config.model.ConfigAllInfo;
+import io.dynamic.threadpool.config.service.ConfigCacheService;
 import org.springframework.util.StringUtils;
 
 import javax.servlet.http.HttpServletRequest;

config/src/main/java/io/dynamic/threadpool/config/toolkit/RequestUtil.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.toolkit;
+package io.dynamic.threadpool.config.toolkit;
 
 import org.springframework.util.StringUtils;
 

config/src/main/java/io/dynamic/threadpool/config/toolkit/SimpleReadWriteLock.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.toolkit;
+package io.dynamic.threadpool.config.toolkit;
 
 /**
  * 简单读写锁.

config/src/main/java/io/dynamic/threadpool/config/toolkit/SingletonRepository.java

@@ -1,4 +1,4 @@
-package io.dynamic.threadpool.server.toolkit;
+package io.dynamic.threadpool.config.toolkit;
 
 import java.util.concurrent.ConcurrentHashMap;
 

server/src/main/java/io/dynamic/threadpool/server/ServerApplication.java

@@ -4,11 +4,8 @@ import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
-@SpringBootApplication(
-        scanBasePackages = {
-                "io.dynamic.threadpool.server", "io.dynamic.threadpool.common.config"
-        })
-@MapperScan("io.dynamic.threadpool.server.mapper")
+@MapperScan("io.dynamic.threadpool.config.mapper")
+@SpringBootApplication(scanBasePackages = "io.dynamic.threadpool")
 public class ServerApplication {
 
     public static void main(String[] args) {