天天看點

確定某個BeanDefinitionRegistryPostProcessor Bean被最後執行的幾種實作方式

目錄

  • 一、事出有因
  • 二、解決方案困境
  • 三、柳暗花明,終級解決方案
    • 第一種實作方案
    • 第二種實作方案
    • 第三種實作方案
  • 四、引發的思考

​ 最近有一個場景,因同一個項目中不同JAR包依賴同一個元件,但依賴元件的版本不同,導緻無論使用哪個版本都報錯(無法同時相容兩個JAR包中所需的方法調用),經過分析發現差異的部份是在一個BEAN中的方法出入參不同而矣,故考慮通過動态替換掉這個存在相容性的BEAN,換成我們自己繼承自該BEAN類并實作适配相容方法,進而最終解決元件版本不相容問題;

​ 但在實作的編碼過程中發現,原依賴的那個BEAN并不是普通的通過标注@Compent之類的注解實作的注冊的BEAN,而是由自定義的BeanDefinitionRegistryPostProcessor BEAN類中動态注冊的BEAN,這樣BEAN的注冊順序是“無法确定”的,我原本想通過自定義一個BeanDefinitionRegistryPostProcessor BEAN類,在postProcessBeanDefinitionRegistry方法中通過找到原依賴BEAN的名字,然後移除該名稱對應的BEAN定義資訊(BeanDefinition),最後再以原BEAN的名字定義并注冊成為我自己的擴充卡的BEAN類,這樣就實作了“移花接木”的功能,然而想法是OK的但最終運作起來,發現BEAN并沒有成功被替換,究其原因發現,原來我自己定義的BeanDefinitionRegistryPostProcessor BEAN類是優先于原依賴的那個問題BEAN所對應的BeanDefinitionRegistryPostProcessor BEAN類之前執行的,這樣就會導緻在我的自定義BeanDefinitionRegistryPostProcessor BEAN類postProcessBeanDefinitionRegistry方法中并沒有找到原依賴BEAN名字對應的BeanDefinition,也就無法進行正常的替換了,如果說文字難看懂,可以見如下圖所示:

確定某個BeanDefinitionRegistryPostProcessor Bean被最後執行的幾種實作方式

​ 既然問題根源找到,那確定一個自定義的BeanDefinitionRegistryPostProcessor 類被最後定義為Bean、且被最後執行成為關鍵(至少得比原依賴的那個問題BEAN所對應的BeanDefinitionRegistryPostProcessor BEAN類【如:OldBeanDefinitionRegistryPostProcessor】之後執行才行),因為這樣我們才能獲得原依賴的問題Bean的BeanDefinition,才能進行正常的替換BeanDefinition,最終達到原來依賴問題Bean的自動都依賴到新的擴充卡Bean,進而可以控制修改問題方法的中的邏輯(比如:相容、降級)。當然,我估計此時有人會想說,何必這麼麻煩,一個AOP切面不就搞定了嗎?通過實作@Around切面,把有問題的方法攔截替換成自己的适配方法邏輯,這種确實也是一種有效手段,但我認為不夠優雅,而且代碼的可讀性不強且未必能覆寫所有方法,比如:如果涉及問題方法内部依賴的内部方法(如protected)過多或依賴的其它BEAN過多時,可能就會導緻這個切面類裡面要複制一堆的原問題BEAN類中的内部方法到切面類中,但這樣帶來的風險就是代碼重複及原代碼更新後導緻的不一緻等隐性問題,故我的原則是:如果隻是簡單的替換原有方法且邏輯不複雜的可以使用AOP切面來解決,但如果涉及複雜的業務邏輯且内部依賴過多,這時采取代理、适配或裝飾可能更為合适一些。

好了,如下就是我要分享的三種:確定一個自定義的BeanDefinitionRegistryPostProcessor 類被最後定義為Bean、且被最後執行的實作方式。

第一種:通過嵌套注冊自定義的BeanDefinitionRegistryPostProcessor 類BEAN的方式,這種方式實作思路是:PostProcessorRegistrationDelegate.invokeBeanFactoryPostProcessors會先執行已獲得BeanDefinitionRegistryPostProcessor BEAN集合,執行完這些BEAN集合後(這裡我稱為第一輪或第一層),會再次嘗試擷取第二輪、第三輪一直到擷取的BeanDefinitionRegistryPostProcessor BEAN集合全部處理完成為止,架構相關代碼片段如下:

boolean reiterate = true;
			while (reiterate) {
				reiterate = false;
				postProcessorNames = beanFactory.getBeanNamesForType(BeanDefinitionRegistryPostProcessor.class, true, false);
				for (String ppName : postProcessorNames) {
					if (!processedBeans.contains(ppName)) {
						currentRegistryProcessors.add(beanFactory.getBean(ppName, BeanDefinitionRegistryPostProcessor.class));
						processedBeans.add(ppName);
						reiterate = true;
					}
				}
				sortPostProcessors(currentRegistryProcessors, beanFactory);
				registryProcessors.addAll(currentRegistryProcessors);
				invokeBeanDefinitionRegistryPostProcessors(currentRegistryProcessors, registry);
				currentRegistryProcessors.clear();
			}
           

