Spring杂谈 | 什么是ObjectFactory?什么是ObjectProvider?

简介: Spring杂谈 | 什么是ObjectFactory?什么是ObjectProvider?

ObjectFactory


接口定义

// 一个对象工厂
public interface ObjectFactory<T> {
    // 返回一个对象
    T getObject() throws BeansException;
}

这个接口的定义非常简单,就是一个对象工厂,定义了一个返回对象的工厂方法。回顾我们直接介绍过的一个内容FactroyBean,其接口定义如下:

public interface FactoryBean<T> {
  @Nullable
  T getObject() throws Exception;
  @Nullable
  Class<?> getObjectType();
  default boolean isSingleton() {
    return true;
  }
}

可以看到两者都有一个getObject方法,那么它们有什么区别或者联系呢?


跟FactoryBean的区别及联系


联系


二者在功能设计上是没有什么联系的,他们最大的共同点就是都采用了工厂模式,通过工厂模式来返回一个对象


区别


1.FactoryBean在BeanFacotry的实现中有着特殊的处理,如果一个对象实现了FactoryBean 那么通过它get出来的对象实际是factoryBean.getObject()得到的对象,如果想得到FactoryBean必须通过在 '&' + beanName的方式获取


2.FactoryBean的设计主要是为了进行扩展容器中Bean的创建方式,所以FactoryBean着重于自定义创建对象过程,同时FactoryBean都会放到容器中,FactoryBean所创建的Bean也会放入容器中


3.ObjectFactory则只是一个普通的对象工厂接口。在Spring中主要两处用了它


Scope接口中的get方法,需要传入一个ObjectFactory,如下:

Object get(String name, ObjectFactory<?> objectFactory);

这个方法的目的就是从对于的域中获取到指定名称的对象。为什么要传入一个objectFactory呢?主要是为了方便我们扩展自定义的域,而不是仅仅使用request,session等域。


ConfigurableListableBeanFactory类中的registerResolvableDependency方法,其定义如下,

void registerResolvableDependency(Class<?> dependencyType, @Nullable Object autowiredValue);

粗看起来,好像这个方法跟ObjectFactory没有什么关联,但是我们留意这个方法上面的JavaDoc,其中有一段关于参数autowiredValue的介绍,如下

@param autowiredValue the corresponding autowired value. This may also be an* implementation of the {@link org.springframework.beans.factory.ObjectFactory}* interface, which allows for lazy resolution of the actual target value.

从这段内容中我们能知道,autowiredValue这个参数可能就是一个ObjectFactory,主要是为了让注入点能够被延迟注入。Spring通过这种方式注入了request,response等对象

beanFactory.registerResolvableDependency(ServletRequest.class, new RequestObjectFactory());
beanFactory.registerResolvableDependency(ServletResponse.class, new ResponseObjectFactory());
beanFactory.registerResolvableDependency(HttpSession.class, new SessionObjectFactory());
beanFactory.registerResolvableDependency(WebRequest.class, new WebRequestObjectFactory());

我们看看RequestObjectFactory的定义:

private static class RequestObjectFactory implements ObjectFactory<ServletRequest>, Serializable {
    @Override
    // 是从当前线程中获取的
    public ServletRequest getObject() {
        return currentRequestAttributes().getRequest();
    }
    @Override
    public String toString() {
        return "Current HttpServletRequest";
    }
}

当我们在某一个类中如果注入了ServletRequest对象,并不会直接创建一个ServletRequest然后注入进去,而是注入一个代理类,代理类中的方法是通过ObjectFactoryDelegatingInvocationHandler实现的,而这个对象中会持有一个RequestObjectFactory对象。基于此,我们可以通过下面这种方式直接注入request对象,并且保证线程安全

@RestController
public class AutowiredRequestController {
    @Autowired
    private HttpServletRequest request;
}

ObjectProvider


接口定义

