BeanDefinitionRegistryPostProcessor扩展

2024-03-07 00:38
文章标签 扩展 beandefinitionregistrypostprocessor

本文主要是介绍BeanDefinitionRegistryPostProcessor扩展，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

通过BeanDefinitionRegistryPostProcessor扩展能实现额外的很多功能，例如实现将一个接口动态代理，并将该代理对象在spring容器初始化完成前注册到spring容器中。实现可以通过@Autowired等注释或其他方法从spring容器中获取该代理对象。

代理工厂
import lombok.extern.slf4j.Slf4j;import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;@Slf4j
public class HelloProxy implements InvocationHandler {private Class<?> interfaceClass;public Object bind(Class<?> cls) {this.interfaceClass = cls;return Proxy.newProxyInstance(cls.getClassLoader(), new Class[]{interfaceClass}, this);}@Overridepublic Object invoke(Object proxy, Method method, Object[] args) {log.info("调用代理方法, method: {}", method.getName());return "hello world";}}

import org.springframework.beans.factory.FactoryBean;public class ProxyBeanFactory<T> implements FactoryBean<T> {private Class<T> interfaceClass;public Class<T> getInterfaceClass() {return interfaceClass;}public void setInterfaceClass(Class<T> interfaceClass) {this.interfaceClass = interfaceClass;}@Overridepublic T getObject() {return (T) new HelloProxy().bind(interfaceClass);}@Overridepublic Class<?> getObjectType() {return interfaceClass;}@Overridepublic boolean isSingleton() {// 单例模式return true;}}
扫描注册
import com.wakzz.autowire.proxy.ProxyBeanFactory;
import org.springframework.beans.factory.annotation.AnnotatedBeanDefinition;
import org.springframework.beans.factory.config.BeanDefinitionHolder;
import org.springframework.beans.factory.support.BeanDefinitionBuilder;
import org.springframework.beans.factory.support.BeanDefinitionRegistry;
import org.springframework.beans.factory.support.GenericBeanDefinition;
import org.springframework.context.annotation.ClassPathBeanDefinitionScanner;
import org.springframework.core.type.classreading.MetadataReader;
import org.springframework.core.type.classreading.MetadataReaderFactory;
import org.springframework.core.type.filter.AnnotationTypeFilter;
import org.springframework.core.type.filter.TypeFilter;import java.lang.annotation.Annotation;
import java.util.Set;public class ClassPathReferenceScanner extends ClassPathBeanDefinitionScanner {private BeanDefinitionRegistry registry;private Class<? extends Annotation> annotationClass;public ClassPathReferenceScanner(BeanDefinitionRegistry registry) {super(registry, false);this.registry = registry;}public void setAnnotationClass(Class<? extends Annotation> annotationClass) {this.annotationClass = annotationClass;}/*** 只扫描出指定Annotation注解的类*/public void registerFilters() {if (this.annotationClass != null) {addIncludeFilter(new AnnotationTypeFilter(this.annotationClass));}// exclude package-info.javaaddExcludeFilter(new TypeFilter() {@Overridepublic boolean match(MetadataReader metadataReader, MetadataReaderFactory metadataReaderFactory) {String className = metadataReader.getClassMetadata().getClassName();return className.endsWith("package-info");}});}/*** 只扫描出接口类*/@Overrideprotected boolean isCandidateComponent(AnnotatedBeanDefinition beanDefinition) {return beanDefinition.getMetadata().isInterface() && beanDefinition.getMetadata().isIndependent();}@Overridepublic Set<BeanDefinitionHolder> doScan(String... basePackages) {Set<BeanDefinitionHolder> beanDefinitions = super.doScan(basePackages);processBeanDefinitions(beanDefinitions);return beanDefinitions;}/*** 将扫描出的类实现代理类,并注册到spring中*/private void processBeanDefinitions(Set<BeanDefinitionHolder> beanDefinitions) {for (BeanDefinitionHolder holder : beanDefinitions) {String className = holder.getBeanDefinition().getBeanClassName();BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(className);GenericBeanDefinition proxyDefinition = (GenericBeanDefinition) builder.getRawBeanDefinition();proxyDefinition.getPropertyValues().add("interfaceClass", className);proxyDefinition.setBeanClass(ProxyBeanFactory.class);proxyDefinition.setAutowireMode(GenericBeanDefinition.AUTOWIRE_BY_TYPE);this.registry.registerBeanDefinition(holder.getBeanName(), proxyDefinition);}}
}

import org.springframework.beans.factory.BeanNameAware;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
import org.springframework.beans.factory.support.BeanDefinitionRegistry;
import org.springframework.beans.factory.support.BeanDefinitionRegistryPostProcessor;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;import java.lang.annotation.Annotation;public class ReferenceRegistryPostProcessor implements BeanDefinitionRegistryPostProcessor, InitializingBean, ApplicationContextAware, BeanNameAware {private String basePackage;private Class<? extends Annotation> annotationClass;private ApplicationContext applicationContext;public void setBasePackage(String basePackage) {this.basePackage = basePackage;}public void setAnnotationClass(Class<? extends Annotation> annotationClass) {this.annotationClass = annotationClass;}@Overridepublic void setApplicationContext(ApplicationContext applicationContext) {this.applicationContext = applicationContext;}@Overridepublic void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) {}@Overridepublic void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) {ClassPathReferenceScanner scanner = new ClassPathReferenceScanner(registry);scanner.setAnnotationClass(this.annotationClass);scanner.setResourceLoader(this.applicationContext);scanner.registerFilters();scanner.scan(basePackage);}@Overridepublic void afterPropertiesSet() {}@Overridepublic void setBeanName(String name) {}
}
注入实现
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface Reference {
}

import com.wakzz.autowire.Reference;@Reference
public interface TestService {String sayHello();}

import com.wakzz.autowire.Reference;
import org.springframework.beans.factory.support.BeanDefinitionRegistryPostProcessor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class ReferenceConfig {@Beanpublic BeanDefinitionRegistryPostProcessor referenceRegistryPostProcessor() {ReferenceRegistryPostProcessor referenceRegistryPostProcessor = new ReferenceRegistryPostProcessor();referenceRegistryPostProcessor.setAnnotationClass(Reference.class);referenceRegistryPostProcessor.setBasePackage("com.wakzz.autowire");return referenceRegistryPostProcessor;}}
效果
ConfigurableApplicationContext applicationContext = new SpringApplicationBuilder().sources(Application.class).run(args);
TestService bean = applicationContext.getBean(TestService.class);
String response = bean.sayHello();
System.out.println(response);

最终输出如下:

2019-12-29 15:37:35.938  INFO 25336 --- [           main] com.wakzz.autowire.proxy.HelloProxy      : 调用代理方法, method: sayHello
hello world

这篇关于BeanDefinitionRegistryPostProcessor扩展的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/781892。

相关文章

csu 1446 Problem J Modified LCS （扩展欧几里得算法的简单应用）

csu 1446 Problem J Modified LCS （扩展欧几里得算法的简单应用）

这是一道扩展欧几里得算法的简单应用题，这题是在湖南多校训练赛中队友ac的一道题，在比赛之后请教了队友，然后自己把它a掉 这也是自己独自做扩展欧几里得算法的题目 题意：把题意转变下就变成了：求d1*x - d2*y = f2 - f1的解,很明显用exgcd来解 下面介绍一下exgcd的一些知识点：求ax + by = c的解 一、首先求ax + by = gcd(a,b)的解 这个
阅读更多...
科研绘图系列：R语言扩展物种堆积图（Extended Stacked Barplot）

科研绘图系列：R语言扩展物种堆积图（Extended Stacked Barplot）

介绍 R语言的扩展物种堆积图是一种数据可视化工具，它不仅展示了物种的堆积结果，还整合了不同样本分组之间的差异性分析结果。这种图形表示方法能够直观地比较不同物种在各个分组中的显著性差异，为研究者提供了一种有效的数据解读方式。 加载R包 knitr::opts_chunk$set(warning = F, message = F)library(tidyverse)library(phyl
阅读更多...
Spring框架5 - 容器的扩展功能 (ApplicationContext)

Spring框架5 - 容器的扩展功能 (ApplicationContext)

private static ApplicationContext applicationContext;static {applicationContext = new ClassPathXmlApplicationContext("bean.xml");} BeanFactory的功能扩展类ApplicationContext进行深度的分析。ApplicationConext与 BeanF
阅读更多...
PHP7扩展开发之数组处理

PHP7扩展开发之数组处理

前言 这次，我们将演示如何在PHP扩展中如何对数组进行处理。要实现的PHP代码如下： <?phpfunction array_concat ($arr, $prefix) {foreach($arr as $key => $val) {if (isset($prefix[$key]) && is_string($val) && is_string($prefix[$key])) {$arr[
阅读更多...
PHP7扩展开发之字符串处理

PHP7扩展开发之字符串处理

前言 这次，我们来看看字符串在PHP扩展里面如何处理。 示例代码如下： <?phpfunction str_concat($prefix, $string) {$len = strlen($prefix);$substr = substr($string, 0, $len);if ($substr != $prefix) {return $prefix." ".$string;} else
阅读更多...
PHP7扩展开发之类型处理

PHP7扩展开发之类型处理

前言 这次，我们将演示如何在PHP扩展中如何对类型进行一些操作。如，判断变量类型。要实现的PHP代码如下： <?phpfunction get_size ($value) {if (is_string($value)) {return "string size is ". strlen($value);} else if (is_array($value)) {return "array si
阅读更多...
PHP7扩展开发之依赖其他扩展

PHP7扩展开发之依赖其他扩展

前言 有的时候，我们的扩展要依赖其他扩展。比如，我们PHP的mysqli扩展就依赖mysqlnd扩展。这中情况下，我们怎么使用其他扩展呢？这个就是本文讲述的内容。 我们新建立一个扩展，名字叫 demo_dep ， 依赖之前的say扩展。 在demo_dep扩展中，我们实现demo_say方法。这个方法调用say扩展的say方法。 代码 基础代码 确保say扩展的头文件正确安装到了php
阅读更多...
PHP7扩展开发之函数方式使用lib库

PHP7扩展开发之函数方式使用lib库

前言 首先说下什么是lib库。lib库就是一个提供特定功能的一个文件。可以把它看成是PHP的一个文件，这个文件提供一些函数方法。只是这个lib库是用c或者c++写的。 使用lib库的场景。一些软件已经提供了lib库，我们就没必要再重复实现一次。如，原先的mysql扩展，就是使用mysql官方的lib库进行的封装。 在本文，我们将建立一个简单的lib库，并在扩展中进行封装调用。 代码 基础
阅读更多...
PHP7扩展开发之对象方式使用lib库

PHP7扩展开发之对象方式使用lib库

前言 上一篇文章，我们使用的是函数方式调用lib库。这篇文章我们将使用对象的方式调用lib库。调用代码如下： <?php $hello = new hello(); $result = $hello->get(); var_dump($result); ?> 我们将在扩展中实现hello类。hello类中将依赖lib库。 代码 基础代码 这个扩展，我们将在say扩展上增加相关代码。sa
阅读更多...
PHP7扩展开发之流操作

PHP7扩展开发之流操作

前言 啥是流操作？简单来讲就是对一些文件，网络的IO操作。PHP已经把这些IO操作，封装成流操作。这节，我们将使用PHP扩展实现一个目录遍历的功能。PHP示例代码如下： <?phpfunction list_dir($dir) {if (is_dir($dir) === false) {return;} $dh = opendir($dir);if ($dh == false) {ret
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2