解决@Autowired注入空指针问题(利用Bean的生命周期)

 更新时间:2022年02月24日 11:52:19   作者:Hermione Granger  
这篇文章主要介绍了解决@Autowired注入空指针问题(利用Bean的生命周期),具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教

今天做项目的时候遇到一个问题,需要将线程池的参数抽取到yml文件里进行设置。这不是so easy吗?

我就写出了下面这样的代码进行抽取

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
/**
 * @author BestQiang
 */
@Component
@ConfigurationProperties(prefix = "thread-pool")
public class ThreadPool {
    private int corePoolSize;
    private int maximumPoolSize;
    private long keepAliveTime;
    private int capacity;
    public int getCorePoolSize() {
        return corePoolSize;
    }
    public void setCorePoolSize(int corePoolSize) {
        this.corePoolSize = corePoolSize;
    }
    public int getMaximumPoolSize() {
        return maximumPoolSize;
    }
    public void setMaximumPoolSize(int maximumPoolSize) {
        this.maximumPoolSize = maximumPoolSize;
    }
    public long getKeepAliveTime() {
        return keepAliveTime;
    }
    public void setKeepAliveTime(long keepAliveTime) {
        this.keepAliveTime = keepAliveTime;
    }
    public int getCapacity() {
        return capacity;
    }
    public void setCapacity(int capacity) {
        this.capacity = capacity;
    }
}
package cn.bestqiang.util;
import cn.bestqiang.pojo.ThreadPool;
import com.google.common.util.concurrent.ThreadFactoryBuilder;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
import java.util.concurrent.*;
/**
 * @author Yaqiang Chen
 */
@Component
public class MyThreadUtils {
    @Autowired
    ThreadPool threadPool1;
    private ExecutorService threadPool = new ThreadPoolExecutor(
                threadPool1.getCorePoolSize(),
                threadPool1.getMaximumPoolSize(),
                threadPool1.getKeepAliveTime(),
                TimeUnit.SECONDS,
                new LinkedBlockingDeque<Runnable>(threadPool1.getCapacity()),
                namedThreadFactory,
                new ThreadPoolExecutor.DiscardPolicy()
        );;
    private ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
            .setNameFormat("pool-%d").build();
    public void execute(Runnable runnable){
        threadPool.submit(runnable);
    }
}

在yml文件的配置如下:

thread-pool:
  core-pool-size: 5
  maximum-pool-size: 20
  keep-alive-time: 1
  capacity: 1024

本想应该毫无问题,但是,报错了:

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'myThreadUtils' defined in fileXXXXXXXXXX(省略)Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [cn.itcast.util.MyThreadUtils]: Constructor threw exception; nested exception is java.lang.NullPointerExceptionCaused by: java.lang.NullPointerException: null

空指针异常?检查好几遍配置没错。因为公司开发环境没法上网,只好拖到下班google了一下,结合我比较深厚的基础(自恋一下),

问题轻松解决

这就是答案。上面说所有的Spring的@Autowired注解都在构造函数之后,而如果一个对象像下面代码一样声明(private XXX = new XXX() 直接在类中声明)的话,成员变量是在构造函数之前进行初始化的,甚至可以作为构造函数的参数。

即 成员变量初始化 -> Constructor -> @Autowired

所以,在这个时候如果成员变量初始化时调用了利用@Autowired注解初始化的对象时,必然会报空指针异常的啊。

真相大白了。如果解决呢?那就让上面我写的代码的成员变量threadPool在@Autowired之后执行就好了。

要想解决这个问题,首先要知道@Autowired的原理:

AutowiredAnnotationBeanPostProcessor 这个类

其实看到这个继承结构,我心中已经有解决办法了。具体详细为什么,等997的工作结束(无奈)我会在后续博客里将Spring的注解配置详细的捋一遍,到时候会讲到Bean的生命周期的。

继承的BeanFactoryAware是在属性赋值完成,执行构造方法后,postProcessBeforeInitialization才执行,而且,是在其他生命周期之前,而@Autowired注解就是依靠这个原理进行的自动注入。想要解决这个问题很简单,就是把要赋值的成员变量放到其他生命周期中就可以。

