上一节课,我们讲解了 Spring 中支持扩展功能的两种设计模式:观察者模式和模板模式。这两种模式能够帮助我们创建扩展点,让框架的使用者在不修改源码的情况下,基于扩展点定制化框架功能。

实际上,Spring 框架中用到的设计模式非常多,不下十几种。我们今天就总结罗列一下它们。限于篇幅,我不可能对每种设计模式都进行非常详细的讲解。有些前面已经讲过的或者比较简单的,我就点到为止。如果有什么不是很懂的地方,你可以通过阅读源码,查阅之前的理论讲解,自己去搞定它。如果一直跟着我的课程学习,相信你现在已经具备这样的学习能力。

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

适配器模式在 Spring 中的应用

在 Spring MVC 中,定义一个 Controller 最常用的方式是,通过 @Controller 注解来标记某个类是 Controller 类,通过 @RequesMapping 注解来标记函数对应的 URL。不过,定义一个 Controller 远不止这一种方法。我们还可以通过让类实现 Controller 接口或者 Servlet 接口,来定义一个 Controller。针对这三种定义方式,我写了三段示例代码,如下所示:

  1. // 方法一:通过@Controller、@RequestMapping来定义
  2. @Controller
  3. public class DemoController {
  4. @RequestMapping("/employname")
  5. public ModelAndView getEmployeeName() {
  6. ModelAndView model = new ModelAndView("Greeting");
  7. model.addObject("message", "Dinesh");
  8. return model;
  9. }
  10. }
  11. // 方法二:实现Controller接口 + xml配置文件:配置DemoController与URL的对应关系
  12. public class DemoController implements Controller {
  13. @Override
  14. public ModelAndView handleRequest(HttpServletRequest req, HttpServletResponse resp) throws Exception {
  15. ModelAndView model = new ModelAndView("Greeting");
  16. model.addObject("message", "Dinesh Madhwal");
  17. return model;
  18. }
  19. }
  20. // 方法三:实现Servlet接口 + xml配置文件:配置DemoController类与URL的对应关系
  21. public class DemoServlet extends HttpServlet {
  22. @Override
  23. protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
  24. this.doPost(req, resp);
  25. }
  26. @Override
  27. protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
  28. resp.getWriter().write("Hello World.");
  29. }
  30. }

在应用启动的时候,Spring 容器会加载这些 Controller 类,并且解析出 URL 对应的处理函数,封装成 Handler 对象,存储到 HandlerMapping 对象中。当有请求到来的时候,DispatcherServlet 从 HanderMapping 中,查找请求 URL 对应的 Handler,然后调用执行 Handler 对应的函数代码,最后将执行结果返回给客户端。

但是,不同方式定义的 Controller,其函数的定义(函数名、入参、返回值等)是不统一的。如上示例代码所示,方法一中的函数的定义很随意、不固定,方法二中的函数定义是 handleRequest()、方法三中的函数定义是 service()(看似是定义了 doGet()、doPost(),实际上,这里用到了模板模式,Servlet 中的 service() 调用了 doGet() 或 doPost() 方法,DispatcherServlet 调用的是 service() 方法)。DispatcherServlet 需要根据不同类型的 Controller,调用不同的函数。下面是具体的伪代码:

  1. Handler handler = handlerMapping.get(URL);
  2. if (handler instanceof Controller) {
  3. ((Controller)handler).handleRequest(...);
  4. } else if (handler instanceof Servlet) {
  5. ((Servlet)handler).service(...);
  6. } else if (hanlder 对应通过注解来定义的Controller) {
  7. 反射调用方法...
  8. }

从代码中我们可以看出,这种实现方式会有很多 if-else 分支判断,而且,如果要增加一个新的 Controller 的定义方法,我们就要在 DispatcherServlet 类代码中,对应地增加一段如上伪代码所示的 if 逻辑。这显然不符合开闭原则。