實作方式代碼如下:

//如下是第一層自定義的BeanDefinitionRegistryPostProcessor BEAN,内部再注冊真正用于替換BEAN目的NewBeanDefinitionRegistryPostProcessor BEAN
//author:zuowenjun
@Component
public class FirstDynamicBeanPostProcessor implements BeanDefinitionRegistryPostProcessor {
    @Override
    public void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry beanDefinitionRegistry) throws BeansException {
   BeanDefinitionBuilder beanDefinitionBuilder=BeanDefinitionBuilder.genericBeanDefinition(NewBeanDefinitionRegistryPostProcessor.class);
beanDefinitionRegistry.registerBeanDefinition("newBeanDefinitionRegistryPostProcessor",beanDefinitionBuilder.getBeanDefinition());
        System.out.printf("【%1$tF %1$tT.%1$tL】%s,FirstDynamicBeanPostProcessor.postProcessBeanDefinitionRegistry%n", new Date());
    }

    @Override
    public void postProcessBeanFactory(ConfigurableListableBeanFactory configurableListableBeanFactory) throws BeansException {
        System.out.printf("【%1$tF %1$tT.%1$tL】%s,FirstDynamicBeanPostProcessor.postProcessBeanFactory%n", new Date());
    }
}

//用于将原依賴的問題Bean替換為同名的新的擴充卡Bean(下文中所有替換方式最終都要使用該類)
public class NewBeanDefinitionRegistryPostProcessor implements BeanDefinitionRegistryPostProcessor {
    @Override
    public void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry beanDefinitionRegistry) throws BeansException {
        System.out.printf("【%1$tF %1$tT.%1$tL】%s,NewBeanDefinitionRegistryPostProcessor.postProcessBeanDefinitionRegistry%n",new Date());
        boolean isContainsSpecialBean = ((DefaultListableBeanFactory) beanDefinitionRegistry).containsBean("old問題Bean名稱");
        if (isContainsSpecialBean) {
            beanDefinitionRegistry.removeBeanDefinition("old問題Bean名稱");
            BeanDefinitionBuilder beanDefinitionBuilder = BeanDefinitionBuilder.genericBeanDefinition(DemoCompentB.class);
            beanDefinitionBuilder.addConstructorArgValue(((DefaultListableBeanFactory) beanDefinitionRegistry).getBean(NewBeanAdapter.class)); //NewBeanAdapter為繼承自old問題Bean的裝飾者、擴充卡類
            AbstractBeanDefinition beanDefinition = beanDefinitionBuilder.getBeanDefinition();
            beanDefinition.setPrimary(true);
            beanDefinitionRegistry.registerBeanDefinition("old問題Bean名稱", beanDefinition);
        }

    }

    @Override
    public void postProcessBeanFactory(ConfigurableListableBeanFactory configurableListableBeanFactory) throws BeansException {
        System.out.printf("【%1$tF %1$tT.%1$tL】%s,NewBeanDefinitionRegistryPostProcessor.postProcessBeanFactory%n",new Date());
    }
}

           

最終執行的順序如下:(可以看到NewBeanDefinitionRegistryPostProcessor是在OldBeanDefinitionRegistryPostProcessor之後執行的,這樣就可以正常替換Bean定義了)

FirstDynamicBeanPostProcessor.postProcessBeanDefinitionRegistry (第一輪)

OldBeanDefinitionRegistryPostProcessor.postProcessBeanDefinitionRegistry (第一輪)

NewBeanDefinitionRegistryPostProcessor.postProcessBeanDefinitionRegistry (第二輪)

FirstDynamicBeanPostProcessor.postProcessBeanFactory

OldBeanDefinitionRegistryPostProcessor.postProcessBeanFactory

NewBeanDefinitionRegistryPostProcessor.postProcessBeanFactory

第二種:通過額外定義一個BeanDefinitionRegistryPostProcessor BEAN并實作PriorityOrdered、BeanFactoryAware接口,確定該BEAN最先被執行(Order=0),然後在postProcessBeanDefinitionRegistry方法中通過applicationContext.setDependencyComparator設定自定義的排序器,達到排序BeanDefinitionRegistryPostProcessor BEAN集合的執行順序,這種方式實作思路是:在執行BeanDefinitionRegistryPostProcessor BEAN集合前會調用

sortPostProcessors

方法進行排序,而排序規則又依賴于DependencyComparator,通過控制排序規則實作間接控制執行順序,先看架構的代碼片段:

