重庆分公司
重庆分公司，新征程启航
为企业提供网站建设、域名注册、服务器等服务
如何实现基于ImportBeanDefinitionRegistrar和FactoryBean动态注入Bean到Spring容器中
这篇文章主要讲解了“如何实现基于ImportBeanDefinitionRegistrar和FactoryBean动态注入Bean到Spring容器中”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“如何实现基于ImportBeanDefinitionRegistrar和FactoryBean动态注入Bean到Spring容器中”吧！
创新互联专注为客户提供全方位的互联网综合服务，包含不限于网站制作、做网站、汝城网络推广、微信小程序、汝城网络营销、汝城企业策划、汝城品牌公关、搜索引擎seo、人物专访、企业宣传片、企业代运营等，从售前售中售后，我们都将竭诚为您服务，您的肯定，是我们最大的嘉奖；创新互联为所有大学生创业者提供汝城建站搭建服务，24小时服务热线：028-86922220，官方网址：www.cdcxhl.com
一、背景
我们自己开发了一个第三方的jar包，想和Spring整合起来，并注入到Spring容器中。自己的jar包中，需要加入到Spring容器的类上都加入了一个自定义注解@CustomImport(beanName=""),beanName属性的值表示需要注入到Spring容器中的名字。
二、实现方案
1、基于@ComponentScan注解实现
使用此种方案比较简单，直接使用@ComponentScan(includeFilters = {@ComponentScan.Filter(value = CustomImport.class)})即可将我们自定义的注解加入到Spring容器中。 此种方案略。
2、基于ImportBeanDefinitionRegistrar和FactoryBean实现
1、实现此接口(ImportBeanDefinitionRegistrar)，可以将我们自己的BeanDefinition对象加到BeanDefinitionRegistry中，等待后续Spring初始化对象。
注：
1. 我们可以从自定义的注解中获取到一些属性，然后来个性化我们要初始化的Bean是什么样的。
2. 实现ImportBeanDefinitionRegistrar的类配合上@Configuration和@Import注解，可以在程序启动的时候加载这个类。
2、实现此接口(FactoryBean)，可以让我们自定义实例化出我们要构建的Bean。
3、注意
可能有些人会说，我用@ComponentScan就可以搞定的事情，为何还要选择基于第二种方法实现，这个不是多此一举吗？这个其实我主要是记录这样的一个思路。比如：Mybatis和Spring整合后，只需要申明一个@Mapper就可以自定加入到Spring管理中(MapperScannerRegistrar)，那么这是怎么实现的呢？应该是和上方的方案2类似。
三、实现步骤
1、自定义一个注解 CustomImport，被此注解标注的类，表示需要加入到Spring容器中。
CustomImport 注解可以增加一些额外的属性，比如beanName表示注入到Spring容器时,bean的名字。
2、写一个类实现CustomImportFactoryBean，表示如何实例化出CustomImport注解标注的类。
构造化对象。
构造出的对象需要自己完成初始化操作，如果需要用到Spring的里的对象，可以获取到ApplicationContext然后获取注入。
3、写一个类实现ImportBeanDefinitionRegistrar，扫描出所有的CustomImport的类，然后构造出BeanDefinition,加入到Spring容器中。
构造BeanDefinition时的BeanClass属性需要指定上一个的CustomImportFactoryBean的class。
ClassPathBeanDefinitionScanner可以扫描包。
4、自定义一个注解EnableCustomImport，启动类上加入此注解后，实现ImportBeanDefinitionRegistrar的调用。
此注解上需要使用
@Import标注
1、自定义注解CustomImport
/**
* 此注解标注的类也会自动加入到 Spring 管理中。
*
* @author huan.fu 2021/4/14 - 上午9:23
*/
@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface CustomImport {
/**
* 这个bean注入到Spring容器中的名字
*/
String beanName();
}2、实现CustomImportFactoryBean构建对象
package com.huan.study.framewrok; import org.springframework.beans.BeansException; import org.springframework.beans.factory.FactoryBean; import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContextAware; /** * 工厂Bean，用于构建 CustomImport 注解标注的类，如何进行实例化 * * @author huan.fu 2021/4/14 - 上午9:44 */ public class CustomImportFactoryBean implements FactoryBean
3、编写ImportBeanDefinitionRegistrar
package com.huan.study.framewrok;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.AnnotatedBeanDefinition;
import org.springframework.beans.factory.config.BeanDefinition;
import org.springframework.beans.factory.support.AbstractBeanDefinition;
import org.springframework.beans.factory.support.BeanDefinitionBuilder;
import org.springframework.beans.factory.support.BeanDefinitionRegistry;
import org.springframework.context.EnvironmentAware;
import org.springframework.context.ResourceLoaderAware;
import org.springframework.context.annotation.ClassPathBeanDefinitionScanner;
import org.springframework.context.annotation.ImportBeanDefinitionRegistrar;
import org.springframework.core.annotation.AnnotationAttributes;
import org.springframework.core.env.Environment;
import org.springframework.core.io.ResourceLoader;
import org.springframework.core.type.AnnotationMetadata;
import org.springframework.core.type.filter.AnnotationTypeFilter;
import java.util.Map;
import java.util.Optional;
import java.util.Set;
/**
* @author huan.fu 2021/4/14 - 上午9:25
*/
public class CustomImportBeanDefinitionRegistrar implements ImportBeanDefinitionRegistrar, ResourceLoaderAware, EnvironmentAware {
private static final Logger log = LoggerFactory.getLogger(CustomImportBeanDefinitionRegistrar.class);
private Environment environment;
private ResourceLoader resourceLoader;
@Override
public void registerBeanDefinitions(AnnotationMetadata annotationMetadata, BeanDefinitionRegistry registry) {
if (!annotationMetadata.hasAnnotation(EnableCustomImport.class.getName())) {
return;
}
Map annotationAttributesMap = annotationMetadata.getAnnotationAttributes(EnableCustomImport.class.getName());
AnnotationAttributes annotationAttributes = Optional.ofNullable(AnnotationAttributes.fromMap(annotationAttributesMap)).orElseGet(AnnotationAttributes::new);
// 获取需要扫描的包
String[] packages = retrievePackagesName(annotationMetadata, annotationAttributes);
// useDefaultFilters = false,即第二个参数 表示不扫描 @Component、@ManagedBean、@Named 注解标注的类
ClassPathBeanDefinitionScanner scanner = new ClassPathBeanDefinitionScanner(registry, false, environment, resourceLoader);
// 添加我们自定义注解的扫描
scanner.addIncludeFilter(new AnnotationTypeFilter(CustomImport.class));
// 扫描包
for (String needScanPackage : packages) {
Set candidateComponents = scanner.findCandidateComponents(needScanPackage);
try {
registerCandidateComponents(registry, candidateComponents);
} catch (ClassNotFoundException e) {
log.error(e.getMessage(), e);
}
}
}
/**
* 获取需要扫描的包
*/
private String[] retrievePackagesName(AnnotationMetadata annotationMetadata, AnnotationAttributes annotationAttributes) {
String[] packages = annotationAttributes.getStringArray("packages");
if (packages.length > 0) {
return packages;
}
String className = annotationMetadata.getClassName();
int lastDot = className.lastIndexOf('.');
return new String[]{className.substring(0, lastDot)};
}
/**
* 注册 BeanDefinition
*/
private void registerCandidateComponents(BeanDefinitionRegistry registry, Set candidateComponents) throws ClassNotFoundException {
for (BeanDefinition candidateComponent : candidateComponents) {
if (candidateComponent instanceof AnnotatedBeanDefinition) {
AnnotatedBeanDefinition annotatedBeanDefinition = (AnnotatedBeanDefinition) candidateComponent;
AnnotationMetadata annotationMetadata = annotatedBeanDefinition.getMetadata();
Map customImportAnnotationAttributesMap = annotationMetadata.getAnnotationAttributes(CustomImport.class.getName());
AnnotationAttributes customImportAnnotationAttributes = Optional.ofNullable(AnnotationAttributes.fromMap(customImportAnnotationAttributesMap)).orElseGet(AnnotationAttributes::new);
String beanName = customImportAnnotationAttributes.getString("beanName");
String className = annotationMetadata.getClassName();
Class clazzName = Class.forName(className);
AbstractBeanDefinition beanDefinition = BeanDefinitionBuilder.genericBeanDefinition(CustomImportFactoryBean.class)
.addPropertyValue("type", clazzName)
.addPropertyValue("beanName", beanName)
.setAutowireMode(AbstractBeanDefinition.AUTOWIRE_BY_TYPE)
.setRole(BeanDefinition.ROLE_INFRASTRUCTURE)
.getBeanDefinition();
registry.registerBeanDefinition(beanName, beanDefinition);
}
}
}
@Override
public void setEnvironment(Environment environment) {
this.environment = environment;
}
@Override
public void setResourceLoader(ResourceLoader resourceLoader) {
this.resourceLoader = resourceLoader;
}
} 4、编写@EnableCustomImport
/**
* 启用自动导入
*
* @author huan.fu 2021/4/14 - 上午9:29
*/
@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Import(CustomImportBeanDefinitionRegistrar.class)
public @interface EnableCustomImport {
String[] packages() default {};
}5、运行一个小的案例，获取测试结果
感谢各位的阅读，以上就是“如何实现基于ImportBeanDefinitionRegistrar和FactoryBean动态注入Bean到Spring容器中”的内容了，经过本文的学习后，相信大家对如何实现基于ImportBeanDefinitionRegistrar和FactoryBean动态注入Bean到Spring容器中这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是创新互联，小编将为大家推送更多相关知识点的文章，欢迎关注！
本文名称：如何实现基于ImportBeanDefinitionRegistrar和FactoryBean动态注入Bean到Spring容器中
网页网址：http://cqcxhl.com/article/ggecio.html