Spring注解驅動擴展原理BeanFactoryPostProcessor
1、擴展原理-BeanFactoryPostProcessor
BeanFactoryPostProcessor
* 擴展原理:* BeanPostProcessor:bean后置處理器,bean創建對象初始化前后進行攔截工作的** 1、BeanFactoryPostProcessor:beanFactory的后置處理器;* 在BeanFactory標準初始化之后調用,來定制和修改BeanFactory的內容;* 所有的bean定義已經保存加載到beanFactory,但是bean的實例還未創建*** BeanFactoryPostProcessor原理:* 1)、ioc容器創建對象* 2)、invokeBeanFactoryPostProcessors(beanFactory);* 如何找到所有的BeanFactoryPostProcessor并執行他們的方法;* 1)、直接在BeanFactory中找到所有類型是BeanFactoryPostProcessor的組件,并執行他們的方法* 2)、在初始化創建其他組件前面執行
代碼實現
@Componentpublic class MyBeanFactoryPostProcessor implements BeanFactoryPostProcessor { public void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException { System.out.println('MyBeanFactoryPostProcessor...postProcessBeanFactory...'); int count = beanFactory.getBeanDefinitionCount(); String[] names = beanFactory.getBeanDefinitionNames(); System.out.println('當前BeanFactory中有'+count+' 個Bean'); System.out.println(Arrays.asList(names)); } }
2、擴展原理-BeanDefinitionRegistryPostProcessor
BeanDefinitionRegistryPostProcessor
* 2、BeanDefinitionRegistryPostProcessor extends BeanFactoryPostProcessor* postProcessBeanDefinitionRegistry();* 在所有bean定義信息將要被加載,bean實例還未創建的;** 優先于BeanFactoryPostProcessor執行;* 利用BeanDefinitionRegistryPostProcessor給容器中再額外添加一些組件;** 原理:* 1)、ioc創建對象* 2)、refresh()-》invokeBeanFactoryPostProcessors(beanFactory);* 3)、從容器中獲取到所有的BeanDefinitionRegistryPostProcessor組件。* 1、依次觸發所有的postProcessBeanDefinitionRegistry()方法* 2、再來觸發postProcessBeanFactory()方法BeanFactoryPostProcessor;** 4)、再來從容器中找到BeanFactoryPostProcessor組件;然后依次觸發postProcessBeanFactory()方法
代碼實現
@Componentpublic class MyBeanDefinitionRegistryPostProcessor implements BeanDefinitionRegistryPostProcessor{ public void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException { // TODO Auto-generated method stub System.out.println('MyBeanDefinitionRegistryPostProcessor...bean的數量:'+beanFactory.getBeanDefinitionCount()); } //BeanDefinitionRegistry Bean定義信息的保存中心,以后BeanFactory就是按照BeanDefinitionRegistry里面保存的每一個bean定義信息創建bean實例; public void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) throws BeansException { // TODO Auto-generated method stub System.out.println('postProcessBeanDefinitionRegistry...bean的數量:'+registry.getBeanDefinitionCount()); //RootBeanDefinition beanDefinition = new RootBeanDefinition(Blue.class); AbstractBeanDefinition beanDefinition = BeanDefinitionBuilder.rootBeanDefinition(Blue.class).getBeanDefinition(); registry.registerBeanDefinition('hello', beanDefinition); } }
3、擴展原理-ApplicationListener用法
監聽器ApplicationListener
* 3、ApplicationListener:監聽容器中發布的事件。事件驅動模型開發;* public interface ApplicationListener<E extends ApplicationEvent>* 監聽 ApplicationEvent 及其下面的子事件;** 步驟:* 1)、寫一個監聽器(ApplicationListener實現類)來監聽某個事件(ApplicationEvent及其子類)* @EventListener;* 原理:使用EventListenerMethodProcessor處理器來解析方法上的@EventListener;** 2)、把監聽器加入到容器;* 3)、只要容器中有相關事件的發布,我們就能監聽到這個事件;* ContextRefreshedEvent:容器刷新完成(所有bean都完全創建)會發布這個事件;* ContextClosedEvent:關閉容器會發布這個事件;* 4)、發布一個事件:* applicationContext.publishEvent();
代碼實現:
方式一:實現ApplicationListener<E extends ApplicationEvent>接口
@Componentpublic class MyApplicationListener implements ApplicationListener<ApplicationEvent> { //當容器中發布此事件以后,方法觸發 public void onApplicationEvent(ApplicationEvent event) { // TODO Auto-generated method stub System.out.println('收到事件:'+event); }}
方式二:使用@EventListener注解標識事件監聽方法
@Servicepublic class UserService { @EventListener(classes={ApplicationEvent.class}) public void listen(ApplicationEvent event){ System.out.println('UserService。。監聽到的事件:'+event); }}
4、擴展原理-ApplicationListener原理
* 原理:* ContextRefreshedEvent、IOCTest_Ext$1[source=我發布的時間]、ContextClosedEvent;* 1)、ContextRefreshedEvent事件:* 1)、容器創建對象:refresh();* 2)、finishRefresh();容器刷新完成會發布ContextRefreshedEvent事件* 2)、自己發布事件;* 3)、容器關閉會發布ContextClosedEvent;* * 【事件發布流程】:* 3)、publishEvent(new ContextRefreshedEvent(this));* 1)、獲取事件的多播器(派發器):getApplicationEventMulticaster()* 2)、multicastEvent派發事件:* 3)、獲取到所有的ApplicationListener;* for (final ApplicationListener<?> listener : getApplicationListeners(event, type)) {* 1)、如果有Executor,可以支持使用Executor進行異步派發;* Executor executor = getTaskExecutor();* 2)、否則,同步的方式直接執行listener方法;invokeListener(listener, event);* 拿到listener回調onApplicationEvent方法;* * 【事件多播器(派發器)】* 1)、容器創建對象:refresh();* 2)、initApplicationEventMulticaster();初始化ApplicationEventMulticaster;* 1)、先去容器中找有沒有id=“applicationEventMulticaster”的組件;* 2)、如果沒有this.applicationEventMulticaster = new SimpleApplicationEventMulticaster(beanFactory);* 并且加入到容器中,我們就可以在其他組件要派發事件,自動注入這個applicationEventMulticaster;* * 【容器中有哪些監聽器】* 1)、容器創建對象:refresh();* 2)、注冊監聽器:registerListeners();* 從容器中拿到所有的監聽器,把他們注冊到applicationEventMulticaster中;* String[] listenerBeanNames = getBeanNamesForType(ApplicationListener.class, true, false);* //將listener注冊到ApplicationEventMulticaster中* getApplicationEventMulticaster().addApplicationListenerBean(listenerBeanName);
5、擴展原理-@EventListener與SmartInitializingSingleton
* SmartInitializingSingleton 原理:->afterSingletonsInstantiated();* 1)、ioc容器創建對象并refresh();* 2)、finishBeanFactoryInitialization(beanFactory);初始化剩下的單實例bean;* 1)、先創建所有的單實例bean;getBean();* 2)、獲取所有創建好的單實例bean,判斷是否是SmartInitializingSingleton類型的;* 如果是就調用afterSingletonsInstantiated();
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網。
相關文章: