Spring Bean的生命周期函数

03113

Bean的生命周期

  1. Bean定义
  2. Bean注册
  3. Bean初始化
  4. Bean销毁

Bean注册

?>Bean定义时会调用BeanDefinitionRegistryPostProcessor的子类的两个实现方法postProcessBeanDefinitionRegistry和postProcessBeanFactory。

  1. postProcessBeanDefinitionRegistry，可以注册Bean（先调）

  2. postProcessBeanFactory，可以获取到BeanFactory，BeanFactory能做的这个方法都能做（后调）

    点击查看代码 

    import cn.com.xuhx.service.impl.UserServiceImpl;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
import org.springframework.beans.factory.support.BeanDefinitionRegistry;
import org.springframework.beans.factory.support.BeanDefinitionRegistryPostProcessor;
import org.springframework.beans.factory.support.RootBeanDefinition;
import org.springframework.stereotype.Component;

/**
 * 作用：动态注册BeanDefinition
 * 调动时机：IOC加载注册BeanDefinition 的时候会调用
 */
@Component
public class MyBeanDefinitionRegistyPostProcessor implements BeanDefinitionRegistryPostProcessor {

	/**
	 * 动态注册Bean
	 * 先执行
	 * @param beanDefinitionRegistry the bean definition registry used by the application context
	 * @throws BeansException
	 */
	@Override
	public void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry beanDefinitionRegistry) throws BeansException {
		RootBeanDefinition rootBeanDefinition = new RootBeanDefinition(UserServiceImpl.class);
		//手动注册UserServiceImpl的Bean
		beanDefinitionRegistry.registerBeanDefinition("userService", rootBeanDefinition);
	}

	/**
	 * configurableListableBeanFactory Bean工厂，Bean工厂一切能做的，都能在这里做
	 *  可以注册Bean
	 *  可以修改BeanDefinition的定义 例如单例变多例
	 *  可以通过Bean的名称获取Bean
	 *  可以销毁Bean
	 * 后执行
	 * @param configurableListableBeanFactory the bean factory used by the application context
	 * @throws BeansException
	 */
	@Override
	public void postProcessBeanFactory(ConfigurableListableBeanFactory configurableListableBeanFactory) throws BeansException {

	}
}

Bean初始化

Aware接口

BeanNameAware

?>通过实现BeanNameAware接口，重写setBeanName方法可以获得当前类的BeanName

点击查看代码 

import org.springframework.beans.factory.BeanNameAware;
import org.springframework.stereotype.Service;

@Service
public class UserServiceImpl implements UserService, BeanNameAware {

    /**
     * UserServiceImpl的BeanName
     */
    private String beanName;

    /**
     * 通过实现BeanNameAware重写setBeanName方法获取当前对象的BeanName
     * @param name the name of the bean in the factory.
     */
    @Override
    public void setBeanName(String name) {
        this.beanName = name;
    }

    public String getBeanName() {
        return beanName;
    }
}

BeanFactoryAware

?>通过实现BeanFactoryAware接口，重写setBeanFactory方法可以获取BeanFactory，可以用于注册Bean、修改BeanDefinition定义、根据BeanName获取Bean，销毁Bean等。

点击查看代码 

import org.springframework.beans.BeansException;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.beans.factory.BeanFactoryAware;
import org.springframework.stereotype.Service;

@Service
public class UserServiceImpl implements UserService, BeanFactoryAware {

    /**
     * Bean工厂
     */
    private BeanFactory beanFactory;

    /**
     * BeanFactoryAware重写的方法，可以获取BeanFactory
     * @param beanFactory owning BeanFactory (never {@code null}).
     * @throws BeansException
     */
    @Override
    public void setBeanFactory(BeanFactory beanFactory) throws BeansException {
        this.beanFactory = beanFactory;
    }

    public BeanFactory getBeanFactory() {
        return beanFactory;
    }
}

BeanClassLoaderAware

?>通过实现BeanClassLoaderAware接口，重写setBeanClassLoader方法可以获取类加载器，用于动态加载类

点击查看代码 

import org.springframework.beans.factory.BeanClassLoaderAware;
import org.springframework.stereotype.Service;

@Service
public class UserServiceImpl implements UserService, BeanClassLoaderAware {

    /**
     * 类加载器
     */
    private ClassLoader classLoader;

    /**
     * BeanClassLoaderAware重写的方法，可以获取类加载器
     * @param classLoader the owning class loader
     */
    @Override
    public void setBeanClassLoader(ClassLoader classLoader) {
        this.classLoader = classLoader;
    }

    public ClassLoader getClassLoader() {
        return classLoader;
    }
}

EnvironmentAware

?>通过实现EnvironmentAware接口，重写setEnvironment方法可以获取Environment对象，用于读取配置文件

点击查看代码 

import org.springframework.context.EnvironmentAware;
import org.springframework.core.env.Environment;
import org.springframework.stereotype.Service;

@Service
public class UserServiceImpl implements UserService, EnvironmentAware {

    /**
     * 环境管理对象
     */
    private Environment env;

    /**
     * EnvironmentAware重写的方法，可以获取Environment
     * @param environment
     */
    @Override
    public void setEnvironment(Environment environment) {
        this.env = environment;
    }

    public Environment getEnv() {
        return env;
    }
}

EmbeddedValueResolverAware

?>通过实现EmbeddedValueResolverAware接口，重写setEmbeddedValueResolver方法获取StringValueResolver对象，用于解析字符串

点击查看代码 

import org.springframework.context.EmbeddedValueResolverAware;
import org.springframework.stereotype.Service;
import org.springframework.util.StringValueResolver;

@Service
public class UserServiceImpl implements UserService, EmbeddedValueResolverAware {

    /**
     * 字符串占位符解析对象
     */
    private StringValueResolver resolver;

    /**
     * EmbeddedValueResolverAware重写的方法，可以获取StringValueResolver
     * @param resolver
     */
    @Override
    public void setEmbeddedValueResolver(StringValueResolver resolver) {
        this.resolver = resolver;
    }

    public StringValueResolver getResolver() {
        return resolver;
    }

    @Override
    public String getMessage() {
        String message = "你好，${student.name}";
        return resolver.resolveStringValue(message);
    }
}

!>properties配置文件的中文需要转码(与编码格式无关)，否则会乱码，可以使用jdk8自带的程序native2ascii.exe编码

ResourceLoaderAware

?>通过实现ResourceLoaderAware接口，重写setResourceLoader方法获取ResourceLoader对象，用于加载配置文件

点击查看代码 

import org.springframework.context.ResourceLoaderAware;
import org.springframework.core.io.Resource;
import org.springframework.core.io.ResourceLoader;
import org.springframework.stereotype.Service;
import java.io.*;

@Service
public class UserServiceImpl implements UserService, ResourceLoaderAware {

    /**
     * resourceLoader对象
     */
    private ResourceLoader resourceLoader;

    @javax.annotation.Resource
    private ResourceUtils resourceUtils;

    /**
     * ResourceLoaderAware重写的方法，可以获取resourceLoader
     * @param resourceLoader
     */
    @Override
    public void setResourceLoader(ResourceLoader resourceLoader) {
        this.resourceLoader = resourceLoader;
    }

    public String readFile() throws IOException {
        Resource resource = resourceLoader.getResource("classpath:/abc");
        return resourceUtils.getContent(resource);
    }
}

ApplicationEventPublisherAware

?>通过实现ApplicationEventPublisherAware接口，重写setApplicationEventPublisher方法获取ApplicationEventPublisher对象，用于订阅发布事件。

事件对象 

import org.springframework.context.ApplicationEvent;

/**
 * 用户事件
 */
public class UserEvent extends ApplicationEvent {

    private String message;

    private String topic;

     public UserEvent(Object source, String message, String topic) {
        super(source);
        this.message = message;
        this.topic = topic;
    }

    public String getMessage() {
        return message;
    }

    public String getTopic() {
        return topic;
    }
}

事件监听器 

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

/**
 * 用户事件监听器
 */
@Component
public class UserEventListener {

    /**
     * 日志对象
     */
    private final Logger logger = LoggerFactory.getLogger(this.getClass());

