2019-08-22 14:43:08 3036浏览
今天千锋扣丁学堂Java培训老师给大家分享一篇关于Spring动态加载bean后调用实现方法解析的详细介绍,首先在使用Spring的过程中,我们有时候并不想通过xml的方式进行bean的注入,希望在不改变原有的程序结构的基础上添加我们需要的bean,这个时候我们可以利用Spring的spring-beans的jar包里提供的BeanFactoryPostProcessor接口类,通过实现这个接口类,我们可以动态的加载所需要的bean,特别是在引入已经打包在jar里面的程序而没有办法做出修改的情况下,这个接口就为我们提供了及其方便的入口。
	
	
<parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.6.RELEASE</version> </parent> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>com.thread</groupId> <artifactId>test</artifactId> <version>1.0</version> <scope>system</scope> <systemPath>f:/threadTest.jar</systemPath> </dependency> </dependencies>
import org.springframework.boot.SpringApplication; 
import org.springframework.boot.autoconfigure.SpringBootApplication; 
/** 
 * @author liaoyubo 
 * @version 1.0 2017/7/31 
 * @description 
 */
@SpringBootApplication
public class App { 
  
 public static void main(String [] args){ 
  SpringApplication.run(App.class); 
 } 
}
public class DynamicCreateBean { 
 public void printMethod(){ 
  System.out.println("DynamicCreateBean Success"); 
 } 
}
import org.springframework.beans.BeansException; 
import org.springframework.beans.factory.config.BeanFactoryPostProcessor; 
import org.springframework.beans.factory.config.ConfigurableListableBeanFactory; 
import org.springframework.beans.factory.support.BeanDefinitionBuilder; 
import org.springframework.beans.factory.support.DefaultListableBeanFactory; 
import org.springframework.stereotype.Component; 
import com.thread.mulitSynThreadTest.Run; 
/** 
 * @author liaoyubo 
 * @version 1.0 2017/8/11 
 * @description 
 */
@Component
public class LoadBean implements BeanFactoryPostProcessor { 
 private DefaultListableBeanFactory defaultListableBeanFactory; 
 @Override
 public void postProcessBeanFactory(ConfigurableListableBeanFactory configurableListableBeanFactory) throws BeansException { 
  this.defaultListableBeanFactory = (DefaultListableBeanFactory)configurableListableBeanFactory; 
  BeanDefinitionBuilder beanDefinitionBuilder = BeanDefinitionBuilder.rootBeanDefinition("com.springRedis.dynamic.DynamicCreateBean"); 
  //用于设置指定的类中需要引入的其他bean 
  //beanDefinitionBuilder.addPropertyValue("otherBeanName","otherBeanName"); 
  this.defaultListableBeanFactory.registerBeanDefinition("dynamicCreateBean",beanDefinitionBuilder.getBeanDefinition()); 
  beanDefinitionBuilder = BeanDefinitionBuilder.rootBeanDefinition(Run.class.getName()); 
  //用于设置指定的类中需要引入的其他bean 
  //beanDefinitionBuilder.addPropertyValue("otherBeanName","otherBeanName"); 
  this.defaultListableBeanFactory.registerBeanDefinition("mulitRun",beanDefinitionBuilder.getBeanDefinition()); 
 } 
}
import com.springRedis.App; 
import com.springRedis.dynamic.DynamicCreateBean; 
import com.thread.mulitSynThreadTest.Run; 
import org.junit.Test; 
import org.junit.runner.RunWith; 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.boot.test.context.SpringBootTest; 
import org.springframework.test.context.junit4.SpringRunner; 
/** 
 * @author liaoyubo 
 * @version 1.0 2017/8/11 
 * @description 
 */
@RunWith(SpringRunner.class) 
@SpringBootTest(classes = App.class) 
public class MultiTest { 
 @Autowired
 private DynamicCreateBean dynamicCreateBean; 
 @Autowired
 private Run run; 
 @Test
 public void testDynamic(){ 
  dynamicCreateBean.printMethod(); 
  run.printRun(); 
 } 
}
private void registerFeignClient(BeanDefinitionRegistry registry, AnnotationMetadata annotationMetadata, Map<String, Object> attributes) { 
  String className = annotationMetadata.getClassName(); 
  BeanDefinitionBuilder definition = BeanDefinitionBuilder.genericBeanDefinition(FeignClientFactoryBean.class); 
  this.validate(attributes); 
  definition.addPropertyValue("url", this.getUrl(attributes)); 
  definition.addPropertyValue("path", this.getPath(attributes)); 
  String name = this.getName(attributes); 
  definition.addPropertyValue("name", name); 
  definition.addPropertyValue("type", className); 
  definition.addPropertyValue("decode404", attributes.get("decode404")); 
  definition.addPropertyValue("fallback", attributes.get("fallback")); 
  definition.addPropertyValue("fallbackFactory", attributes.get("fallbackFactory")); 
  definition.setAutowireMode(2); 
  String alias = name + "FeignClient"; 
  AbstractBeanDefinition beanDefinition = definition.getBeanDefinition(); 
  boolean primary = ((Boolean)attributes.get("primary")).booleanValue(); 
  beanDefinition.setPrimary(primary); 
  String qualifier = this.getQualifier(attributes); 
  if(StringUtils.hasText(qualifier)) { 
   alias = qualifier; 
  } 
  BeanDefinitionHolder holder = new BeanDefinitionHolder(beanDefinition, className, new String[]{alias}); 
  BeanDefinitionReaderUtils.registerBeanDefinition(holder, registry); 
 }
	
	
                          
	
【关注微信公众号获取更多学习资料】 【扫码进入JavaEE/微服务VIP免费公开课】