Spring註解驅動——擴充套件原理
阿新 • • 發佈:2020-12-24
配置類
/** * 擴充套件原理: * BeanPostProcessor:bean後置處理器,bean建立物件初始化前後進行攔截工作的 * * 1、BeanFactoryPostProcessor:beanFactory的後置處理器; * 在BeanFactory標準初始化之後呼叫,來定製和修改BeanFactory的內容; * 所有的bean定義已經儲存載入到beanFactory,但是bean的例項還未建立 * * * BeanFactoryPostProcessor原理: * 1)、ioc容器建立物件 * 2)、invokeBeanFactoryPostProcessors(beanFactory); * 如何找到所有的BeanFactoryPostProcessor並執行他們的方法; * 1)、直接在BeanFactory中找到所有型別是BeanFactoryPostProcessor的元件,並執行他們的方法 * 2)、在初始化建立其他元件前面執行 * * 2、BeanDefinitionRegistryPostProcessorextends BeanFactoryPostProcessor * postProcessBeanDefinitionRegistry(); * 在所有bean定義資訊將要被載入,bean例項還未建立的; * * 優先於BeanFactoryPostProcessor執行; * 利用BeanDefinitionRegistryPostProcessor給容器中再額外新增一些元件; * * 原理: * 1)、ioc建立物件 * 2)、refresh()-》invokeBeanFactoryPostProcessors(beanFactory); * 3)、從容器中獲取到所有的BeanDefinitionRegistryPostProcessor元件。 * 1、依次觸發所有的postProcessBeanDefinitionRegistry()方法 * 2、再來觸發postProcessBeanFactory()方法BeanFactoryPostProcessor; * * 4)、再來從容器中找到BeanFactoryPostProcessor元件;然後依次觸發postProcessBeanFactory()方法 * * 3、ApplicationListener:監聽容器中釋出的事件。事件驅動模型開發; * public interface ApplicationListener<E extends ApplicationEvent> * 監聽 ApplicationEvent 及其下面的子事件; * * 步驟: * 1)、寫一個監聽器(ApplicationListener實現類)來監聽某個事件(ApplicationEvent及其子類) * @EventListener; * 原理:使用EventListenerMethodProcessor處理器來解析方法上的@EventListener; * * 2)、把監聽器加入到容器; * 3)、只要容器中有相關事件的釋出,我們就能監聽到這個事件; * ContextRefreshedEvent:容器重新整理完成(所有bean都完全建立)會發布這個事件; * ContextClosedEvent:關閉容器會發布這個事件; * 4)、釋出一個事件: * applicationContext.publishEvent(); * * 原理: * 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); * * SmartInitializingSingleton原理:->afterSingletonsInstantiated(); * 1)、ioc容器建立物件並refresh(); * 2)、finishBeanFactoryInitialization(beanFactory);初始化剩下的單例項bean; * 1)、先建立所有的單例項bean;getBean(); * 2)、獲取所有建立好的單例項bean,判斷是否是SmartInitializingSingleton型別的; * 如果是就呼叫afterSingletonsInstantiated(); */ @ComponentScan("com.atguigu.ext") @Configuration public class ExtConfig { @Bean public Blue blue(){ return new Blue(); } }
測試類
@Component public class MyBeanFactoryPostProcessor implements BeanFactoryPostProcessor { @Override 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)); } }
@Component public class MyBeanDefinitionRegistryPostProcessor implements BeanDefinitionRegistryPostProcessor{ @Override 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例項; @Override 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); } }
@Component public class MyApplicationListener implements ApplicationListener<ApplicationEvent> { //當容器中釋出此事件以後,方法觸發 @Override public void onApplicationEvent(ApplicationEvent event) { // TODO Auto-generated method stub System.out.println("收到事件:"+event); } }
@Service public class UserService { @EventListener(classes={ApplicationEvent.class}) public void listen(ApplicationEvent event){ System.out.println("UserService。。監聽到的事件:"+event); } }
測試呼叫
public class IOCTest_Ext { @Test public void test01(){ AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext(ExtConfig.class); //釋出事件; applicationContext.publishEvent(new ApplicationEvent(new String("我釋出的時間")) { }); applicationContext.close(); } }