    /**
     * 监听器
     * @param userEvent
     */
    @EventListener(condition = "'heiBei'.equals(#userEvent.topic)")
    @Async
    public void receiveHeiBeiUser(UserEvent userEvent) {
        logger.info("receive heiBei: " + userEvent.getTopic() + "：" + userEvent.getMessage());
    }

    /**
     * 监听器
     * @param userEvent
     */
    @EventListener(condition = "'jiangSu'.equals(#userEvent.topic)")
    @Async
    public void receiveJiangSuUser(UserEvent userEvent) {
        logger.info("receive JiangSu: " + userEvent.getTopic() + "：" + userEvent.getMessage());
    }
}

发送消息 

import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
import org.springframework.stereotype.Service;

/**
 * 消息发布
 */
@Service
public class UserServiceImpl implements UserService, ApplicationEventPublisherAware {

    /**
     * 消息发布对象
     */
    private ApplicationEventPublisher applicationEventPublisher;

    /**
     * ApplicationEventPublisherAware重写的方法，可以获取applicationEventPublisher
     * @param applicationEventPublisher
     */
    @Override
    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
        this.applicationEventPublisher = applicationEventPublisher;
    }

    /**
     * 发送消息
     */
    public void publishEvent(String topic) {
        UserEvent userTopic = new UserEvent(this, "Hello World!", topic);
        applicationEventPublisher.publishEvent(userTopic);
    }
}

MessageSourceAware

?>通过实现MessageSourceAware接口，重写setMessageSource方法获取MessageSource对象，用于实现国际化功能

创建用户事件 

import org.springframework.context.ApplicationEvent;

/**
 * 用户事件
 */
public class UserEvent extends ApplicationEvent {

    private String message;

    private String topic;

     public UserEvent(Object source, String message, String topic) {
        super(source);
        this.message = message;
        this.topic = topic;
    }

    public String getMessage() {
        return message;
    }

    public String getTopic() {
        return topic;
    }
}

用户事件监听器 

import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

/**
 * 用户事件监听器
 */
@Component
public class UserEventListener {

    /**
     * 日志对象
     */
    private final Logger logger = LoggerFactory.getLogger(this.getClass());

    /**
     * 监听器（异步需要在启动器上加@EnableAsync）
     * @param userEvent
     */
    @EventListener(condition = "'heiBei'.equals(#userEvent.topic)")
    @Async
    public void receiveHeiBeiUser(UserEvent userEvent) {
        logger.info("receive heiBei: " + userEvent.getTopic() + "：" + userEvent.getMessage());
    }

    /**
     * 监听器
     * @param userEvent
     */
    @EventListener(condition = "'jiangSu'.equals(#userEvent.topic)")
    @Async
    public void receiveJiangSuUser(UserEvent userEvent) {
        logger.info("receive JiangSu: " + userEvent.getTopic() + "：" + userEvent.getMessage());
    }
}

发送消息 

import org.springframework.context.MessageSource;
import org.springframework.context.MessageSourceAware;
import org.springframework.stereotype.Service;
import java.util.Locale;

/**
 * 消息发布
 */
@Service
public class UserServiceImpl implements UserService, MessageSourceAware {

    private MessageSource messageSource;

    /**
     * MessageSourceAware重写的方法，可以获取messageSource
     * @param messageSource
     */
    @Override
    public void setMessageSource(MessageSource messageSource) {
        this.messageSource = messageSource;
    }

    public String getMessage(String lanuageType) {
        if ("US".equalsIgnoreCase(lanuageType)) {
            return messageSource.getMessage("message", null, new Locale("en", "US"));
        } else if ("CN".equalsIgnoreCase(lanuageType)) {
            return messageSource.getMessage("message", null, new Locale("zh", "CN"));
        }
        return messageSource.getMessage("message", null, null);
    }
}

创建Message配置文件
图片[1]-Spring Bean的生命周期函数 - 玄机博客-玄机博客
添加配置
spring.messages.basename=i18n/Message

!>properties配置文件的中文需要转码(与编码格式无关)，否则会乱码，可以使用jdk8自带的程序native2ascii.exe编码

ImportAware

?>通过实现ImportAware接口，重写setImportMetadata方法获取AnnotationMetadata对象，用于获取注解信息

点击查看代码 

