在上一节课我们讲到,当创建对象是一个“大工程”的时候,我们一般会选择使用工厂模式,来封装对象复杂的创建过程,将对象的创建和使用分离,让代码更加清晰。
那何为“大工程”呢?上一节课中我们讲了两种情况:

  • 一种是创建过程涉及复杂的 if-else 分支判断;
  • 另一种是对象创建需要组装多个其他类对象,或者需要复杂的初始化过程。

今天,我们再来讲一个创建对象的“大工程”,依赖注入框架,或者叫依赖注入容器(Dependency Injection Container),简称 DI 容器。
在今天的讲解中,我会带你一块搞清楚这样几个问题:

  • DI 容器跟我们讲的工厂模式又有何区别和联系?
  • DI 容器的核心功能有哪些,以及如何实现一个简单的 DI 容器?

话不多说,让我们正式开始今天的学习吧!

工厂模式和 DI 容器有何区别?

实际上,DI 容器底层最基本的设计思路就是基于工厂模式的。
DI 容器相当于一个大的工厂类,负责在程序启动的时候,根据配置(要创建哪些类对象,每个类对象的创建需要依赖哪些其他类对象)事先创建好对象。当应用程序需要使用某个类对象的时候,直接从容器中获取即可。正是因为它持有一堆对象,所以这个框架才被称为“容器”。


DI 容器相对于我们上节课讲的工厂模式的例子来说,它处理的是更大的对象创建工程。
上节课讲的工厂模式中,一个工厂类只负责某个类对象或者某一组相关类对象(继承自同一抽象类或者接口的子类)的创建,而 DI 容器负责的是整个应用中所有类对象的创建。
DI 容器负责的事情要比单纯的工厂模式要多。比如,它还包括配置的解析、对象生命周期的管理。
接下来,我们就详细讲讲,一个简单的 DI 容器应该包含哪些核心功能。

DI 容器的核心功能有哪些?

总结一下,一个简单的 DI 容器的核心功能一般有三个:配置解析、对象创建和对象生命周期管理。

配置解析

首先,我们来看配置解析。
在上节课讲的工厂模式中,工厂类要创建哪个类对象是事先确定好的,并且是写死在工厂类代码中的。
作为一个通用的框架来说,框架代码跟应用代码应该是高度解耦的,DI 容器事先并不知道应用会创建哪些对象,不可能把某个应用要创建的对象写死在框架代码中。所以,我们需要通过一种形式,让应用告知 DI 容器要创建哪些对象。这种形式就是我们要讲的配置。
我们将需要由 DI 容器来创建的类对象和创建类对象的必要信息(使用哪个构造函数以及对应的构造函数参数都是什么等等),放到配置文件中。容器读取配置文件,根据配置文件提供的信息来创建对象。


下面是一个典型的 Spring 容器的配置文件。
Spring 容器读取这个配置文件,解析出要创建的两个对象:rateLimiter 和 redisCounter,并且得到两者的依赖关系:rateLimiter 依赖 redisCounter。

  1. public class RateLimiter {
  2. private RedisCounter redisCounter;
  3. public RateLimiter(RedisCounter redisCounter) {
  4. this.redisCounter = redisCounter;
  5. }
  6. public void test() {
  7. System.out.println("Hello World!");
  8. }
  9. //...
  10. }
  11. public class RedisCounter {
  12. private String ipAddress;
  13. private int port;
  14. public RedisCounter(String ipAddress, int port) {
  15. this.ipAddress = ipAddress;
  16. this.port = port;
  17. }
  18. //...
  19. }
  20. 配置文件beans.xml
  21. <beans>
  22. <bean id="rateLimiter" class="com.xzg.RateLimiter">
  23. <constructor-arg ref="redisCounter"/>
  24. </bean>
  25. <bean id="redisCounter" class="com.xzg.redisCounter">
  26. <constructor-arg type="String" value="127.0.0.1">
  27. <constructor-arg type="int" value=1234>
  28. </bean>
  29. </beans>

对象创建

其次,我们再来看对象创建。
在 DI 容器中,如果我们给每个类都对应创建一个工厂类,那项目中类的个数会成倍增加,这会增加代码的维护成本。要解决这个问题并不难。我们只需要将所有类对象的创建都放到一个工厂类中完成就可以了,比如 BeansFactory。