实际上,我们可以利用是适配器模式对代码进行改造,让其满足开闭原则,能更好地支持扩展。在第 51 节课中,我们讲到,适配器其中一个作用是“统一多个类的接口设计”。利用适配器模式,我们将不同方式定义的 Controller 类中的函数,适配为统一的函数定义。这样,我们就能在 DispatcherServlet 类代码中,移除掉 if-else 分支判断逻辑,调用统一的函数。

刚刚讲了大致的设计思路,我们再具体看下 Spring 的代码实现。

Spring 定义了统一的接口 HandlerAdapter,并且对每种 Controller 定义了对应的适配器类。这些适配器类包括:AnnotationMethodHandlerAdapter、SimpleControllerHandlerAdapter、SimpleServletHandlerAdapter 等。源码我贴到了下面,你可以结合着看下。

  1. public interface HandlerAdapter {
  2. boolean supports(Object var1);
  3. ModelAndView handle(HttpServletRequest var1, HttpServletResponse var2, Object var3) throws Exception;
  4. long getLastModified(HttpServletRequest var1, Object var2);
  5. }
  6. // 对应实现Controller接口的Controller
  7. public class SimpleControllerHandlerAdapter implements HandlerAdapter {
  8. public SimpleControllerHandlerAdapter() {
  9. }
  10. public boolean supports(Object handler) {
  11. return handler instanceof Controller;
  12. }
  13. public ModelAndView handle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
  14. return ((Controller)handler).handleRequest(request, response);
  15. }
  16. public long getLastModified(HttpServletRequest request, Object handler) {
  17. return handler instanceof LastModified ? ((LastModified)handler).getLastModified(request) : -1L;
  18. }
  19. }
  20. // 对应实现Servlet接口的Controller
  21. public class SimpleServletHandlerAdapter implements HandlerAdapter {
  22. public SimpleServletHandlerAdapter() {
  23. }
  24. public boolean supports(Object handler) {
  25. return handler instanceof Servlet;
  26. }
  27. public ModelAndView handle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
  28. ((Servlet)handler).service(request, response);
  29. return null;
  30. }
  31. public long getLastModified(HttpServletRequest request, Object handler) {
  32. return -1L;
  33. }
  34. }
  35. //AnnotationMethodHandlerAdapter对应通过注解实现的Controller,
  36. //代码太多了,我就不贴在这里了

在 DispatcherServlet 类中,我们就不需要区分对待不同的 Controller 对象了,统一调用 HandlerAdapter 的 handle() 函数就可以了。按照这个思路实现的伪代码如下所示。你看,这样就没有烦人的 if-else 逻辑了吧?

  1. // 之前的实现方式
  2. Handler handler = handlerMapping.get(URL);
  3. if (handler instanceof Controller) {
  4. ((Controller)handler).handleRequest(...);
  5. } else if (handler instanceof Servlet) {
  6. ((Servlet)handler).service(...);
  7. } else if (hanlder 对应通过注解来定义的Controller) {
  8. 反射调用方法...
  9. }
  10. // 现在实现方式
  11. HandlerAdapter handlerAdapter = handlerMapping.get(URL);
  12. handlerAdapter.handle(...);

策略模式在 Spring 中的应用

我们前面讲到,Spring AOP 是通过动态代理来实现的。熟悉 Java 的同学应该知道,具体到代码实现,Spring 支持两种动态代理实现方式,一种是 JDK 提供的动态代理实现方式,另一种是 Cglib 提供的动态代理实现方式。

前者需要被代理的类有抽象的接口定义,后者不需要(这两种动态代理实现方式的更多区别请自行百度研究吧)。针对不同的被代理类,Spring 会在运行时动态地选择不同的动态代理实现方式。这个应用场景实际上就是策略模式的典型应用场景。

我们前面讲过,策略模式包含三部分,策略的定义、创建和使用。接下来,我们具体看下,这三个部分是如何体现在 Spring 源码中的。

