本文是Spring源碼分析中的一篇,來說講Spring框架中BeanFactory解析bean的過程,先來看一個在Spring中一個基本的bean定義與使用。(也能夠來公號查看)java
package bean;
public class TestBean {
private String beanName = "beanName";
public String getBeanName() {
return beanName;
}
public void setBeanName(String beanName) {
this.beanName = beanName;
}
}
複製代碼
Spring配置文件定義以下:node
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.1.xsd">
<bean id="testBean" class="bean.TestBean">
</beans>
複製代碼
下面使用XmlBeanFactory來獲取該bean:spring
public class BeanTest {
private static final java.util.logging.Logger logger = LoggerFactory.getLogger(BeanTest.class);
@Test
public void getBeanTest() {
BeanFactory factory = new XmlBeanFactory(new ClassPathResource("root.xml"));
TestBean bean = factory.getBean("testBean");
logger.info(bean.getBeanName);
}
}
複製代碼
這個單元測試運行結果就是輸出beanName,上面就是Spring最基本的bean的獲取操做,這裏我用BeanFactory做爲容器來獲取bean的操做並很少見,在企業開發中通常是使用功能更完善的ApplicationContext,這裏先不討論這個,下面重點講解使用BeanFactory獲取bean的過程。bash
如今就來分析下上面的測試代碼,看看Spring到底爲咱們作了什麼工做,上面代碼完成功能的流程不外乎如此:框架
先來看看XmlBeanFactory源碼:ide
public class XmlBeanFactory extends DefaultListableBeanFactory {
private final XmlBeanDefinitionReader reader = new XmlBeanDefinitionReader(this);
public XmlBeanFactory(Resource resource) throws BeansException {
this(resource, null);
}
public XmlBeanFactory(Resource resource, BeanFactory parentBeanFactory) throws BeansException {
super(parentBeanFactory);
this.reader.loadBeanDefinitions(resource);
}
}
複製代碼
從上面能夠看出XmlBeanFactory繼承了DefaultListableBeanFactory,DefaultListableBeanFactory是Spring註冊加載bean的默認實現,它是整個bean加載的核心部分,XmlBeanFactory與它的不一樣點就是XmlBeanFactory使用了自定義的XML讀取器XmlBeanDefinitionReader,實現了本身的BeanDefinitionReader讀取。 XmlBeanFactory加載bean的關鍵就在於XmlBeanDefinitionReader,下面看看XmlBeanDefinitionReader的源碼(只列出部分):源碼分析
public class XmlBeanDefinitionReader extends AbstractBeanDefinitionReader {
private Class<?> documentReaderClass = DefaultBeanDefinitionDocumentReader.class;
private ProblemReporter problemReporter = new FailFastProblemReporter();
private ReaderEventListener eventListener = new EmptyReaderEventListener();
private SourceExtractor sourceExtractor = new NullSourceExtractor();
private NamespaceHandlerResolver namespaceHandlerResolver;
private DocumentLoader documentLoader = new DefaultDocumentLoader();
private EntityResolver entityResolver;
private ErrorHandler errorHandler = new SimpleSaxErrorHandler(logger);
}
複製代碼
XmlBeanDefinitionReader繼承自AbstractBeanDefinitionReader,下面是AbstractBeanDefinitionReader的源碼(只列出部分):post
public abstract class AbstractBeanDefinitionReader implements EnvironmentCapable, BeanDefinitionReader {
protected final Log logger = LogFactory.getLog(getClass());
private final BeanDefinitionRegistry registry;
private ResourceLoader resourceLoader;
private ClassLoader beanClassLoader;
private Environment environment;
private BeanNameGenerator beanNameGenerator = new DefaultBeanNameGenerator();
}
複製代碼
XmlBeanDefinitionReader主要經過如下三步來加載Spring配置文件中的bean:單元測試
瞭解以上基礎後,接下來詳細分析下一開始例子中的代碼:測試
BeanFactory factory = new XmlBeanFactory(new ClassPathResource("root.xml"));
複製代碼
先看看下面XmlBeanFactory初始化的時序圖來進一步瞭解這段代碼的執行,
public XmlBeanFactory(Resource resource) throws BeansException {
this(resource, null);
}
public XmlBeanFactory(Resource resource, BeanFactory parentBeanFactory) throws BeansException {
super(parentBeanFactory);
this.reader.loadBeanDefinitions(resource);
}
複製代碼
this.reader.loadBeanDefinition(resource)就是資源加載真正的實現,時序圖中XmlBeanDefinitionReader加載數據就是在這裏完成的。
接下來跟進this.reader.loadBeanDefinition(resource)方法裏面(只列關鍵部分):
public class XmlBeanDefinitionReader extends AbstractBeanDefinitionReader {
@Override
public int loadBeanDefinitions(Resource resource) throws BeanDefinitionStoreException {
return loadBeanDefinitions(new EncodedResource(resource));
}
}
複製代碼
在loadBeanDefinition(resource)方法裏對資源文件resource使用EncodedResource類進行編碼處理後繼續傳入loadBeanDefinitions方法,繼續跟進loadBeanDefinitions(new EncodedResource(resource))方法源碼:
public int loadBeanDefinitions(EncodedResource encodedResource) throws BeanDefinitionStoreException {
Assert.notNull(encodedResource, "EncodedResource must not be null");
if (logger.isInfoEnabled()) {
logger.info("Loading XML bean definitions from " + encodedResource.getResource());
}
// 經過屬性記錄已加載的資源
Set<EncodedResource> currentResources = this.resourcesCurrentlyBeingLoaded.get();
if (currentResources == null) {
currentResources = new HashSet<EncodedResource>(4);
this.resourcesCurrentlyBeingLoaded.set(currentResources);
}
if (!currentResources.add(encodedResource)) {
throw new BeanDefinitionStoreException(
"Detected cyclic loading of " + encodedResource + " - check your import definitions!");
}
try {
// 從resource中獲取對應的InputStream,用於下面構造InputSource
InputStream inputStream = encodedResource.getResource().getInputStream();
try {
InputSource inputSource = new InputSource(inputStream);
if (encodedResource.getEncoding() != null) {
inputSource.setEncoding(encodedResource.getEncoding());
}
// 調用doLoadBeanDefinitions方法
return doLoadBeanDefinitions(inputSource, encodedResource.getResource());
}
finally {
inputStream.close();
}
}
catch (IOException ex) {
throw new BeanDefinitionStoreException(
"IOException parsing XML document from " + encodedResource.getResource(), ex);
}
finally {
currentResources.remove(encodedResource);
if (currentResources.isEmpty()) {
this.resourcesCurrentlyBeingLoaded.remove();
}
}
}
複製代碼
繼續跟進doLoadBeanDefinitions(inputSource, encodedResource.getResource())方法,這是整個bean加載過程的核心方法,在這個方法執行bean的加載。
protected int doLoadBeanDefinitions(InputSource inputSource, Resource resource) throws BeanDefinitionStoreException {
try {
Document doc = doLoadDocument(inputSource, resource);
return registerBeanDefinitions(doc, resource);
}
/* 省略一堆catch */
}
複製代碼
跟進doLoadDocument(inputSource, resource)源碼:
protected Document doLoadDocument(InputSource inputSource, Resource resource) throws Exception {
return this.documentLoader.loadDocument(inputSource, getEntityResolver(), this.errorHandler,
getValidationModeForResource(resource), isNamespaceAware());
}
複製代碼
在doLoadDocument(inputSource, resource)方法裏就使用到了前面講的documentLoader加載Document,這裏DocumentLoader是個接口,真正調用的是其實現類DefaultDocumentLoader的loadDocument方法,跟進源碼:
public class DefaultDocumentLoader implements DocumentLoader {
@Override
public Document loadDocument(InputSource inputSource, EntityResolver entityResolver, ErrorHandler errorHandler, int validationMode, boolean namespaceAware) throws Exception {
DocumentBuilderFactory factory = createDocumentBuilderFactory(validationMode, namespaceAware);
if (logger.isDebugEnabled()) {
logger.debug("Using JAXP provider [" + factory.getClass().getName() + "]");
}
DocumentBuilder builder = createDocumentBuilder(factory, entityResolver, errorHandler);
return builder.parse(inputSource);
}
}
複製代碼
從源碼能夠看出這裏先建立DocumentBuilderFactory,再用它建立DocumentBuilder,進而解析inputSource來返回Document對象。獲得Document對象後就能夠準備註冊咱們的Bean信息了。
在上面的doLoadBeanDefinitions(inputSource, encodedResource.getResource())方法中拿到Document對象後下面就是執行registerBeanDefinitions(doc, resource)方法了,看源碼:
public int registerBeanDefinitions(Document doc, Resource resource) throws BeanDefinitionStoreException {
BeanDefinitionDocumentReader documentReader = createBeanDefinitionDocumentReader();
documentReader.setEnvironment(getEnvironment());
// 還沒註冊bean前的BeanDefinition加載個數
int countBefore = getRegistry().getBeanDefinitionCount();
// 加載註冊bean
documentReader.registerBeanDefinitions(doc, createReaderContext(resource));
// 本次加載註冊的BeanDefinition個數
return getRegistry().getBeanDefinitionCount() - countBefore;
}
複製代碼
這裏的doc就是上面的loadDocument方法加載轉換來的,從上面能夠看出主要工做是交給BeanDefinitionDocumentReader的registerBeanDefinitions()方法實現的,這裏BeanDefinitionDocumentReader是個接口,註冊bean功能在默認實現類DefaultBeanDefinitionDocumentReader的該方法實現,跟進它的源碼:
@Override
public void registerBeanDefinitions(Document doc, XmlReaderContext readerContext) {
this.readerContext = readerContext;
logger.debug("Loading bean definitions");
Element root = doc.getDocumentElement();
doRegisterBeanDefinitions(root);
}
複製代碼
到這裏經過doc.getDocumentElement()得到Element對象後,交給doRegisterBeanDefinitions()方法後就是真正執行XML文檔的解析了,跟進doRegisterBeanDefinitions()方法源碼:
protected void doRegisterBeanDefinitions(Element root) {
BeanDefinitionParserDelegate parent = this.delegate;
this.delegate = createDelegate(getReaderContext(), root, parent);
if (this.delegate.isDefaultNamespace(root)) {
String profileSpec = root.getAttribute(PROFILE_ATTRIBUTE);
if (StringUtils.hasText(profileSpec)) {
String[] specifiedProfiles = StringUtils.tokenizeToStringArray(
profileSpec, BeanDefinitionParserDelegate.MULTI_VALUE_ATTRIBUTE_DELIMITERS);
if (!getReaderContext().getEnvironment().acceptsProfiles(specifiedProfiles)) {
return;
}
}
}
preProcessXml(root);
parseBeanDefinitions(root, this.delegate);
postProcessXml(root);
this.delegate = parent;
}
複製代碼
到這裏處理流程就很清晰了,先是對profile進行處理,以後就經過parseBeanDefinitions()方法進行文檔的解析操做,跟進parseBeanDefinitions()方法源碼:
protected void parseBeanDefinitions(Element root, BeanDefinitionParserDelegate delegate) {
if (delegate.isDefaultNamespace(root)) {
NodeList nl = root.getChildNodes();
for (int i = 0; i < nl.getLength(); i++) {
Node node = nl.item(i);
if (node instanceof Element) {
Element ele = (Element) node;
// 下面對bean進行處理
if (delegate.isDefaultNamespace(ele)) {
parseDefaultElement(ele, delegate);
}
else {
delegate.parseCustomElement(ele);
}
}
}
}
else {
delegate.parseCustomElement(root);
}
}
複製代碼
上面if-else語句塊中的parseDefaultElement(ele, delegate)和delegate.parseCustomElement(ele)就是對Spring配置文件中的默認命名空間和自定義命名空間進行解析用的。在Spring的XML配置中,默認Bean聲明就如前面定義的:
<bean id="testBean" class="bean.TestBean">
複製代碼
自定義的Bean聲明如:
<tx:annotation-driven />
複製代碼
XmlBeanFactory加載bean的整個過程基本就講解到這裏了。