你可能会说,如果要创建的类对象非常多,BeansFactory 中的代码会不会线性膨胀(代码量跟创建对象的个数成正比)呢?
实际上并不会。待会讲到 DI 容器的具体实现的时候,我们会讲“反射”这种机制,它能在程序运行的过程中,动态地加载类、创建对象,不需要事先在代码中写死要创建哪些对象。所以,不管是创建一个对象还是十个对象,BeansFactory 工厂类代码都是一样的。

对象的生命周期管理

最后,我们来看对象的生命周期管理。
上一节课我们讲到,简单工厂模式有两种实现方式:

  • 一种是每次都返回新创建的对象;
  • 另一种是每次都返回同一个事先创建好的对象,也就是所谓的单例对象。

在 Spring 框架中,我们可以通过配置 scope 属性,来区分这两种不同类型的对象。scope=prototype 表示返回新创建的对象,scope=singleton 表示返回单例对象。


除此之外,我们还可以配置对象是否支持懒加载。

  • 如果 lazy-init=true,对象在真正被使用到的时候才被创建(比如:Spring 里的通过BeansFactory.getBean(“userService”) 获取对象时菜能创建);
  • 如果 lazy-init=false,对象在应用启动的时候就事先创建好。

不仅如此,我们还可以配置对象的 init-method 和 destroy-method 方法,比如 init-method=loadProperties(),destroy-method=updateConfigFile()。
DI 容器在创建好对象之后,会主动调用 init-method 属性指定的方法来初始化对象。在对象被最终销毁之前,DI 容器会主动调用 destroy-method 属性指定的方法来做一些清理工作,比如释放数据库连接池、关闭文件。

如何实现一个简单的 DI 容器?

实际上,用 Java 语言来实现一个简单的 DI 容器,核心逻辑只需要包括这样两个部分:配置文件解析、根据配置文件通过“反射”语法来创建对象。

1. 最小原型设计

因为我们主要是讲解设计模式,所以,在今天的讲解中,我们只实现一个 DI 容器的最小原型。
像 Spring 框架这样的 DI 容器,它支持的配置格式非常灵活和复杂。
为了简化代码实现,重点讲解原理,在最小原型中,我们只支持下面配置文件中涉及的配置语法。

  1. <beans>
  2. <bean id="rateLimiter" class="com.xzg.RateLimiter">
  3. <constructor-arg ref="redisCounter"/>
  4. </bean>
  5. <bean id="redisCounter" class="com.xzg.redisCounter" scope="singleton" lazy-init="true">
  6. <constructor-arg type="String" value="127.0.0.1">
  7. <constructor-arg type="int" value=1234>
  8. </bean>
  9. </bean

最小原型的使用方式跟 Spring 框架非常类似,示例代码如下所示:

  1. public class Demo {
  2. public static void main(String[] args) {
  3. ApplicationContext applicationContext = new ClassPathXmlApplicationContext("beans.xml");
  4. RateLimiter rateLimiter = (RateLimiter) applicationContext.getBean("rateLimiter");
  5. rateLimiter.test();
  6. //...
  7. }
  8. }

2. 提供执行入口

前面我们讲到,面向对象设计的最后一步是:组装类并提供执行入口。
在这里,执行入口就是一组暴露给外部使用的接口和类。
通过刚刚的最小原型使用示例代码,我们可以看出,执行入口主要包含两部分:

  • ApplicationContext;
  • ClassPathXmlApplicationContext。

其中,ApplicationContext 是接口,ClassPathXmlApplicationContext 是接口的实现类。
两个类具体实现如下所示:

  1. public interface ApplicationContext {
  2. Object getBean(String beanId);
  3. }
  4. public class ClassPathXmlApplicationContext implements ApplicationContext {
  5. private BeansFactory beansFactory;
  6. private BeanConfigParser beanConfigParser;
  7. public ClassPathXmlApplicationContext(String configLocation) {
  8. this.beansFactory = new BeansFactory();
  9. this.beanConfigParser = new XmlBeanConfigParser();
  10. loadBeanDefinitions(configLocation);
  11. }
  12. private void loadBeanDefinitions(String configLocation) {
  13. InputStream in = null;
  14. try {
  15. in = this.getClass().getResourceAsStream("/" + configLocation);
  16. if (in == null) {
  17. throw new RuntimeException("Can not find config file: " + configLocation);
  18. }
  19. List<BeanDefinition> beanDefinitions = beanConfigParser.parse(in);
  20. beansFactory.addBeanDefinitions(beanDefinitions);
  21. } finally {
  22. if (in != null) {
  23. try {
  24. in.close();
  25. } catch (IOException e) {
  26. // TODO: log error
  27. }
  28. }
  29. }
  30. }
  31. @Override
  32. public Object getBean(String beanId) {
  33. return beansFactory.getBean(beanId);
  34. }
  35. }