private static void sortPostProcessors(List<?> postProcessors, ConfigurableListableBeanFactory beanFactory) {
		Comparator<Object> comparatorToUse = null;
		if (beanFactory instanceof DefaultListableBeanFactory) {
			comparatorToUse = ((DefaultListableBeanFactory) beanFactory).getDependencyComparator();
		}
		if (comparatorToUse == null) {
			comparatorToUse = OrderComparator.INSTANCE;
		}
		postProcessors.sort(comparatorToUse);
	}

//如下是invokeBeanFactoryPostProcessors方法片段:
sortPostProcessors(currentRegistryProcessors, beanFactory);
				registryProcessors.addAll(currentRegistryProcessors);
				invokeBeanDefinitionRegistryPostProcessors(currentRegistryProcessors, registry);
           
@Component
    public static class FirstBeanDefinitionRegistryPostProcessor implements BeanDefinitionRegistryPostProcessor, PriorityOrdered
        , BeanFactoryAware {

        private BeanFactory beanFactory;

        @Override
        public void setBeanFactory(BeanFactory beanFactory) throws BeansException {
            this.beanFactory=beanFactory;
       }

        @Override
        public void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry beanDefinitionRegistry) throws BeansException {
            ((DefaultListableBeanFactory) beanFactory).setDependencyComparator(new OrderComparator(){
                @Override
                protected int getOrder(Object obj) {
                    if (obj instanceof NewBeanDefinitionRegistryPostProcessor){ //如果是NewBeanDefinitionRegistryPostProcessor則将它的排序序号設定為最大
                        return Integer.MAX_VALUE;
                    }
                    return super.getOrder(obj)-1; //其餘的全部設為比它小1
                }
            });
            System.out.printf("【%1$tF %1$tT.%1$tL】%s,FirstBeanDefinitionRegistryPostProcessor.postProcessBeanDefinitionRegistry%n", new Date());
        }

        @Override
        public void postProcessBeanFactory(ConfigurableListableBeanFactory configurableListableBeanFactory) throws BeansException {
            System.out.printf("【%1$tF %1$tT.%1$tL】%s,FirstBeanDefinitionRegistryPostProcessor.postProcessBeanFactory%n", new Date());
        }

        @Override
        public int getOrder() {
            return 0;//確定
        }
    }
           

最終執行的順序如下:(NewBeanDefinitionRegistryPostProcessor在OldBeanDefinitionRegistryPostProcessor後面執行)

FirstBeanDefinitionRegistryPostProcessor.postProcessBeanDefinitionRegistry (第1批:實作PriorityOrdered執行)

OldBeanDefinitionRegistryPostProcessor.postProcessBeanDefinitionRegistry (第3批:普通BEAN執行)

NewBeanDefinitionRegistryPostProcessor.postProcessBeanDefinitionRegistry (第3批:普通BEAN執行)

FirstBeanDefinitionRegistryPostProcessor.postProcessBeanFactory

第三種:通過自定義DeferredImportSelector類并配合@Import注解,實作NewBeanDefinitionRegistryPostProcessor最後才被注冊成為BEAN,最後才有機會執行,這種方式實作思路是:因為DeferredImportSelector的執行時機是在所有

@Configuration

類型bean解析之後。

public static class BeansImportSelector implements DeferredImportSelector {
        @Override
        public String[] selectImports(AnnotationMetadata importingClassMetadata) {
            return new String[]{NewBeanDefinitionRegistryPostProcessor.class.getName()};
        }
    }

@Configuration
@Import(BeansImportSelector.class)
public class BeansConfig {
    
}
           

OldBeanDefinitionRegistryPostProcessor.postProcessBeanDefinitionRegistry

NewBeanDefinitionRegistryPostProcessor.postProcessBeanDefinitionRegistry

如上就是三種實作方式,至于哪種方式最好,這要看具體的場景,第一種、第三種影響面相對較小,而第二種因為涉及更換DependencyComparator,可能影響的是全局。另外之是以會研究如上實作方式,主要原因還是因為我們的項目架構代碼沒有考慮擴充性及規範性,比如要動态注冊BEAN,至少應實作PriorityOrdered或Order接口或指明@Order注解,這樣當我們在某些特定場景需要做一下優化或替換時,則可以直接采取相同的方式但指定Order在前或在後即可,也就不用這麼複雜了,比如:

@Component
public class OldBeanDefinitionRegistryPostProcessor implements BeanDefinitionRegistryPostProcessor,Order {
    
        @Override
        public int getOrder() {
            return 100;
        }
    
    ...
}

@Component
public class NewBeanDefinitionRegistryPostProcessor implements BeanDefinitionRegistryPostProcessor,Order {
    
        @Override
        public int getOrder() {
            return 101;//隻需序号在OldBeanDefinitionRegistryPostProcessor.getOrder之後即可
        }
    
    ...
}