Spring源码分析(五) -- Spring中的BeanPostProcessor

BeanPostProcessor 定义

public interface BeanPostProcessor {
	//这个方法会在bean实例化后，调用初始化方法以前执行
	@Nullable
	default Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
		return bean;
	}
    //这个方法会在bean实例化后，调用初始化方法以后执行
    //这里的before和after是相对于初始化方法的调用
	@Nullable
	default Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
		return bean;
	}

}
复制代码

• 从定义中能够看出BeanPostProcessor是一个接口
• BeanPostProcessor定义了两个方法，都是default修饰的。

BeanPostProcessor 使用

Dao 类

public interface IDao {
	void query();
}

@Repository("indexDao")
public class IndexDao implements IDao {
	@Override
	public void query() {
		System.out.println("index dao");
	}
}
复制代码

InvocationHandler 类

public class InvocationHandlerTest implements InvocationHandler{

	private Object target;

	public InvocationHandlerTest(Object target) {
		this.target = target;
	}

	@Override
	public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
		System.out.println("invoke proxy");
		return method.invoke(target, args);
	}
}
复制代码

BeanPostProcessorTest 类

@Component
public class BeanPostProcessorTest implements BeanPostProcessor {
	@Override
	public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
		if (beanName.equals("indexDao")) {
			System.out.println("before");
            //使用JDK动态代理，返回一个代理类
			return Proxy.newProxyInstance(bean.getClass().getClassLoader(), bean.getClass().getInterfaces(), new InvocationHandlerTest(bean));
		}
		return bean;
	}

	@Override
	public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
		if (beanName.equals("indexDao")) {
			System.out.println("after");
		}
		return bean;
	}
}
复制代码

Appconfig 类

@Configuration
@ComponentScan("com.ktcatv")
public class Appconfig {
}
复制代码

Test 类

public class Test {

	public static void main(String[] args) {
		AnnotationConfigApplicationContext configApplicationContext = new AnnotationConfigApplicationContext(Appconfig.class);
        //这里打断点能够看出，这个IDao对象是一个代理类
        //说明原始对象在BeanPostProcessorTest中被替换了
		IDao dao = (IDao) configApplicationContext.getBean("indexDao");
		dao.query();

	}
}
复制代码