hippo4j-core 添加 web 容器线程池修改. (#141)

hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/starter/config/BootstrapCoreProperties.java

@@ -57,6 +57,22 @@ public class BootstrapCoreProperties implements BootstrapPropertiesInterface {
      */
     private Map<String, String> apollo;
 
+    /**
+     * Tomcat thread pool config.
+     */
+    private WebThreadPoolProperties tomcat;
+
+    /**
+     * Undertow thread pool config.
+     */
+    private WebThreadPoolProperties undertow;
+
+    /**
+     * Jetty thread pool config.
+     * KeepAliveTime is not supported temporarily.
+     */
+    private WebThreadPoolProperties jetty;
+
     /**
      * Notify platforms.
      */

hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/starter/config/DynamicThreadPoolCoreAutoConfiguration.java

@@ -10,6 +10,7 @@ import cn.hippo4j.common.notify.platform.DingSendMessageHandler;
 import cn.hippo4j.common.notify.platform.LarkSendMessageHandler;
 import cn.hippo4j.common.notify.platform.WeChatSendMessageHandler;
 import cn.hippo4j.core.config.UtilAutoConfiguration;
+import cn.hippo4j.core.config.WebThreadPoolConfiguration;
 import cn.hippo4j.core.executor.ThreadPoolNotifyAlarmHandler;
 import cn.hippo4j.core.starter.notify.CoreNotifyConfigBuilder;
 import cn.hippo4j.core.starter.refresher.ApolloRefresherHandler;
@@ -36,7 +37,7 @@ import org.springframework.core.annotation.Order;
 @Configuration
 @AllArgsConstructor
 @EnableConfigurationProperties(BootstrapCoreProperties.class)
-@ImportAutoConfiguration({UtilAutoConfiguration.class})
+@ImportAutoConfiguration({UtilAutoConfiguration.class, WebThreadPoolConfiguration.class})
 @ConditionalOnProperty(prefix = BootstrapCoreProperties.PREFIX, value = "enable", matchIfMissing = true, havingValue = "true")
 public class DynamicThreadPoolCoreAutoConfiguration {
 
@@ -117,5 +118,4 @@ public class DynamicThreadPoolCoreAutoConfiguration {
         return new ApolloRefresherHandler(threadPoolNotifyAlarmHandler, bootstrapCoreProperties);
     }
 
-
 }

hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/starter/config/WebThreadPoolProperties.java

@@ -0,0 +1,29 @@
+package cn.hippo4j.core.starter.config;
+
+import lombok.Data;
+
+/**
+ * Web thread pool properties.
+ *
+ * @author chen.ma
+ * @date 2022/3/11 19:23
+ */
+@Data
+public class WebThreadPoolProperties {
+
+    /**
+     * Core pool size
+     */
+    private Integer corePoolSize;
+
+    /**
+     * Maximum pool size
+     */
+    private Integer maximumPoolSize;
+
+    /**
+     * Keep alive time
+     */
+    private Integer keepAliveTime;
+
+}

hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/starter/refresher/BootstrapCorePropertiesBinderAdapt.java

@@ -11,6 +11,10 @@ import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.bean.copier.CopyOptions;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
+import org.springframework.boot.context.properties.bind.Bindable;
+import org.springframework.boot.context.properties.bind.Binder;
+import org.springframework.boot.context.properties.source.ConfigurationPropertySource;
+import org.springframework.boot.context.properties.source.MapConfigurationPropertySource;
 
 import java.util.List;
 import java.util.Map;
@@ -33,9 +37,8 @@ public class BootstrapCorePropertiesBinderAdapt {
      * @return
      */
     public static BootstrapCoreProperties bootstrapCorePropertiesBinder(Map<Object, Object> configInfo, BootstrapCoreProperties bootstrapCoreProperties) {
-        BootstrapCoreProperties bindableCoreProperties = adapt(configInfo);
-        ;
-        /*try {
+        BootstrapCoreProperties bindableCoreProperties = null;
+        try {
             ConfigurationPropertySource sources = new MapConfigurationPropertySource(configInfo);
             Binder binder = new Binder(sources);
             bindableCoreProperties = binder.bind(PREFIX, Bindable.ofInstance(bootstrapCoreProperties)).get();
@@ -45,7 +48,7 @@ public class BootstrapCorePropertiesBinderAdapt {
             } catch (ClassNotFoundException notEx) {
                 bindableCoreProperties = adapt(configInfo);
             }
-        }*/
+        }
 
         return bindableCoreProperties;
     }