从上面的代码中,我们可以看出,ClassPathXmlApplicationContext 负责组装 BeansFactory 和 BeanConfigParser 两个类,串联执行流程:从 classpath 中加载 XML 格式的配置文件,通过 BeanConfigParser 解析为统一的 BeanDefinition 格式,然后,BeansFactory 根据 BeanDefinition 来创建对象。

3. 配置文件解析

配置文件解析主要包含 BeanConfigParser 接口和 XmlBeanConfigParser 实现类,负责将配置文件解析为 BeanDefinition 结构,以便 BeansFactory 根据这个结构来创建对象。
配置文件的解析比较繁琐,不涉及我们专栏要讲的理论知识,不是我们讲解的重点,所以这里我只给出两个类的大致设计思路,并未给出具体的实现代码。如果感兴趣的话,你可以自行补充完整。
具体的代码框架如下所示:

  1. public interface BeanConfigParser {
  2. List<BeanDefinition> parse(InputStream inputStream);
  3. List<BeanDefinition> parse(String configContent);
  4. }
  5. public class XmlBeanConfigParser implements BeanConfigParser {
  6. @Override
  7. public List<BeanDefinition> parse(InputStream inputStream) {
  8. String content = null;
  9. // TODO:...
  10. return parse(content);
  11. }
  12. @Override
  13. public List<BeanDefinition> parse(String configContent) {
  14. List<BeanDefinition> beanDefinitions = new ArrayList<>();
  15. // TODO:...
  16. return beanDefinitions;
  17. }
  18. }
  19. public class BeanDefinition {
  20. private String id;
  21. private String className;
  22. private List<ConstructorArg> constructorArgs = new ArrayList<>();
  23. private Scope scope = Scope.SINGLETON;
  24. private boolean lazyInit = false;
  25. // 省略必要的getter/setter/constructors
  26. public boolean isSingleton() {
  27. return scope.equals(Scope.SINGLETON);
  28. }
  29. public static enum Scope {
  30. SINGLETON, PROTOTYPE
  31. }
  32. public static class ConstructorArg {
  33. private boolean isRef;
  34. private Class type;
  35. private Object arg;
  36. // 省略必要的getter/setter/constructors
  37. }
  38. }

4. 核心工厂类设计

最后,我们来看,BeansFactory 是如何设计和实现的。这也是我们这个 DI 容器最核心的一个类了。
BeansFactory 它负责根据从配置文件解析得到的 BeanDefinition 来创建对象。

  • 如果对象的 scope 属性是 singleton,那对象创建之后会缓存在 singletonObjects 这样一个 map 中,下次再请求此对象的时候,直接从 map 中取出返回,不需要重新创建。
  • 如果对象的 scope 属性是 prototype,那每次请求对象,BeansFactory 都会创建一个新的对象返回。

实际上,BeansFactory 创建对象用到的主要技术点就是 Java 中的反射语法:一种动态加载类和创建对象的机制。
我们知道,JVM 在启动的时候会根据代码自动地加载类、创建对象。
至于都要加载哪些类、创建哪些对象,这些都是在代码中写死的,或者说提前写好的。但是,如果某个对象的创建并不是写死在代码中,而是放到配置文件中,我们需要在程序运行期间,动态地根据配置文件来加载类、创建对象,那这部分工作就没法让 JVM 帮我们自动完成了,我们需要利用 Java 提供的反射语法自己去编写代码。


