dromara-org
/
dynamic-tp
mirror of https://github.com/dromara/dynamic-tp.git
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix(spring): mark early dtp beans as ROLE_INFRASTRUCTURE 

dtpApplicationContextHolder and dtpHashedWheelTimer are dependsOn of
DtpPostProcessor and therefore initialize before all BeanPostProcessors
are ready. Mark them (and the BPP itself) as ROLE_INFRASTRUCTURE so
Spring's BeanPostProcessorChecker no longer logs auto-proxy warnings.
This commit is contained in:
yanhom 2026-08-03 15:18:47 +08:00
parent 3306f9b8fb
commit 3544afda62
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
spring/src/main/java/org/dromara/dynamictp/spring/annotation/DtpBaseBeanDefinitionRegistrar.java
View File

@ -24,6 +24,7 @@ import org.dromara.dynamictp.core.executor.NamedThreadFactory;
import org.dromara.dynamictp.spring.DtpPostProcessor;
import org.dromara.dynamictp.spring.holder.SpringContextHolder;
import org.dromara.dynamictp.spring.util.BeanRegistrationUtil;
import org.springframework.beans.factory.config.BeanDefinition;
import org.springframework.beans.factory.support.BeanDefinitionRegistry;
import org.springframework.context.annotation.ImportBeanDefinitionRegistrar;
import org.springframework.core.type.AnnotationMetadata;
@ -48,10 +49,14 @@ public class DtpBaseBeanDefinitionRegistrar implements ImportBeanDefinitionRegis
public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) {
registerHashedWheelTimer(registry);
BeanRegistrationUtil.registerIfAbsent(registry, APPLICATION_CONTEXT_HOLDER, SpringContextHolder.class);
markInfrastructure(registry, APPLICATION_CONTEXT_HOLDER);
// ApplicationContextHolder and HashedWheelTimer are required in DtpExecutor execute method, so they must be registered first
// ApplicationContextHolder and HashedWheelTimer are required in DtpExecutor execute method, so they must be registered first.
// They are intentionally created early with DtpPostProcessor; mark as ROLE_INFRASTRUCTURE so
// BeanPostProcessorChecker does not warn about early initialization / auto-proxy ineligibility.
BeanRegistrationUtil.registerIfAbsent(registry, DTP_POST_PROCESSOR, DtpPostProcessor.class,
null, Lists.newArrayList(APPLICATION_CONTEXT_HOLDER, HASHED_WHEEL_TIMER));
markInfrastructure(registry, DTP_POST_PROCESSOR);
}
private void registerHashedWheelTimer(BeanDefinitionRegistry registry) {
@ -61,5 +66,12 @@ public class DtpBaseBeanDefinitionRegistrar implements ImportBeanDefinitionRegis
TimeUnit.MILLISECONDS
};
BeanRegistrationUtil.registerIfAbsent(registry, HASHED_WHEEL_TIMER, HashedWheelTimer.class, constructorArgs);
markInfrastructure(registry, HASHED_WHEEL_TIMER);
}
private static void markInfrastructure(BeanDefinitionRegistry registry, String beanName) {
if (registry.containsBeanDefinition(beanName)) {
registry.getBeanDefinition(beanName).setRole(BeanDefinition.ROLE_INFRASTRUCTURE);
}
}
}