在策略模式中,策略的定义这一部分很简单。我们只需要定义一个策略接口,让不同的策略类都实现这一个策略接口。对应到 Spring 源码,AopProxy 是策略接口,JdkDynamicAopProxy、CglibAopProxy 是两个实现了 AopProxy 接口的策略类。其中,AopProxy 接口的定义如下所示:

  1. public interface AopProxy {
  2. Object getProxy();
  3. Object getProxy(ClassLoader var1);
  4. }

在策略模式中,策略的创建一般通过工厂方法来实现。对应到 Spring 源码,AopProxyFactory 是一个工厂类接口,DefaultAopProxyFactory 是一个默认的工厂类,用来创建 AopProxy 对象。两者的源码如下所示:

  1. public interface AopProxyFactory {
  2. AopProxy createAopProxy(AdvisedSupport var1) throws AopConfigException;
  3. }
  4. public class DefaultAopProxyFactory implements AopProxyFactory, Serializable {
  5. public DefaultAopProxyFactory() {
  6. }
  7. public AopProxy createAopProxy(AdvisedSupport config) throws AopConfigException {
  8. if (!config.isOptimize() && !config.isProxyTargetClass() && !this.hasNoUserSuppliedProxyInterfaces(config)) {
  9. return new JdkDynamicAopProxy(config);
  10. } else {
  11. Class<?> targetClass = config.getTargetClass();
  12. if (targetClass == null) {
  13. throw new AopConfigException("TargetSource cannot determine target class: Either an interface or a target is required for proxy creation.");
  14. } else {
  15. return (AopProxy)(!targetClass.isInterface() && !Proxy.isProxyClass(targetClass) ? new ObjenesisCglibAopProxy(config) : new JdkDynamicAopProxy(config));
  16. }
  17. }
  18. }
  19. //用来判断用哪个动态代理实现方式
  20. private boolean hasNoUserSuppliedProxyInterfaces(AdvisedSupport config) {
  21. Class<?>[] ifcs = config.getProxiedInterfaces();
  22. return ifcs.length == 0 || ifcs.length == 1 && SpringProxy.class.isAssignableFrom(ifcs[0]);
  23. }
  24. }

策略模式的典型应用场景,一般是通过环境变量、状态值、计算结果等动态地决定使用哪个策略。对应到 Spring 源码中,我们可以参看刚刚给出的 DefaultAopProxyFactory 类中的 createAopProxy() 函数的代码实现。其中,第 10 行代码是动态选择哪种策略的判断条件。

组合模式在 Spring 中的应用

上节课讲到 Spring“再封装、再抽象”设计思想的时候,我们提到了 Spring Cache。Spring Cache 提供了一套抽象的 Cache 接口。使用它我们能够统一不同缓存实现(Redis、Google Guava…)的不同的访问方式。Spring 中针对不同缓存实现的不同缓存访问类,都依赖这个接口,比如:EhCacheCache、GuavaCache、NoOpCache、RedisCache、JCacheCache、ConcurrentMapCache、CaffeineCache。Cache 接口的源码如下所示:

  1. public interface Cache {
  2. String getName();
  3. Object getNativeCache();
  4. Cache.ValueWrapper get(Object var1);
  5. <T> T get(Object var1, Class<T> var2);
  6. <T> T get(Object var1, Callable<T> var2);
  7. void put(Object var1, Object var2);
  8. Cache.ValueWrapper putIfAbsent(Object var1, Object var2);
  9. void evict(Object var1);
  10. void clear();
  11. public static class ValueRetrievalException extends RuntimeException {
  12. private final Object key;
  13. public ValueRetrievalException(Object key, Callable<?> loader, Throwable ex) {
  14. super(String.format("Value for key '%s' could not be loaded using '%s'", key, loader), ex);
  15. this.key = key;
  16. }
  17. public Object getKey() {
  18. return this.key;
  19. }
  20. }
  21. public interface ValueWrapper {
  22. Object get();
  23. }
  24. }