import org.springframework.context.annotation.ImportAware;
import org.springframework.core.type.AnnotationMetadata;
import org.springframework.stereotype.Service;


@Service
public class UserServiceImpl implements UserService, ImportAware {

    /**
     * 获取注解信息
     */
    private AnnotationMetadata annotationMetadata;

    /**
     * ImportAware重写的方法，可以获取AnnotationMetadata
     * @param importMetadata
     */
    @Override
    public void setImportMetadata(AnnotationMetadata importMetadata) {
        annotationMetadata = importMetadata;
    }
}

@PostConstruct

?>当Spring IOC Bean初始化时会调用@PostConstruct标注的方法

点击查看代码 

import org.springframework.stereotype.Service;
import javax.annotation.PostConstruct;


@Service
public class UserServiceImpl implements UserService {

    private Logger logger = LoggerFactory.getLogger(this.getClass());

    /**
     * 初始化
     */
    @PostConstruct
    public void init() {
        logger.info("UserServiceImpl初始化");
    }
}

Bean生命周期的回调

BeanPostProcessor

?>Bean初始化前会调用BeanPostProcessor的postProcessBeforeInitialization方法，Bean初始化后会调用方法postProcessAfterInitialization

点击查看代码 

import org.springframework.beans.BeansException;
import org.springframework.beans.factory.config.BeanPostProcessor;
import org.springframework.stereotype.Component;

@Component
public class MyBeanPostProcessor implements BeanPostProcessor {

    private final Logger logger = LoggerFactory.getLogger(this.getClass());

    /**
     * Bean初始化前
     * @param bean the new bean instance
     * @param beanName the name of the bean
     * @return
     * @throws BeansException
     */
    @Override
    public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
        logger.info("postProcessBeforeInitialization Bean = {}, BeanName = {}", bean, beanName);
        return BeanPostProcessor.super.postProcessBeforeInitialization(bean, beanName);
    }

    /**
     * Bean初始化后
     * @param bean the new bean instance
     * @param beanName the name of the bean
     * @return
     * @throws BeansException
     */
    @Override
    public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
        logger.info("postProcessAfterInitialization Bean = {}, BeanName = {}", bean, beanName);
        return BeanPostProcessor.super.postProcessAfterInitialization(bean, beanName);
    }
}

InitializingBean

?>Bean初始化会调用InitializingBean的实现方法afterPropertiesSet，作用相当于@PostConstruct

点击查看代码 

import org.springframework.beans.factory.InitializingBean;
import org.springframework.stereotype.Service;

@Service
public class UserServiceImpl implements UserService, InitializingBean {

    private Logger logger = LoggerFactory.getLogger(this.getClass());

    @Override
    public void afterPropertiesSet() throws Exception {
        logger.info("UserServiceImpl初始化");
    }
}

init-method

?>Bean初始化会调用init-method指定的方法，作用相当于InitializingBean.afterPropertiesSet和@PostConstruct

点击查看代码 

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class BeanConfiguration {

    @Bean(name = "userService", initMethod = "init")
    public UserService getUserService() {
        return new UserServiceImpl();
    }
}

DisposableBean

?>Bean销毁会调用DisposableBean的实现方法destroy

点击查看代码 

import org.springframework.beans.factory.DisposableBean;
import org.springframework.stereotype.Service;

@Service
public class UserServiceImpl implements UserService, DisposableBean {

    private Logger logger = LoggerFactory.getLogger(this.getClass());

    @Override
    public void destroy() throws Exception {
        logger.info("UserServiceImpl被销毁了");
    }
}

destroy-method

?>Bean销毁会调用destroy-method指定的方法，作用相当于DisposableBean.destroy

点击查看代码 

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class BeanConfiguration {

    @Bean(name = "userService", destroyMethod = "destroy")
    public UserService getUserService() {
        return new UserServiceImpl();
    }
}
玄机博客
© 版权声明

1.本站内容仅供参考，不作为任何法律依据。用户在使用本站内容时，应自行判断其真实性、准确性和完整性，并承担相应风险。

2.本站部分内容来源于互联网，仅用于交流学习研究知识，若侵犯了您的合法权益，请及时邮件或站内私信与本站联系，我们将尽快予以处理。

