feat: starter 和 server 端完成参数交互.

dtp-example/pom.xml

@@ -10,7 +10,7 @@
     </parent>
 
     <artifactId>dtp-example</artifactId>
-    <version>0.0.1-SNAPSHOT</version>
+    <packaging>jar</packaging>
 
     <name>dtp-example</name>
     <description>Demo project for Spring Boot</description>
@@ -25,6 +25,11 @@
             <artifactId>spring-boot-starter</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>

dtp-example/src/main/java/io/dtp/example/config/ThreadPoolConfig.java

@@ -15,7 +15,7 @@ public class ThreadPoolConfig {
 
     @Bean
     public DynamicThreadPoolWrap messageCenterConsumeThreadPool() {
-        return new DynamicThreadPoolWrap("message-consume");
+        return new DynamicThreadPoolWrap("common", "message", "message-consume");
     }
 
 }

dtp-server/src/main/java/io/dtp/server/mapper/RowMapperManager.java

@@ -19,10 +19,11 @@ public final class RowMapperManager {
 
     public static class ConfigAllInfoRowMapper implements RowMapper<ConfigAllInfo> {
 
+        @Override
         public ConfigAllInfo mapRow(ResultSet rs, int rowNum) throws SQLException {
             ConfigAllInfo configAllInfo = new ConfigAllInfo();
-            configAllInfo.setDataId(rs.getString("data_id"));
-            configAllInfo.setGroupId(rs.getString("group_id"));
+            configAllInfo.setTpId(rs.getString("tp_id"));
+            configAllInfo.setItemId(rs.getString("item_id"));
             configAllInfo.setTenant(rs.getString("tenant_id"));
             configAllInfo.setContent(rs.getString("content"));
             configAllInfo.setMd5(rs.getString("md5"));

dtp-server/src/main/java/io/dtp/server/model/ConfigInfoBase.java

@@ -16,14 +16,14 @@ public class ConfigInfoBase implements Serializable {
     private static final long serialVersionUID = -1892597426099265730L;
 
     /**
-     * DataId
+     * TpId
      */
-    private String dataId;
+    private String tpId;
 
     /**
-     * GroupId
+     * ItemId
      */
-    private String groupId;
+    private String itemId;
 
     /**
      * 内容

dtp-server/src/main/java/io/dtp/server/service/impl/ConfigServiceImpl.java

@@ -19,6 +19,7 @@ public class ConfigServiceImpl implements ConfigService {
     @Autowired
     private JdbcTemplate jdbcTemplate;
 
+    @Override
     public ConfigAllInfo findConfigAllInfo(String tpId, String itemId, String tenant) {
         ConfigAllInfo configAllInfo = jdbcTemplate.queryForObject(
                 "select * from config_info where tp_id = ? and item_id = ? and tenant_id = ?",

dtp-spring-boot-starter/pom.xml

@@ -33,7 +33,6 @@
         <dependency>
             <groupId>com.squareup.okhttp3</groupId>
             <artifactId>logging-interceptor</artifactId>
-            <optional>true</optional>
         </dependency>
 
         <dependency>

dtp-spring-boot-starter/src/main/java/io/dtp/starter/config/OkHttpClientConfig.java

@@ -1,5 +1,6 @@
 package io.dtp.starter.config;
 
+import io.dtp.starter.toolkit.HttpClientUtil;
 import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import okhttp3.OkHttpClient;
@@ -37,6 +38,11 @@ public class OkHttpClientConfig {
         return build.build();
     }
 
+    @Bean
+    public HttpClientUtil httpClientUtil() {
+        return new HttpClientUtil();
+    }
+
     /**
      * 支持 Https
      *

dtp-spring-boot-starter/src/main/java/io/dtp/starter/core/ThreadPoolRunListener.java

@@ -55,7 +55,7 @@ public class ThreadPoolRunListener implements ApplicationRunner {
     }
 
     private String buildUrl() {
-        return "http://127.0.0.1/v1/cs/configs";
+        return "http://127.0.0.1:6691/v1/cs/configs";
     }
 
     private String buildOnlyId(DynamicThreadPoolWrap poolWrap) {

dtp-spring-boot-starter/src/main/java/io/dtp/starter/toolkit/HttpClientUtil.java

@@ -16,7 +16,6 @@ import java.util.Map;
  * @date 2021/6/10 13:30
  */
 @Slf4j
-@Component
 public class HttpClientUtil {
 
     @Autowired

dtp-spring-boot-starter/src/main/java/io/dtp/starter/wrap/DynamicThreadPoolWrap.java

@@ -27,19 +27,25 @@ public class DynamicThreadPoolWrap {
     /**
      * 首选服务端线程池, 为空使用默认线程池 {@link CommonThreadPool#getInstance(String)}
      *
+     * @param tenant
+     * @param itemId
      * @param threadPoolId
      */
-    public DynamicThreadPoolWrap(String threadPoolId) {
+    public DynamicThreadPoolWrap(String tenant, String itemId, String threadPoolId) {
+        this.tenant = tenant;
+        this.itemId = itemId;
         this.tpId = threadPoolId;
     }
 
     /**
      * 首选服务端线程池, 为空使用 threadPoolExecutor
      *
+     * @param tenant
+     * @param itemId
      * @param threadPoolId
      * @param threadPoolExecutor
      */
-    public DynamicThreadPoolWrap(String threadPoolId, ThreadPoolExecutor threadPoolExecutor) {
+    public DynamicThreadPoolWrap(String tenant, String itemId, String threadPoolId, ThreadPoolExecutor threadPoolExecutor) {
         this.tpId = threadPoolId;
         this.pool = threadPoolExecutor;
     }

pom.xml

@@ -23,8 +23,9 @@
     </properties>
 
     <modules>
-        <module>dtp-spring-boot-starter</module>
         <module>dtp-server</module>
+        <module>dtp-example</module>
+        <module>dtp-spring-boot-starter</module>
     </modules>
 
     <dependencyManagement>
@@ -72,6 +73,16 @@
                 <groupId>org.springframework.boot</groupId>
                 <artifactId>spring-boot-maven-plugin</artifactId>
             </plugin>
+
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>2.3.2</version>
+                <configuration>
+                    <source>1.8</source>
+                    <target>1.8</target>
+                </configuration>
+            </plugin>
         </plugins>
     </build>