在实际的开发中,一个项目有可能会用到多种不同的缓存,比如既用到 Google Guava 缓存,也用到 Redis 缓存。除此之外,同一个缓存实例,也可以根据业务的不同,分割成多个小的逻辑缓存单元(或者叫作命名空间)。

为了管理多个缓存,Spring 还提供了缓存管理功能。不过,它包含的功能很简单,主要有这样两部分:一个是根据缓存名字(创建 Cache 对象的时候要设置 name 属性)获取 Cache 对象;另一个是获取管理器管理的所有缓存的名字列表。对应的 Spring 源码如下所示:

  1. public interface CacheManager {
  2. Cache getCache(String var1);
  3. Collection<String> getCacheNames();
  4. }

刚刚给出的是 CacheManager 接口的定义,那如何来实现这两个接口呢?实际上,这就要用到了我们之前讲过的组合模式。

我们前面讲过,组合模式主要应用在能表示成树形结构的一组数据上。树中的结点分为叶子节点和中间节点两类。对应到 Spring 源码,EhCacheManager、SimpleCacheManager、NoOpCacheManager、RedisCacheManager 等表示叶子节点,CompositeCacheManager 表示中间节点。

叶子节点包含的是它所管理的 Cache 对象,中间节点包含的是其他 CacheManager 管理器,既可以是 CompositeCacheManager,也可以是具体的管理器,比如 EhCacheManager、RedisManager 等。

我把 CompositeCacheManger 的代码贴到了下面,你可以结合着讲解一块看下。其中,getCache()、getCacheNames() 两个函数的实现都用到了递归。这正是树形结构最能发挥优势的地方。

  1. public class CompositeCacheManager implements CacheManager, InitializingBean {
  2. private final List<CacheManager> cacheManagers = new ArrayList();
  3. private boolean fallbackToNoOpCache = false;
  4. public CompositeCacheManager() {
  5. }
  6. public CompositeCacheManager(CacheManager... cacheManagers) {
  7. this.setCacheManagers(Arrays.asList(cacheManagers));
  8. }
  9. public void setCacheManagers(Collection<CacheManager> cacheManagers) {
  10. this.cacheManagers.addAll(cacheManagers);
  11. }
  12. public void setFallbackToNoOpCache(boolean fallbackToNoOpCache) {
  13. this.fallbackToNoOpCache = fallbackToNoOpCache;
  14. }
  15. public void afterPropertiesSet() {
  16. if (this.fallbackToNoOpCache) {
  17. this.cacheManagers.add(new NoOpCacheManager());
  18. }
  19. }
  20. public Cache getCache(String name) {
  21. Iterator var2 = this.cacheManagers.iterator();
  22. Cache cache;
  23. do {
  24. if (!var2.hasNext()) {
  25. return null;
  26. }
  27. CacheManager cacheManager = (CacheManager)var2.next();
  28. cache = cacheManager.getCache(name);
  29. } while(cache == null);
  30. return cache;
  31. }
  32. public Collection<String> getCacheNames() {
  33. Set<String> names = new LinkedHashSet();
  34. Iterator var2 = this.cacheManagers.iterator();
  35. while(var2.hasNext()) {
  36. CacheManager manager = (CacheManager)var2.next();
  37. names.addAll(manager.getCacheNames());
  38. }
  39. return Collections.unmodifiableSet(names);
  40. }
  41. }

装饰器模式在 Spring 中的应用

我们知道,缓存一般都是配合数据库来使用的。如果写缓存成功,但数据库事务回滚了,那缓存中就会有脏数据。为了解决这个问题,我们需要将缓存的写操作和数据库的写操作,放到同一个事务中,要么都成功,要么都失败。

