diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/BootstrapProperties.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/BootstrapProperties.java index 1da444e9..061cb077 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/BootstrapProperties.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/BootstrapProperties.java @@ -25,9 +25,6 @@ import org.springframework.boot.context.properties.ConfigurationProperties; /** * Bootstrap properties. - * - * @author chen.ma - * @date 2021/6/22 09:14 */ @Slf4j @Getter diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/DiscoveryConfiguration.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/DiscoveryConfiguration.java index 78990169..3e08e87c 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/DiscoveryConfiguration.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/DiscoveryConfiguration.java @@ -37,9 +37,6 @@ import static cn.hippo4j.core.toolkit.IdentifyUtil.CLIENT_IDENTIFICATION_VALUE; /** * Dynamic threadPool discovery config. - * - * @author chen.ma - * @date 2021/8/6 21:35 */ @AllArgsConstructor public class DiscoveryConfiguration { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/DynamicThreadPoolAutoConfiguration.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/DynamicThreadPoolAutoConfiguration.java index 58ec9f9e..49c6195d 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/DynamicThreadPoolAutoConfiguration.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/DynamicThreadPoolAutoConfiguration.java @@ -59,9 +59,6 @@ import org.springframework.core.env.ConfigurableEnvironment; /** * Dynamic thread-pool auto-configuration. - * - * @author chen.ma - * @date 2021/6/22 09:20 */ @Configuration @AllArgsConstructor diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/HttpClientConfiguration.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/HttpClientConfiguration.java index 690680c5..42b55fb8 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/HttpClientConfiguration.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/HttpClientConfiguration.java @@ -32,9 +32,6 @@ import java.util.concurrent.TimeUnit; /** * Http client config. - * - * @author chen.ma - * @date 2021/6/10 13:28 */ public class HttpClientConfiguration { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/NettyClientConfiguration.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/NettyClientConfiguration.java index 1ac2a0fa..9790f5ad 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/NettyClientConfiguration.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/NettyClientConfiguration.java @@ -25,9 +25,6 @@ import org.springframework.context.annotation.Bean; /** * Netty ClientCon figuration - * - * @author lk - * @date 2022/6/18 */ @ConditionalOnProperty(prefix = BootstrapProperties.PREFIX, name = "report-type", matchIfMissing = false, havingValue = "netty") public class NettyClientConfiguration { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/condition/PrometheusMonitorCondition.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/condition/PrometheusMonitorCondition.java deleted file mode 100644 index 7bde825f..00000000 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/condition/PrometheusMonitorCondition.java +++ /dev/null @@ -1,37 +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.springboot.starter.config.condition; - -import cn.hippo4j.common.toolkit.StringUtil; -import cn.hippo4j.springboot.starter.config.BootstrapProperties; -import com.example.monitor.base.MonitorTypeEnum; -import org.springframework.context.annotation.Condition; -import org.springframework.context.annotation.ConditionContext; -import org.springframework.core.type.AnnotatedTypeMetadata; - -/** - * Prometheus monitor condition. - */ -public class PrometheusMonitorCondition implements Condition { - - @Override - public boolean matches(ConditionContext context, AnnotatedTypeMetadata metadata) { - String collectType = context.getEnvironment().getProperty(BootstrapProperties.PREFIX + ".collect-type", ""); - return StringUtil.isNotEmpty(collectType) && collectType.contains(MonitorTypeEnum.PROMETHEUS.name().toLowerCase()) ? true : false; - } -} diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/BaseThreadDetailStateHandler.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/BaseThreadDetailStateHandler.java index 303cedf0..43b143a3 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/BaseThreadDetailStateHandler.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/BaseThreadDetailStateHandler.java @@ -33,11 +33,7 @@ import java.util.concurrent.ThreadPoolExecutor; /** * Base thread detail state handler. * - *

The Java 8 implementation is temporarily provided, - * {@link ThreadDetailState} interface can be customized. - * - * @author chen.ma - * @date 2022/1/9 13:01 + *

The Java 8 implementation is temporarily provided, {@link ThreadDetailState} interface can be customized. */ @Slf4j public class BaseThreadDetailStateHandler implements ThreadDetailState { @@ -62,7 +58,6 @@ public class BaseThreadDetailStateHandler implements ThreadDetailState { if (CollectionUtil.isEmpty(workers)) { return resultThreadState; } - for (Object worker : workers) { Thread thread; try { @@ -75,7 +70,6 @@ public class BaseThreadDetailStateHandler implements ThreadDetailState { log.error("Reflection get worker thread exception. Worker :: {}", worker, ex); continue; } - long threadId = thread.getId(); String threadName = thread.getName(); String threadStatus = thread.getState().name(); diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/CacheData.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/CacheData.java index 48b7e867..f3663751 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/CacheData.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/CacheData.java @@ -28,9 +28,6 @@ import java.util.concurrent.CopyOnWriteArrayList; /** * Cache data. - * - * @author chen.ma - * @date 2021/6/22 20:46 */ @Slf4j public class CacheData { @@ -66,7 +63,6 @@ public class CacheData { if (null == listener) { throw new IllegalArgumentException("Listener is null."); } - ManagerListenerWrapper managerListenerWrap = new ManagerListenerWrapper(md5, listener); if (listeners.addIfAbsent(managerListenerWrap)) { log.info("Add listener status :: ok, thread pool id :: {}, listeners count :: {}", tpId, listeners.size()); @@ -87,7 +83,6 @@ public class CacheData { wrap.setLastCallMd5(md5); listener.receiveConfigInfo(content); }; - try { listener.getExecutor().execute(runnable); } catch (Exception ex) { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ClientWorker.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ClientWorker.java index fd175e4e..b8e9edf9 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ClientWorker.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ClientWorker.java @@ -38,9 +38,6 @@ import static cn.hippo4j.common.constant.Constants.*; /** * Client worker. - * - * @author chen.ma - * @date 2021/6/20 18:34 */ @Slf4j public class ClientWorker { @@ -109,7 +106,6 @@ public class ClientWorker { List cacheDataList = new ArrayList(); List inInitializingCacheList = new ArrayList(); cacheMap.forEach((key, val) -> cacheDataList.add(val)); - List changedTpIds = checkUpdateDataIds(cacheDataList, inInitializingCacheList); for (String groupKey : changedTpIds) { String[] keys = groupKey.split(GROUP_KEY_DELIMITER_TRANSLATION); @@ -121,12 +117,10 @@ public class ClientWorker { CacheData cacheData = cacheMap.get(tpId); String poolContent = ContentUtil.getPoolContent(JSONUtil.parseObject(content, ThreadPoolParameterInfo.class)); cacheData.setContent(poolContent); - } catch (Exception ex) { - // ignore - log.error("Failed to get the latest thread pool configuration.", ex); + } catch (Exception ignored) { + log.error("Failed to get the latest thread pool configuration.", ignored); } } - for (CacheData cacheData : cacheDataList) { if (!cacheData.isInitializing() || inInitializingCacheList .contains(GroupKey.getKeyTenant(cacheData.tpId, cacheData.itemId, cacheData.tenantId))) { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ConfigEmptyAnalyzer.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ConfigEmptyAnalyzer.java index fdc5dd9b..4b46886b 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ConfigEmptyAnalyzer.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ConfigEmptyAnalyzer.java @@ -23,9 +23,6 @@ import org.springframework.boot.diagnostics.FailureAnalysis; /** * Config empty analyzer. - * - * @author chen.ma - * @date 2021/11/28 21:59 */ public class ConfigEmptyAnalyzer extends AbstractFailureAnalyzer { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ConfigService.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ConfigService.java index 6975ced1..86afab74 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ConfigService.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ConfigService.java @@ -19,9 +19,6 @@ package cn.hippo4j.springboot.starter.core; /** * Config service. - * - * @author chen.ma - * @date 2021/6/21 21:49 */ public interface ConfigService { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/DiscoveryClient.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/DiscoveryClient.java index 247ca276..6da7a64f 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/DiscoveryClient.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/DiscoveryClient.java @@ -17,7 +17,6 @@ package cn.hippo4j.springboot.starter.core; -import cn.hippo4j.adapter.base.ThreadPoolAdapter; import cn.hippo4j.common.api.ClientCloseHookExecute; import cn.hippo4j.common.config.ApplicationContextHolder; import cn.hippo4j.common.constant.Constants; @@ -32,7 +31,6 @@ import cn.hutool.core.util.StrUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.DisposableBean; -import java.util.Map; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.TimeUnit; @@ -41,9 +39,6 @@ import static cn.hippo4j.common.constant.Constants.BASE_PATH; /** * Discovery client. - * - * @author chen.ma - * @date 2021/7/13 21:51 */ @Slf4j public class DiscoveryClient implements DisposableBean { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/Listener.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/Listener.java index 5c75e22a..f1f8b880 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/Listener.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/Listener.java @@ -21,9 +21,6 @@ import java.util.concurrent.Executor; /** * Listener. - * - * @author chen.ma - * @date 2021/6/22 20:20 */ public interface Listener { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ServerThreadPoolDynamicRefresh.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ServerThreadPoolDynamicRefresh.java index 2d73df29..084f70d2 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ServerThreadPoolDynamicRefresh.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ServerThreadPoolDynamicRefresh.java @@ -45,9 +45,6 @@ import static cn.hippo4j.common.constant.ChangeThreadPoolConstants.CHANGE_THREAD /** * Thread pool dynamic refresh. - * - * @author chen.ma - * @date 2021/6/20 15:51 */ @Slf4j @AllArgsConstructor @@ -58,10 +55,8 @@ public class ServerThreadPoolDynamicRefresh implements ThreadPoolDynamicRefresh @Override public void dynamicRefresh(String content) { ThreadPoolParameterInfo parameter = JSONUtil.parseObject(content, ThreadPoolParameterInfo.class); - String threadPoolId = parameter.getTpId(); ThreadPoolExecutor executor = GlobalThreadPoolManage.getExecutorService(threadPoolId).getExecutor(); - refreshDynamicPool(parameter, executor); } @@ -79,7 +74,6 @@ public class ServerThreadPoolDynamicRefresh implements ThreadPoolDynamicRefresh int originalCapacity = executor.getQueue().remainingCapacity() + executor.getQueue().size(); long originalKeepAliveTime = executor.getKeepAliveTime(TimeUnit.SECONDS); boolean originalAllowCoreThreadTimeOut = executor.allowsCoreThreadTimeOut(); - Long originalExecuteTimeOut = null; RejectedExecutionHandler rejectedExecutionHandler = executor.getRejectedExecutionHandler(); if (executor instanceof AbstractDynamicExecutorSupport) { @@ -99,7 +93,6 @@ public class ServerThreadPoolDynamicRefresh implements ThreadPoolDynamicRefresh request.setBeforeRejectedName(originalRejected); request.setBeforeExecuteTimeOut(originalExecuteTimeOut); request.setThreadPoolId(threadPoolId); - changePoolInfo(executor, parameter); ThreadPoolExecutor afterExecutor = GlobalThreadPoolManage.getExecutorService(threadPoolId).getExecutor(); request.setNowCorePoolSize(afterExecutor.getCorePoolSize()); diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ShutdownExecuteException.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ShutdownExecuteException.java index 82c523c8..42543fda 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ShutdownExecuteException.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ShutdownExecuteException.java @@ -19,9 +19,6 @@ package cn.hippo4j.springboot.starter.core; /** * Shutdown execute exception. - * - * @author chen.ma - * @date 2021/12/9 21:48 */ public class ShutdownExecuteException extends Exception { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolConfigService.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolConfigService.java index b5f2bd1d..7af42081 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolConfigService.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolConfigService.java @@ -26,9 +26,6 @@ import java.util.Arrays; /** * Thread-pool config service. - * - * @author chen.ma - * @date 2021/6/21 21:50 */ public class ThreadPoolConfigService implements ConfigService, ApplicationListener { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolOperation.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolOperation.java index f5490108..9d173dd2 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolOperation.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolOperation.java @@ -23,9 +23,6 @@ import java.util.concurrent.Executor; /** * Thread-pool operation. - * - * @author chen.ma - * @date 2021/6/22 20:25 */ public class ThreadPoolOperation { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolSubscribeCallback.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolSubscribeCallback.java index 407b9be1..121314e9 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolSubscribeCallback.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolSubscribeCallback.java @@ -19,9 +19,6 @@ package cn.hippo4j.springboot.starter.core; /** * ThreadPool subscribe callback. - * - * @author chen.ma - * @date 2021/6/22 20:26 */ public interface ThreadPoolSubscribeCallback { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/event/ApplicationCompleteEvent.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/event/ApplicationCompleteEvent.java index 2deb7ae6..9393062c 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/event/ApplicationCompleteEvent.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/event/ApplicationCompleteEvent.java @@ -21,9 +21,6 @@ import org.springframework.context.ApplicationEvent; /** * Execute after the spring application context is successfully started. - * - * @author chen.ma - * @date 2021/12/25 21:19 */ public class ApplicationCompleteEvent extends ApplicationEvent { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/event/ApplicationContentPostProcessor.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/event/ApplicationContentPostProcessor.java index 6312fb6e..f4e2cc23 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/event/ApplicationContentPostProcessor.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/event/ApplicationContentPostProcessor.java @@ -25,9 +25,6 @@ import javax.annotation.Resource; /** * Application content post processor. - * - * @author chen.ma - * @date 2021/12/25 20:21 */ public class ApplicationContentPostProcessor implements ApplicationListener { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/event/MonitorEventExecutor.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/event/MonitorEventExecutor.java deleted file mode 100644 index b10e5c87..00000000 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/event/MonitorEventExecutor.java +++ /dev/null @@ -1,56 +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.springboot.starter.event; - -import cn.hippo4j.common.function.NoArgsConsumer; -import cn.hippo4j.core.executor.support.QueueTypeEnum; -import cn.hippo4j.core.executor.support.ThreadPoolBuilder; -import lombok.extern.slf4j.Slf4j; - -import java.util.concurrent.ExecutorService; -import java.util.concurrent.RejectedExecutionException; -import java.util.concurrent.ThreadPoolExecutor; - -import static cn.hippo4j.common.constant.Constants.AVAILABLE_PROCESSORS; - -/** - * 动态线程池监控事件执行器. - * - * @author chen.ma - * @date 2021/11/8 23:44 - */ -@Slf4j -public class MonitorEventExecutor { - - private static final ExecutorService EVENT_EXECUTOR = ThreadPoolBuilder.builder() - .threadFactory("client.monitor.event.executor") - .corePoolSize(AVAILABLE_PROCESSORS) - .maxPoolNum(AVAILABLE_PROCESSORS) - .workQueue(QueueTypeEnum.LINKED_BLOCKING_QUEUE) - .capacity(4096) - .rejected(new ThreadPoolExecutor.AbortPolicy()) - .build(); - - public static void publishEvent(NoArgsConsumer consumer) { - try { - EVENT_EXECUTOR.execute(consumer::accept); - } catch (RejectedExecutionException ex) { - log.error("Monitoring thread pool run events exceeded load."); - } - } -} diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/ReportingEventExecutor.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/ReportingEventExecutor.java index 7aa90c35..efa7a3b5 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/ReportingEventExecutor.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/ReportingEventExecutor.java @@ -53,11 +53,8 @@ import static cn.hippo4j.core.executor.manage.GlobalThreadPoolManage.getThreadPo /** * Dynamic thread pool collection and reporting event executor. - *

- * {@link BlockingQueue} Act as a buffer container, enabling a production-consumption model. * - * @author chen.ma - * @date 2021/12/6 20:23 + *

{@link BlockingQueue} Act as a buffer container, enabling a production-consumption model. */ @Slf4j @RequiredArgsConstructor diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/collect/Collector.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/collect/Collector.java index d84f6d75..3fe5da50 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/collect/Collector.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/collect/Collector.java @@ -21,9 +21,6 @@ import cn.hippo4j.common.monitor.Message; /** * Collect thread-pool data. - * - * @author chen.ma - * @date 2021/12/7 20:11 */ public interface Collector { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/collect/RunTimeInfoCollector.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/collect/RunTimeInfoCollector.java index d12ad787..d38b3ed6 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/collect/RunTimeInfoCollector.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/collect/RunTimeInfoCollector.java @@ -35,9 +35,6 @@ import static cn.hippo4j.core.toolkit.IdentifyUtil.getThreadPoolIdentify; /** * Thread pool runtime data collection. - * - * @author chen.ma - * @date 2021/12/16 19:46 */ @AllArgsConstructor public class RunTimeInfoCollector extends AbstractThreadPoolRuntime implements Collector { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/MessageSender.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/MessageSender.java index 7ba6c289..bf91464a 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/MessageSender.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/MessageSender.java @@ -21,9 +21,6 @@ import cn.hippo4j.common.monitor.Message; /** * Message sender. - * - * @author chen.ma - * @date 2021/12/7 20:49 */ public interface MessageSender { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/http/HttpConnectSender.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/http/HttpConnectSender.java index e918a65f..33fc1173 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/http/HttpConnectSender.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/http/HttpConnectSender.java @@ -29,9 +29,6 @@ import static cn.hippo4j.common.constant.Constants.MONITOR_PATH; /** * Http sender. - * - * @author chen.ma - * @date 2021/12/7 20:53 */ @Slf4j @AllArgsConstructor diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/netty/NettyConnectSender.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/netty/NettyConnectSender.java index 5cfe4e0d..57abbdb4 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/netty/NettyConnectSender.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/netty/NettyConnectSender.java @@ -33,13 +33,9 @@ import io.netty.handler.codec.serialization.ObjectDecoder; import io.netty.handler.codec.serialization.ObjectEncoder; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; /** - * Netty ConnectSender - * - * @author lk - * @date 2022/06/18 + * Netty connect sender. */ @Slf4j @AllArgsConstructor @@ -66,7 +62,6 @@ public class NettyConnectSender implements MessageSender { pipeline.addLast(new SenderHandler(messageWrapper)); } }); - bootstrap.connect(serverNettyAgent.getNettyServerAddress(), serverNettyAgent.getNettyServerPort()).sync(); } catch (Exception e) { log.error("netty send error ", e); diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/netty/SenderHandler.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/netty/SenderHandler.java index 7cf68542..21c72be5 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/netty/SenderHandler.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/netty/SenderHandler.java @@ -24,10 +24,7 @@ import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; /** - * SenderHandler - * - * @author lk - * @date 2022/06/18 + * Sender handler. */ @Slf4j @AllArgsConstructor @@ -37,7 +34,6 @@ public class SenderHandler extends SimpleChannelInboundHandler { @Override protected void channelRead0(ChannelHandlerContext ctx, MessageWrapper msg) throws Exception { - } @Override diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/notify/ServerNotifyConfigBuilder.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/notify/ServerNotifyConfigBuilder.java index 7c4f0244..f18faabd 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/notify/ServerNotifyConfigBuilder.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/notify/ServerNotifyConfigBuilder.java @@ -42,9 +42,6 @@ import static cn.hippo4j.common.constant.Constants.BASE_PATH; /** * Server notify config builder. - * - * @author chen.ma - * @date 2022/2/24 19:57 */ @Slf4j @AllArgsConstructor diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/AbstractHealthCheck.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/AbstractHealthCheck.java index f90188d8..77dd33c3 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/AbstractHealthCheck.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/AbstractHealthCheck.java @@ -36,9 +36,6 @@ import static cn.hippo4j.common.constant.Constants.HEALTH_CHECK_INTERVAL; /** * Abstract health check. - * - * @author chen.ma - * @date 2021/12/8 20:19 */ @Slf4j public abstract class AbstractHealthCheck implements ServerHealthCheck, InitializingBean, ApplicationListener { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/HttpAgent.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/HttpAgent.java index 39961405..e2bf9db5 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/HttpAgent.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/HttpAgent.java @@ -23,9 +23,6 @@ import java.util.Map; /** * Http agent. - * - * @author chen.ma - * @date 2021/6/23 20:45 */ public interface HttpAgent { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/HttpScheduledHealthCheck.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/HttpScheduledHealthCheck.java index 207c7af6..0b786363 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/HttpScheduledHealthCheck.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/HttpScheduledHealthCheck.java @@ -28,9 +28,6 @@ import static cn.hippo4j.common.constant.Constants.UP; /** * Server health check. - * - * @author chen.ma - * @date 2021/12/8 20:16 */ @Slf4j @AllArgsConstructor @@ -49,7 +46,6 @@ public class HttpScheduledHealthCheck extends AbstractHealthCheck { } catch (Throwable ex) { log.error("Failed to periodically check the health status of the server.", ex.getMessage()); } - return healthStatus; } } diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerHealthCheck.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerHealthCheck.java index 5e04492b..cdda8bf9 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerHealthCheck.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerHealthCheck.java @@ -19,9 +19,6 @@ package cn.hippo4j.springboot.starter.remote; /** * Server health check. - * - * @author chen.ma - * @date 2021/12/8 20:08 */ public interface ServerHealthCheck { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerHttpAgent.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerHttpAgent.java index b2c74848..9cd62075 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerHttpAgent.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerHttpAgent.java @@ -34,9 +34,6 @@ import java.util.concurrent.TimeUnit; /** * Server http agent. - * - * @author chen.ma - * @date 2021/6/23 20:50 */ public class ServerHttpAgent implements HttpAgent { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerListManager.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerListManager.java index c384e2eb..f3d72823 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerListManager.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerListManager.java @@ -27,9 +27,6 @@ import java.util.*; /** * Server list manager. - * - * @author chen.ma - * @date 2021/6/23 20:42 */ @Slf4j public class ServerListManager { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerNettyAgent.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerNettyAgent.java index a2958173..fb3617b8 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerNettyAgent.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerNettyAgent.java @@ -22,10 +22,7 @@ import io.netty.channel.EventLoopGroup; import io.netty.channel.nio.NioEventLoopGroup; /** - * Server Netty Agent - * - * @author lk - * @date 2022/6/18 + * Server netty agent. */ public class ServerNettyAgent { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/security/SecurityProxy.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/security/SecurityProxy.java index bae16462..ccccf131 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/security/SecurityProxy.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/security/SecurityProxy.java @@ -33,9 +33,6 @@ import java.util.concurrent.TimeUnit; /** * Security proxy. - * - * @author chen.ma - * @date 2021/12/20 20:19 */ @Slf4j public class SecurityProxy { @@ -74,8 +71,7 @@ public class SecurityProxy { return true; } } - } catch (Throwable ignore) { - // ignore + } catch (Throwable ignored) { } return false; } diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/toolkit/CloudCommonIdUtil.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/toolkit/CloudCommonIdUtil.java index d045bae4..e2058c93 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/toolkit/CloudCommonIdUtil.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/toolkit/CloudCommonIdUtil.java @@ -23,9 +23,6 @@ import org.springframework.core.env.PropertyResolver; /** * Cloud common id util. - * - * @author chen.ma - * @date 2021/8/6 21:02 */ public class CloudCommonIdUtil { @@ -51,8 +48,7 @@ public class CloudCommonIdUtil { return combineParts(hostname, SEPARATOR, appName); } - public static String combineParts(String firstPart, String separator, - String secondPart) { + public static String combineParts(String firstPart, String separator, String secondPart) { String combined = null; if (firstPart != null && secondPart != null) { combined = firstPart + separator + secondPart; diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/toolkit/HttpClientUtil.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/toolkit/HttpClientUtil.java index 65663474..69527e4c 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/toolkit/HttpClientUtil.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/toolkit/HttpClientUtil.java @@ -30,9 +30,6 @@ import java.util.concurrent.TimeUnit; /** * HttpClient util. - * - * @author chen.ma - * @date 2021/6/10 13:30 */ @Slf4j public class HttpClientUtil { diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/wrapper/ManagerListenerWrapper.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/wrapper/ManagerListenerWrapper.java index bb6f309a..0119f655 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/wrapper/ManagerListenerWrapper.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/wrapper/ManagerListenerWrapper.java @@ -25,9 +25,6 @@ import lombok.Setter; /** * Manager listener wrapper. - * - * @author chen.ma - * @date 2021/6/22 17:47 */ @Getter @Setter