下面介绍其中两种办法

第一种JSR250的@PostConstruct

@PostConstruct
public void init() {
	// 这里放要执行的赋值
}

第二种是Spring的InitializingBean(定义初始化逻辑) 

继承接口实现方法即可,这种直接放上完整用法

/**
 * @author Yaqiang Chen
 */
@Component
public class MyThreadUtils implements InitializingBean {
    @Autowired
    ThreadPool threadPool1;
    private ExecutorService threadPool;
    private ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
            .setNameFormat("pool-%d").build();
    public void execute(Runnable runnable){
        threadPool.submit(runnable);
    }
    @Override
    public void afterPropertiesSet() throws Exception {
        threadPool = new ThreadPoolExecutor(
                threadPool1.getCorePoolSize(),
                threadPool1.getMaximumPoolSize(),
                threadPool1.getKeepAliveTime(),
                TimeUnit.SECONDS,
                new LinkedBlockingDeque<Runnable>(threadPool1.getCapacity()),
                namedThreadFactory,
                new ThreadPoolExecutor.DiscardPolicy()
        );
    }
}

设置完成后,问题解决!

相关文章

  • 浅析Spring工厂的反射和配置文件

    浅析Spring工厂的反射和配置文件

    这篇文章主要介绍了浅析Spring工厂的反射和配置文件,spring是通过反射和配置文件的方式来获取 JavaBean 对象,需要的朋友可以参考下
    2023-04-04
  • Spring Boot中记录用户系统操作流程

    Spring Boot中记录用户系统操作流程

    这篇文章主要介绍了如何在Spring Boot中记录用户系统操作流程,将介绍如何在Spring Boot中使用AOP(面向切面编程)和日志框架来实现用户系统操作流程的记录,需要的朋友可以参考下
    2023-07-07
  • Spring之InitializingBean接口和DisposableBean接口的使用

    Spring之InitializingBean接口和DisposableBean接口的使用

    这篇文章主要介绍了Spring之InitializingBean接口和DisposableBean接口的使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-01-01
  • JAVA多线程和并发基础面试问答(翻译)

    JAVA多线程和并发基础面试问答(翻译)

    多线程和并发问题是Java技术面试中面试官比较喜欢问的问题之一。在这里,从面试的角度列出了大部分重要的问题,但是你仍然应该牢固的掌握Java多线程基础知识来对应日后碰到的问题
    2014-09-09
  • Java MongoDB数据库连接方法梳理

    Java MongoDB数据库连接方法梳理

    MongoDB作为一种介于关系型数据库和非关系型数据库之间的产品,它可以提供可扩展的高性能的数据存储解决方案,近些年来受到了开发者的喜爱
    2022-08-08
  • JAVALambda表达式与函数式接口详解

    JAVALambda表达式与函数式接口详解

    大家好,本篇文章主要讲的是JAVALambda表达式与函数式接口详解,感兴趣的同学赶快来看一看吧,对你有帮助的话记得收藏一下
    2022-02-02
  • 基于MyBatis的关联查询优化与应用实践

    基于MyBatis的关联查询优化与应用实践

    在实际项目开发中,关联查询是一种常见的需求,尤其是当涉及到多个表之间的数据统计、关联查询以及嵌套对象的构建时,如何确保数据的准确性和实时性,是开发者必须面对的挑战,本文将介绍基于MyBatis的关联查询优化与应用实践,需要的朋友可以参考下
    2024-12-12
  • Java日常练习题,每天进步一点点(58)

    Java日常练习题,每天进步一点点(58)

    下面小编就为大家带来一篇Java基础的几道练习题(分享)。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧,希望可以帮到你
    2021-08-08
  • Java并发编程变量可见性避免指令重排使用详解

    Java并发编程变量可见性避免指令重排使用详解

    这篇文章主要为大家介绍了Java并发编程变量可见性避免指令重排使用详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-11-11
  • Java详解多线程协作作业之信号同步

    Java详解多线程协作作业之信号同步

    信号量同步是指在不同线程之间,通过传递同步信号量来协调线程执行的先后次序。CountDownLatch是基于时间维度的Semaphore则是基于信号维度的
    2022-05-05

最新评论