实现这样一个功能,Spring 使用到了装饰器模式。TransactionAwareCacheDecorator 增加了对事务的支持,在事务提交、回滚的时候分别对 Cache 的数据进行处理。

TransactionAwareCacheDecorator 实现 Cache 接口,并且将所有的操作都委托给 targetCache 来实现,对其中的写操作添加了事务功能。这是典型的装饰器模式的应用场景和代码实现,我就不多作解释了。

  1. public class TransactionAwareCacheDecorator implements Cache {
  2. private final Cache targetCache;
  3. public TransactionAwareCacheDecorator(Cache targetCache) {
  4. Assert.notNull(targetCache, "Target Cache must not be null");
  5. this.targetCache = targetCache;
  6. }
  7. public Cache getTargetCache() {
  8. return this.targetCache;
  9. }
  10. public String getName() {
  11. return this.targetCache.getName();
  12. }
  13. public Object getNativeCache() {
  14. return this.targetCache.getNativeCache();
  15. }
  16. public ValueWrapper get(Object key) {
  17. return this.targetCache.get(key);
  18. }
  19. public <T> T get(Object key, Class<T> type) {
  20. return this.targetCache.get(key, type);
  21. }
  22. public <T> T get(Object key, Callable<T> valueLoader) {
  23. return this.targetCache.get(key, valueLoader);
  24. }
  25. public void put(final Object key, final Object value) {
  26. if (TransactionSynchronizationManager.isSynchronizationActive()) {
  27. TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
  28. public void afterCommit() {
  29. TransactionAwareCacheDecorator.this.targetCache.put(key, value);
  30. }
  31. });
  32. } else {
  33. this.targetCache.put(key, value);
  34. }
  35. }
  36. public ValueWrapper putIfAbsent(Object key, Object value) {
  37. return this.targetCache.putIfAbsent(key, value);
  38. }
  39. public void evict(final Object key) {
  40. if (TransactionSynchronizationManager.isSynchronizationActive()) {
  41. TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
  42. public void afterCommit() {
  43. TransactionAwareCacheDecorator.this.targetCache.evict(key);
  44. }
  45. });
  46. } else {
  47. this.targetCache.evict(key);
  48. }
  49. }
  50. public void clear() {
  51. if (TransactionSynchronizationManager.isSynchronizationActive()) {
  52. TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
  53. public void afterCommit() {
  54. TransactionAwareCacheDecorator.this.targetCache.clear();
  55. }
  56. });
  57. } else {
  58. this.targetCache.clear();
  59. }
  60. }
  61. }

工厂模式在 Spring 中的应用

在 Spring 中,工厂模式最经典的应用莫过于实现 IOC 容器,对应的 Spring 源码主要是 BeanFactory 类和 ApplicationContext 相关类(AbstractApplicationContext、ClassPathXmlApplicationContext、FileSystemXmlApplicationContext…)。除此之外,在理论部分,我还带你手把手实现了一个简单的 IOC 容器。你可以回过头去再看下。

在 Spring 中,创建 Bean 的方式有很多种,比如前面提到的纯构造函数、无参构造函数加 setter 方法。我写了一个例子来说明这两种创建方式,代码如下所示:

  1. public class Student {
  2. private long id;
  3. private String name;
  4. public Student(long id, String name) {
  5. this.id = id;
  6. this.name = name;
  7. }
  8. public void setId(long id) {
  9. this.id = id;
  10. }
  11. public void setName(String name) {
  12. this.name = name;
  13. }
  14. }
  15. // 使用构造函数来创建Bean
  16. <bean id="student" class="com.xzg.cd.Student">
  17. <constructor-arg name="id" value="1"/>
  18. <constructor-arg name="name" value="wangzheng"/>
  19. </bean>
  20. // 使用无参构造函数+setter方法来创建Bean
  21. <bean id="student" class="com.xzg.cd.Student">
  22. <property name="id" value="1"></property>
  23. <property name="name" value="wangzheng"></property>
  24. </bean>

