淺嘗Spring注解開發_簡單理解BeanFactoryPostProcessor、BeanDefinitionRegistryPostProcessor、ApplicationListener

淺嘗Spring注解開發，基于Spring 4.3.12
分析BeanFactoryPostProcessor、BeanDefinitionRegistryPostProcessor、ApplicationListener

淺嘗Spring注解開發_自定義注冊組件、屬性賦值、自動裝配
淺嘗Spring注解開發_Bean生命周期及執行程序
淺嘗Spring注解開發_AOP原理及完整程序分析（原始碼）
淺嘗Spring注解開發_宣告式事務及原理
淺嘗Spring注解開發_簡單理解BeanFactoryPostProcessor、BeanDefinitionRegistryPostProcessor、ApplicationListener

BeanFactoryPostProcessor

• BeanPostProcessor：bean后置處理器，bean創建物件初始化前后進行攔截作業的
• BeanFactoryPostProcessor：beanFactory的后置處理器
  • 在BeanFactory標準初始化之后呼叫，來定制和修改BeanFactory的內容
  • 所有的bean定義已經保存加載到beanFactory，但是bean的實體還未創建

原理

1. ioc容器創建物件
2. refresh()->invokeBeanFactoryPostProcessors(beanFactory)
   • 如何找到所有的BeanFactoryPostProcessor并執行他們的方法？
     1. 直接在BeanFactory中找到所有型別是BeanFactoryPostProcessor的組件，
     2. 按照Ordered介面排序
     3. 依次執行它們的方法，在初始化創建其他組件前面執行

@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));
	}
}

輸出

MyBeanFactoryPostProcessor...postProcessBeanFactory...
當前BeanFactory中有9 個Bean
//[輸出所有BeanDefinitionNames...]
//創建注入容器中的一個Bean
blue...constructor

BeanDefinitionRegistryPostProcessor

• BeanDefinitionRegistryPostProcessor
  • 繼承自BeanFactoryPostProcessor：BeanDefinitionRegistryPostProcessor extends BeanFactoryPostProcessor
  • postProcessBeanDefinitionRegistry()在所有bean定義資訊將要被加載，bean實體還未創建
• 優先于BeanFactoryPostProcessor執行
• 利用BeanDefinitionRegistryPostProcessor給容器中再額外添加一些組件

原理

1. ioc創建物件
2. refresh()->invokeBeanFactoryPostProcessors(beanFactory)
3. 從容器中獲取到所有的BeanDefinitionRegistryPostProcessor組件
   1. 同樣實作了Ordered介面排序，依次觸發所有的postProcessBeanDefinitionRegistry()方法
   2. 再來觸發BeanFactoryPostProcessor方法postProcessBeanFactory()

@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());
        
        //再注冊一個Bean，兩種不同方法
		//RootBeanDefinition beanDefinition = new RootBeanDefinition(Blue.class);
		AbstractBeanDefinition beanDefinition = BeanDefinitionBuilder.rootBeanDefinition(Blue.class).getBeanDefinition();
		registry.registerBeanDefinition("hello", beanDefinition);
	}
}

輸出

//下面兩個都是MyBeanDefinitionRegistryPostProcessor方法，由于在方法內又手動注冊了一個，所以是11個
postProcessBeanDefinitionRegistry...bean的數量：10
MyBeanDefinitionRegistryPostProcessor...bean的數：11
//下面一個是BeanFactoryPostProcessor方法
MyBeanFactoryPostProcessor...postProcessBeanFactory...
當前BeanFactory中有11 個Bean
//輸出所有BeanDefinitionNames...
[org.springframework...]
//兩個Bean
blue...constructor
blue...constructor

ApplicationListener

• ApplicationListener：監聽容器中發布的事件，事件驅動模型開發

• public interface ApplicationListener<E extends ApplicationEvent>：監聽 ApplicationEvent 及其下面的子事件

步驟

1. 寫一個監聽器（ApplicationListener實作類）來監聽某個事件（ApplicationEvent及其子類），或者使用@EventListener注解標注在監聽方法上
2. 把監聽器加入到容器
3. 只要容器中有相關事件的發布，我們就能監聽到這個事件
   • ContextRefreshedEvent：容器重繪完成（所有bean都完全創建）會發布這個事件
   • ContextClosedEvent：關閉容器會發布這個事件
4. 發布一個事件
   • applicationContext.publishEvent()

自定義監聽器

@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();
	}

}

輸出

//注入Bean
blue...constructor
//監聽容器重繪事件
UserService..監聽到的事件：org.springframework.context.event.ContextRefreshedEvent[]
收到事件：org.springframework.context.event.ContextRefreshedEvent[]
UserService..監聽到的事件：com.atguigu.test.IOCTest_Ext$1[source=我發布的事件]
//監聽自定義事件
UserService..監聽到的事件：org.springframework.context.event.ContextClosedEvent[]
收到事件：com.atguigu.test.IOCTest_Ext$1[source=我發布的事件]
//監聽容器關閉事件
UserService..監聽到的事件：org.springframework.context.event.ContextClosedEvent
收到事件：org.springframework.context.event.ContextClosedEvent[]

原理

1. 發布ContextRefreshedEvent事件為例：

   1. 容器創建物件：refresh()

   2. finishRefresh()，容器重繪完成

      事件發布流程：

      1. 獲取事件的多播器（派發器）：getApplicationEventMulticaster()

      2. multicastEvent派發事件

      3. 獲取到所有的ApplicationListener

         for (final ApplicationListener<?> listener : getApplicationListeners(event, type))

         1. 如果有Executor，可以支持使用Executor進行異步派發：Executor executor = getTaskExecutor()
         2. 否則，同步的方式直接執行listener方法：invokeListener(listener, event)
         3. 拿到listener回呼onApplicationEvent方法

2. 發布自定義事件

3. 容器關閉發布ContextClosedEvent事件

事件多播器（派發器）

1. 容器創建物件：refresh()
2. initApplicationEventMulticaster()：初始化ApplicationEventMulticaster
   1. 先去容器中找有沒有id="applicationEventMulticaster"的組件
   2. 如果沒有就創建一個：this.applicationEventMulticaster = new SimpleApplicationEventMulticaster(beanFactory)，并且加入到容器中，我們就可以在其他組件要派發事件，自動注入這個applicationEventMulticaster

容器中有哪些監聽器

1. 容器創建物件：refresh()
2. registerListeners()
   1. 從容器中拿到所有的監聽器，把他們注冊到applicationEventMulticaster中String[] listenerBeanNames = getBeanNamesForType(ApplicationListener.class, true, false)
   2. 將listener注冊到ApplicationEventMulticaster中getApplicationEventMulticaster().addApplicationListenerBean(listenerBeanName)

SmartInitializingSingleton原理

@EventListener使用EventListenerMethodProcessor處理器來決議方法上的@EventListener，EventListenerMethodProcessor實作了SmartInitializingSingleton

1. ioc容器創建物件并refresh()

2. finishBeanFactoryInitialization(beanFactory)：初始化剩下的單實體bean

   1. 先創建所有的單實體bean，getBean()

   2. 獲取所有創建好的單實體bean，判斷是否是SmartInitializingSingleton型別的

      如果是就呼叫afterSingletonsInstantiated()

標籤：其他

上一篇：【Linux 網路編程】生動講解 Reactor 模式與 Proactor 模式

下一篇：wait、notify和notifyAll方法學習