3.本文采用知识共享 署名4.0国际许可协议 [BY-NC-SA] 进行授权

4.根据《计算机软件保护条例》第十七条规定“为了学习和研究软件内含的设计思想和原理，通过安装、显示、传输或者存储软件等方式使用软件的，可以不经软件著作权人许可，不向其支付报酬。”您需知晓本站所有内容资源均来源于网络，仅供用户交流学习与研究使用，版权归属原版权方所有，版权争议与本站无关，用户本人下载后不能用作商业或非法用途，需在24个小时之内从您的电脑中彻底删除上述内容，否则后果均由用户承担责任；如果您访问和下载此文件，表示您同意只将此文件用于参考、学习而非其他用途，否则一切后果请您自行承担，如果您喜欢该程序，请支持正版软件，购买注册，得到更好的正版服务。

5.本站是非经营性个人站点，所有软件信息均来自网络，所有资源仅供学习参考研究目的，并不贩卖软件，不存在任何商业目的及用途

THE END
Java开发学习
# 计算机开发# 知识教程# 后端开发# Java开发
喜欢就支持一下吧
点赞13 分享
f51d73cb496ffb39的头像-玄机博客
相关推荐
一加七Pro刷Lineageos21(kernelsu+MicroG)-玄机博客
一加七Pro刷Lineageos21(kernelsu+MicroG)
一加七Pro刷Lineageos21(kernelsu+MicroG)
1年前 101
在 Windows 上利用Qwen大模型搭建一个 ChatGPT 式的问答小助手-玄机博客
在 Windows 上利用Qwen大模型搭建一个 ChatGPT 式的问答小助手
在 Windows 上利用Qwen大模型搭建一个 ChatGPT 式的问答小助手
2年前 87
一加12搞机(kernelsu+lsposed)-玄机博客
一加12搞机(kernelsu+lsposed)
一加12搞机(kernelsu+lsposed)
1年前 83
记录–淘宝、京东复制好友链接弹出商品详情是如何实现的-玄机博客
记录–淘宝、京东复制好友链接弹出商品详情是如何实现的
记录–淘宝、京东复制好友链接弹出商品详情是如何实现的
2年前 80
VScode使用Jupyter并设置IJava内核-玄机博客
VScode使用Jupyter并设置IJava内核
VScode使用Jupyter并设置IJava内核
2年前 74
一加七Pro刷lineageos21(kernelsu+gapps)-玄机博客
一加七Pro刷lineageos21(kernelsu+gapps)
一加七Pro刷lineageos21(kernelsu+gapps)
10个月前 72
评论 抢沙发
头像
欢迎您留下宝贵的见解！
提交
头像

昵称

取消
昵称

请填写用户信息：

  • 昵称(必填)
  • 邮箱(必填)
表情
[aoman][baiyan][bishi][bizui][cahan][ciya][dabing][daku][deyi][doge][fadai][fanu][fendou][ganga][guzhang][haixiu][hanxiao][zuohengheng][zhuakuang][zhouma][zhemo][zhayanjian][zaijian][yun][youhengheng][yiwen][yinxian][xu][xieyanxiao][xiaoku][xiaojiujie][xia][wunai][wozuimei][weixiao][weiqu][tuosai][tu][touxiao][tiaopi][shui][se][saorao][qiudale][qinqin][qiaoda][piezui][penxue][nanguo][liulei][liuhan][lenghan][leiben][kun][kuaikule][ku][koubi][kelian][keai][jingya][jingxi][jingkong][jie][huaixiao][haqian][aini][OK][qiang][quantou][shengli][woshou][gouyin][baoquan][aixin][bangbangtang][xiaoyanger][xigua][hexie][pijiu][lanqiu][juhua][hecai][haobang][caidao][baojin][chi][dan][kulou][shuai][shouqiang][yangtuo][youling]
代码

请输入代码：

确认
图片
快捷回复
谢谢你的分享，我从中学到了很多！
教程很好用，谢谢！
好东西，学习一下！
楼主听话，快到碗里来！
路过一下，我只是来打酱油的！
水帖美如花，养护靠大家！

    暂无评论内容

用户封面
f51d73cb496ffb39的头像-玄机博客