@ -23,18 +23,30 @@ import cn.hippo4j.agent.core.plugin.interceptor.enhance.EnhancedInstance;
import cn.hippo4j.agent.core.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor ;
import cn.hippo4j.agent.core.plugin.interceptor.enhance.MethodInterceptResult ;
import cn.hippo4j.agent.plugin.spring.boot.v2.DynamicThreadPoolChangeHandlerSpring2x ;
import cn.hippo4j.agent.plugin.spring.common.conf.SpringBootConfig ;
import cn.hippo4j.agent.plugin.spring.common.support.SpringPropertiesLoader ;
import cn.hippo4j.agent.plugin.spring.common.support.SpringThreadPoolRegisterSupport ;
import cn.hippo4j.common.executor.ThreadFactoryBuilder ;
import cn.hippo4j.common.executor.ThreadPoolExecutorRegistry ;
import cn.hippo4j.common.extension.design.AbstractSubjectCenter ;
import cn.hippo4j.common.extension.spi.ServiceLoaderRegistry ;
import cn.hippo4j.common.toolkit.StringUtil ;
import cn.hippo4j.threadpool.dynamic.api.ThreadPoolDynamicRefresh ;
import cn.hippo4j.threadpool.dynamic.mode.config.refresher.event.DynamicThreadPoolRefreshListener ;
import lombok.extern.slf4j.Slf4j ;
import org.springframework.context.ConfigurableApplicationContext ;
import java.lang.reflect.Method ;
import java.util.ArrayList ;
import java.util.Arrays ;
import java.util.List ;
import java.util.concurrent.ScheduledThreadPoolExecutor ;
import java.util.concurrent.TimeUnit ;
/ * *
* Event publishing started interceptor
* /
@Slf4j
public class EventPublishingStartedInterceptor implements InstanceMethodsAroundInterceptor {
private static final ILog LOGGER = LogManager . getLogger ( EventPublishingStartedInterceptor . class ) ;
@ -57,6 +69,7 @@ public class EventPublishingStartedInterceptor implements InstanceMethodsAroundI
dynamicRefresh . registerListener ( ) ;
AbstractSubjectCenter . register ( AbstractSubjectCenter . SubjectType . THREAD_POOL_DYNAMIC_REFRESH ,
new DynamicThreadPoolRefreshListener ( ) ) ;
return ret ;
}
@ -64,4 +77,32 @@ public class EventPublishingStartedInterceptor implements InstanceMethodsAroundI
public void handleMethodException ( EnhancedInstance objInst , Method method , Object [ ] allArguments , Class < ? > [ ] argumentsTypes , Throwable t ) {
}
// private void registerMonitor() {
// if (!SpringBootConfig.Spring.Dynamic.Thread_Pool.Monitor.enable
// || StringUtil.isBlank(SpringBootConfig.Spring.Dynamic.Thread_Pool.Monitor.threadPoolTypes)
// || StringUtil.isBlank(SpringBootConfig.Spring.Dynamic.Thread_Pool.Monitor.collectTypes)) {
// return;
// }
// log.info("Start monitoring the running status of dynamic thread pool.");
// List<ThreadPoolMonitor> threadPoolMonitors = new ArrayList<>();
// collectScheduledExecutor = new ScheduledThreadPoolExecutor(
// 1,
// ThreadFactoryBuilder.builder().daemon(true).prefix("client.scheduled.collect.data").build());
// // Get dynamic thread pool monitoring component.
// List<String> collectTypes = Arrays.asList(monitor.getCollectTypes().split(","));
// ApplicationContextHolder.getBeansOfType(ThreadPoolMonitor.class).forEach((beanName, bean) -> threadPoolMonitors.add(bean));
// Collection<DynamicThreadPoolMonitor> dynamicThreadPoolMonitors =
// ServiceLoaderRegistry.getSingletonServiceInstances(DynamicThreadPoolMonitor.class);
// dynamicThreadPoolMonitors.stream().filter(each -> collectTypes.contains(each.getType())).forEach(each -> threadPoolMonitors.add(each));
// // Execute dynamic thread pool monitoring component.
// collectScheduledExecutor.scheduleWithFixedDelay(
// this::scheduleRunnable,
// monitor.getInitialDelay(),
// monitor.getCollectInterval(),
// TimeUnit.MILLISECONDS);
// if (ThreadPoolExecutorRegistry.getThreadPoolExecutorSize() > 0) {
// log.info("Dynamic thread pool: [{}]. The dynamic thread pool starts data collection and reporting.", ThreadPoolExecutorRegistry.getThreadPoolExecutorSize());
// }
// }
}
yanrongzhen
2 years ago