实际上,除了这两种创建 Bean 的方式之外,我们还可以通过工厂方法来创建 Bean。还是刚刚这个例子,用这种方式来创建 Bean 的话就是下面这个样子:

public class StudentFactory {
  private static Map<Long, Student> students = new HashMap<>();

  static{
    map.put(1, new Student(1,"wang"));
    map.put(2, new Student(2,"zheng"));
    map.put(3, new Student(3,"xzg"));
  }

  public static Student getStudent(long id){
    return students.get(id);
  }
}

// 通过工厂方法getStudent(2)来创建BeanId="zheng""的Bean
<bean id="zheng" class="com.xzg.cd.StudentFactory" factory-method="getStudent">
    <constructor-arg value="2"></constructor-arg>           
</bean>

其他模式在 Spring 中的应用

前面的几个模式在 Spring 中的应用讲解的都比较详细,接下来的几个模式,大部分都是我们之前讲过的,这里只是简单总结一下,点到为止,如果你对哪块有遗忘,可以回过头去看下理论部分的讲解。

SpEL,全称叫 Spring Expression Language,是 Spring 中常用来编写配置的表达式语言。它定义了一系列的语法规则。我们只要按照这些语法规则来编写表达式,Spring 就能解析出表达式的含义。实际上,这就是我们前面讲到的解释器模式的典型应用场景。

因为解释器模式没有一个非常固定的代码实现结构,而且 Spring 中 SpEL 相关的代码也比较多,所以这里就不带你一块阅读源码了。如果感兴趣或者项目中正好要实现类似的功能的时候,你可以再去阅读、借鉴它的代码实现。代码主要集中在 spring-expresssion 这个模块下面。

前面讲到单例模式的时候,我提到过,单例模式有很多弊端,比如单元测试不友好等。应对策略就是通过 IOC 容器来管理对象,通过 IOC 容器来实现对象的唯一性的控制。实际上,这样实现的单例并非真正的单例,它的唯一性的作用范围仅仅在同一个 IOC 容器内。

除此之外,Spring 还用到了观察者模式、模板模式、职责链模式、代理模式。其中,观察者模式、模板模式在上一节课已经详细讲过了。

实际上,在 Spring 中,只要后缀带有 Template 的类,基本上都是模板类,而且大部分都是用 Callback 回调来实现的,比如 JdbcTemplate、RedisTemplate 等。剩下的两个模式在 Spring 中的应用应该人尽皆知了。职责链模式在 Spring 中的应用是拦截器(Interceptor),代理模式经典应用是 AOP。重点回顾

总结

好了,今天的内容到此就讲完了。我们一块来总结回顾一下,你需要重点掌握的内容。

我们今天提到的设计模式有 11 种,它们分别是适配器模式、策略模式、组合模式、装饰器模式、工厂模式、单例模式、解释器模式、观察者模式、模板模式、职责链模式、代理模式,基本上占了 23 种设计模式的一半。这还只是我所知道的,实际上,Spring 用到的设计模式可能还要更多。你看,设计模式并非“花拳绣腿”吧,它在实际的项目开发中,确实有很多应用,确实可以发挥很大的作用。

还是那句话,对于今天的内容,你不需要去记忆哪个类用到了哪个设计模式。你只需要跟着我的讲解,把每个设计模式在 Spring 中的应用场景,搞懂就可以了。看到类似的代码,能够立马识别出它用到了哪种设计模式;看到类似的应用场景,能够立马反映出要用哪种模式去解决,这样就说明你已经掌握得足够好了。

问题

我们前面讲到,除了纯构造函数、构造函数加 setter 方法和工厂方法之外,还有另外一个经常用来创建对象的模式,Builder 模式。如果我们让 Spring 支持通过 Builder 模式来创建 Bean,应该如何来编写代码和配置呢?你可以设计一下吗?