// 1.可以看到ObjectProvider本身继承了ObjectFactory接口,所以它本身就是一个ObjectFactory
// 2.从5.1之后,这个接口还多继承了一个Iterable接口,意味着能对它进行迭代以及流式操作
public interface ObjectProvider<T> extends ObjectFactory<T>, Iterable<T> {
  // 返回用指定参数创建的bean, 如果容器中不存在, 抛出异常
  T getObject(Object... args) throws BeansException;
  // 如果指定类型的bean注册到容器中, 返回 bean 实例, 否则返回 null
  @Nullable
  T getIfAvailable() throws BeansException;
  // 如果返回对象不存在,则用传入的Supplier获取一个Bean并返回,否则直接返回存在的对象
  default T getIfAvailable(Supplier<T> defaultSupplier) throws BeansException {
    T dependency = getIfAvailable();
    return (dependency != null ? dependency : defaultSupplier.get());
  }
   // 消费对象的一个实例(可能是共享的或独立的),如果存在通过Consumer回调消耗目标对象。
     // 如果不存在则直接返回
  default void ifAvailable(Consumer<T> dependencyConsumer) throws BeansException {
    T dependency = getIfAvailable();
    if (dependency != null) {
      dependencyConsumer.accept(dependency);
    }
  }
  // 如果不可用或不唯一(没有指定primary)则返回null。否则,返回对象。
  @Nullable
  T getIfUnique() throws BeansException;
  // 如果不存在唯一对象,则调用Supplier的回调函数
  default T getIfUnique(Supplier<T> defaultSupplier) throws BeansException {
    T dependency = getIfUnique();
    return (dependency != null ? dependency : defaultSupplier.get());
  }
  // 如果存在唯一对象,则消耗掉该对象
  default void ifUnique(Consumer<T> dependencyConsumer) throws BeansException {
    T dependency = getIfUnique();
    if (dependency != null) {
      dependencyConsumer.accept(dependency);
    }
  }
  // 返回符合条件的对象的Iterator,没有特殊顺序保证(一般为注册顺序)
  @Override
  default Iterator<T> iterator() {
    return stream().iterator();
  }
  // 返回符合条件对象的连续的Stream,没有特殊顺序保证(一般为注册顺序)
  default Stream<T> stream() {
    throw new UnsupportedOperationException("Multi element access not supported");
  }
  // 返回符合条件对象的连续的Stream。在标注Spring应用上下文中采用@Order注解或实现Order接口的顺序
  default Stream<T> orderedStream() {
    throw new UnsupportedOperationException("Ordered element access not supported");
  }
}

接口分析


在Spring4.3之前,如果你构造函数中要依赖另外一个bean,你必须显示依赖@Autowired(这里不考虑使用了自动注入的方式,关于自动注入跟精确注入请参我之前的文章,《Spring官网阅读》系列第二,三篇) ,像这样子

@Service
public class FooService {
    private final FooRepository repository;
    @Autowired
    public FooService(FooRepository repository) {
        this.repository = repository
    }
}

而在4.3版本之后,已经不需要这么做了,只要我们只提供了一个构造函数,并且构造函数所需要的参数都在Spring容器中(实际上官网中也指出,如果依赖关系是强制的,那么最好使用构造函数进行注入),那么不需要进行精确的指定使用@Autowired。相比于4.3版本这无疑简化了我们的开发,但是这种隐式的注入仍然存在一些不足。例如,就上面的例子而言,如果容器中存在了一个以上的FooRepository甚至一个都没有的情况下,抛出异常


Parameter 0 of constructor in com.example.demo.FooServicerequired a bean of type ‘com.example.demo.FooRepository’ that could not be found.

或者是

No qualifying bean of type ‘com.example.demo.FooRepository’’ available: expected single matching bean but found 2:


那么我们有什么办法解决它呢?基于这个原因,ObjectProvider就出场了。如果注入实例为空时,使用ObjectProvider则避免了强依赖导致的依赖对象不存在异常;如果有多个实例,ObjectProvider的方法可以根据Bean实现的Ordered接口或@Order注解指定的先后顺序获取一个Bean。从而了提供了一个更加宽松的依赖注入方式。Spring主要在org.springframework.beans.factory.support.DefaultListableBeanFactory#resolveDependency方法中使用了它,具体代码如下:

@Override
public Object resolveDependency(DependencyDescriptor descriptor, String requestingBeanName, Set<String> autowiredBeanNames, @Nullable TypeConverter typeConverter) throws BeansException {
  // descriptor代表当前需要注入的那个字段,或者方法的参数,也就是注入点
    // ParameterNameDiscovery用于解析方法参数名称
    descriptor.initParameterNameDiscovery(getParameterNameDiscoverer());
    // 1. Optional<T>
    if (Optional.class == descriptor.getDependencyType()) {
        return createOptionalDependency(descriptor, requestingBeanName);
    // 2. ObjectFactory<T>、ObjectProvider<T>
    } else if (ObjectFactory.class == descriptor.getDependencyType() ||
             ObjectProvider.class == descriptor.getDependencyType()) {
        return new DependencyObjectProvider(descriptor, requestingBeanName);
    // 3. javax.inject.Provider<T>
    } else if (javaxInjectProviderClass == descriptor.getDependencyType()) {
        return new Jsr330Factory().createDependencyProvider(descriptor, requestingBeanName);
    } else {
        // 4. @Lazy
        Object result = getAutowireCandidateResolver().getLazyResolutionProxyIfNecessary(
            descriptor, requestingBeanName);
        // 5. 正常情况
        if (result == null) {
            result = doResolveDependency(descriptor, requestingBeanName, autowiredBeanNames, typeConverter);
        }
        return result;
    }
}

其实不管是上面的哪个情况,最终都会调用到正常情况下的doResolveDependency方法中。我们着重关注上面的第二种情况,可以看到当注入点为ObjectFactory或者ObjectProvider时,会new一个DependencyObjectProvider返回出去,那么返回的这个DependencyObjectProvider是什么呢?


其继承关系如下:

image.png

这个DependencyObjectProvider对象,其实就是一个ObjectProvider,我们看看它是如何实现ObjectProvider中的方法的(方法的实现逻辑都差不多,这里就看一个方法):

public Object getIfAvailable() throws BeansException {
    // 用于解决嵌套的情况,像这种:ObjectProvider<Optional<T>>
    if (this.optional) {
        return createOptionalDependency(this.descriptor, this.beanName);
    }
    else {
        DependencyDescriptor descriptorToUse = new DependencyDescriptor(this.descriptor) {
            @Override
            public boolean isRequired() {
                return false;
            }
        };
        // 最终还是会调用这个方法解决依赖
        return doResolveDependency(descriptorToUse, this.beanName, null, null);
    }
}

从上面的过程中我们可以看出,但Spring中某个Bean的依赖类型为ObjectProvider时,我们不需要提供一个ObjectProvider类型的Bean到容器中,只需要提供一个T类型的Bean到容器中,容器会自动将其包装成一个ObjectProvider,然后注入到依赖中。


而基于ObjectProvider的一系列方法,我们就能解决之前提到的问题。


ObjectProvider解决的问题


问题一


容器中没有Bean时,抛出Parameter 0 of constructor in com.example.demo.FooServicerequired a bean of type 'com.example.demo.FooRepository' that could not be found.。


解决方式:

@Component
public class IndexService {
  B b;
    public IndexService(ObjectProvider<B> b) {
    this.b = b.getIfAvailable();
  }
}

但是上面这种解决方式的弊病也很明显,就是b可能为空,则可能将异常从启动阶段转移到业务运行阶段。


问题二


容器中存在多个Bean时,抛出No qualifying bean of type 'com.example.demo.FooRepository'' available: expected single matching bean but found 2

@Component
public class IndexService {
  B b;
  public IndexService(ObjectProvider<B> b) {
    this.b = b.orderedStream().findFirst().orElse(null);
  }
}

当容器存在多个Bean,我们可以调用它的流式方法获取一个自己想要的依赖。


总结


本文介绍了ObjectFactory跟ObjectProvider,对于ObjectFactory主要介绍了它的应用并且将其与我们之前学习过的FactoryBean做了比较。关于ObjectProvider也对其中定义的方法,以及它解决的问题做了分析。可能有些读者觉得这些东西也不是很重要,并不影响核心代码的阅读。不过笔者在阅读源码过程中,看到了不去弄明白实在是难受,本人也是秉着愚公移山的精神慢慢啃,一个知识点一个知识点慢慢摸索,虽然这样慢了点,但是能学到东西也是有很大满足感的。不管怎么样,我还是写了这篇笔记,也会继续写下去。加油,为自己!