搞清楚了反射的原理,BeansFactory 的代码就不难看懂了。
具体代码实现如下所示:

  1. public class BeansFactory {
  2. private ConcurrentHashMap<String, Object> singletonObjects = new ConcurrentHashMap<>();
  3. private ConcurrentHashMap<String, BeanDefinition> beanDefinitions = new ConcurrentHashMap<>();
  4. public void addBeanDefinitions(List<BeanDefinition> beanDefinitionList) {
  5. for (BeanDefinition beanDefinition : beanDefinitionList) {
  6. this.beanDefinitions.putIfAbsent(beanDefinition.getId(), beanDefinition);
  7. }
  8. for (BeanDefinition beanDefinition : beanDefinitionList) {
  9. if (beanDefinition.isLazyInit() == false && beanDefinition.isSingleton()) {
  10. createBean(beanDefinition);
  11. }
  12. }
  13. }
  14. public Object getBean(String beanId) {
  15. BeanDefinition beanDefinition = beanDefinitions.get(beanId);
  16. if (beanDefinition == null) {
  17. throw new NoSuchBeanDefinitionException("Bean is not defined: " + beanId);
  18. }
  19. return createBean(beanDefinition);
  20. }
  21. @VisibleForTesting
  22. protected Object createBean(BeanDefinition beanDefinition) {
  23. if (beanDefinition.isSingleton() && singletonObjects.contains(beanDefinition.getId())) {
  24. return singletonObjects.get(beanDefinition.getId());
  25. }
  26. Object bean = null;
  27. try {
  28. Class beanClass = Class.forName(beanDefinition.getClassName());
  29. List<BeanDefinition.ConstructorArg> args = beanDefinition.getConstructorArgs();
  30. if (args.isEmpty()) {
  31. bean = beanClass.newInstance();
  32. } else {
  33. Class[] argClasses = new Class[args.size()];
  34. Object[] argObjects = new Object[args.size()];
  35. for (int i = 0; i < args.size(); ++i) {
  36. BeanDefinition.ConstructorArg arg = args.get(i);
  37. if (!arg.getIsRef()) {
  38. argClasses[i] = arg.getType();
  39. argObjects[i] = arg.getArg();
  40. } else {
  41. BeanDefinition refBeanDefinition = beanDefinitions.get(arg.getArg());
  42. if (refBeanDefinition == null) {
  43. throw new NoSuchBeanDefinitionException("Bean is not defined: " + arg.getArg());
  44. }
  45. argClasses[i] = Class.forName(refBeanDefinition.getClassName());
  46. argObjects[i] = createBean(refBeanDefinition);
  47. }
  48. }
  49. bean = beanClass.getConstructor(argClasses).newInstance(argObjects);
  50. }
  51. } catch (ClassNotFoundException | IllegalAccessException | InstantiationException | NoSuchMethodException |
  52. InvocationTargetException e) {
  53. throw new BeanCreationFailureException("", e);
  54. }
  55. if (bean != null && beanDefinition.isSingleton()) {
  56. singletonObjects.putIfAbsent(beanDefinition.getId(), bean);
  57. return singletonObjects.get(beanDefinition.getId());
  58. }
  59. return bean;
  60. }
  61. }

重点回顾

好了,今天的内容到此就讲完了。我们来一块总结回顾一下,你需要重点掌握的内容。
DI 容器在一些软件开发中已经成为了标配,比如 Spring IOC、Google Guice。但是,大部分人可能只是把它当作一个黑盒子来使用,并未真正去了解它的底层是如何实现的。
当然,如果只是做一些简单的小项目,简单会用就足够了,但是,如果我们面对的是非常复杂的系统,当系统出现问题的时候,对底层原理的掌握程度,决定了我们排查问题的能力,直接影响到我们排查问题的效率。


今天,我们讲解了一个简单的 DI 容器的实现原理,其核心逻辑主要包括:配置文件解析,以及根据配置文件通过“反射”语法来创建对象。其中,创建对象的过程就应用到了我们在学的工厂模式。
对象创建、组装、管理完全由 DI 容器来负责,跟具体业务代码解耦,让程序员聚焦在业务代码的开发上。

课堂讨论

BeansFactory 类中的 createBean() 函数是一个递归函数。
当构造函数的参数是 ref 类型时,会递归地创建 ref 属性指向的对象。
如果我们在配置文件中错误地配置了对象之间的依赖关系,导致存在循环依赖,那 BeansFactory 的 createBean() 函数是否会出现堆栈溢出?又该如何解决这个问题呢?