您好,登錄后才能下訂單哦!
前言
在使用Spring的過程中,我們有時候并不想通過xml的方式進行bean的注入,希望在不改變原有的程序結構的基礎上添加我們需要的bean,這個時候我們可以利用Spring的spring-beans的jar包里提供的BeanFactoryPostProcessor接口類,通過實現這個接口類,我們可以動態的加載所需要的bean,特別是在引入已經打包在jar里面的程序而沒有辦法做出修改的情況下,這個接口就為我們提供了及其方便的入口。
因為我是在其他項目的基礎上測試的這個接口,所以引入的jar有其特殊性,所以需要參考的同學可以按照自己的需求來實現。
1.通過pom.xml來引入springboot:
<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>
2.創建App.java啟動類:
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); } }
3.創建一個DynamicCreateBean.java來作為動態加載的對象:
public class DynamicCreateBean { public void printMethod(){ System.out.println("DynamicCreateBean Success"); } }
4.在本項目外另外新增一個項目打成jar的形式導入到該項目中用于測試動態加載,在我的項目中新增的是threadTest.jar,該包是一個用于多線程測試的類,需要的同學自己隨便新建一個來打成jar包測試即可。
5.新增一個LoadBean.java類用于動態加載bean:
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()); } }
6.創建測試類:
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(); } }
以上就是整個的動態加載過程,如果需要了解更多,可以在網上繼續查找資料。
最近在看spring cloud Feign相關文章時發現了另外一種注入動態bean的方式,里面的代碼提供是在FeignClientsRegistrar.java類中
具體代碼為:
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); }
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。