image.png

相关文章
|
Java 测试技术 容器
Spring框架-ObjectProvider更加宽泛的依赖注入
从上面的过程中我们可以看出,但Spring中某个Bean的依赖类型为ObjectProvider时,我们不需要提供一个ObjectProvider类型的Bean到容器中,只需要提供一个T类型的Bean到容器中,容器会自动将其包装成一个ObjectProvider,然后注入到依赖中
187 0
|
Java 应用服务中间件 Spring
Spring Boot 注解之ObjectProvider源码追踪
Spring Boot 注解之ObjectProvider源码追踪
256 0
Spring Boot 注解之ObjectProvider源码追踪
|
设计模式 Java 数据库连接
【小家Spring】一文读懂Spring中的BeanFactory和FactoryBean(以及它和ObjectFactory的区别)的区别(上)
【小家Spring】一文读懂Spring中的BeanFactory和FactoryBean(以及它和ObjectFactory的区别)的区别(上)
|
缓存 Java 测试技术
【小家Spring】一文读懂Spring中的BeanFactory和FactoryBean(以及它和ObjectFactory的区别)的区别(下)
【小家Spring】一文读懂Spring中的BeanFactory和FactoryBean(以及它和ObjectFactory的区别)的区别(下)
|
2月前
|
SQL 监控 druid
springboot-druid数据源的配置方式及配置后台监控-自定义和导入stater(推荐-简单方便使用)两种方式配置druid数据源
这篇文章介绍了如何在Spring Boot项目中配置和监控Druid数据源,包括自定义配置和使用Spring Boot Starter两种方法。
|
27天前
|
人工智能 自然语言处理 前端开发
SpringBoot + 通义千问 + 自定义React组件:支持EventStream数据解析的技术实践
【10月更文挑战第7天】在现代Web开发中,集成多种技术栈以实现复杂的功能需求已成为常态。本文将详细介绍如何使用SpringBoot作为后端框架,结合阿里巴巴的通义千问(一个强大的自然语言处理服务),并通过自定义React组件来支持服务器发送事件(SSE, Server-Sent Events)的EventStream数据解析。这一组合不仅能够实现高效的实时通信,还能利用AI技术提升用户体验。
139 2
|
3月前
|
缓存 Java Maven
Java本地高性能缓存实践问题之SpringBoot中引入Caffeine作为缓存库的问题如何解决
Java本地高性能缓存实践问题之SpringBoot中引入Caffeine作为缓存库的问题如何解决
|
27天前
|
SQL JSON Java
mybatis使用三:springboot整合mybatis,使用PageHelper 进行分页操作,并整合swagger2。使用正规的开发模式:定义统一的数据返回格式和请求模块
这篇文章介绍了如何在Spring Boot项目中整合MyBatis和PageHelper进行分页操作,并且集成Swagger2来生成API文档,同时定义了统一的数据返回格式和请求模块。
44 1
mybatis使用三:springboot整合mybatis,使用PageHelper 进行分页操作,并整合swagger2。使用正规的开发模式:定义统一的数据返回格式和请求模块
|
4月前
|
Java 测试技术 数据库
Spring Boot中的项目属性配置
本节课主要讲解了 Spring Boot 中如何在业务代码中读取相关配置,包括单一配置和多个配置项,在微服务中,这种情况非常常见,往往会有很多其他微服务需要调用,所以封装一个配置类来接收这些配置是个很好的处理方式。除此之外,例如数据库相关的连接参数等等,也可以放到一个配置类中,其他遇到类似的场景,都可以这么处理。最后介绍了开发环境和生产环境配置的快速切换方式,省去了项目部署时,诸多配置信息的修改。
|
1月前
|
XML Java 应用服务中间件
【Spring】运行Spring Boot项目,请求响应流程分析以及404和500报错
【Spring】运行Spring Boot项目,请求响应流程分析以及404和500报错
136 2