快捷導(dǎo)航

spring中實(shí)現(xiàn)容器加載完成后再執(zhí)行自己的方法

更新時(shí)間：2023年02月16日 08:58:33 作者：阿文_ing

這篇文章主要介紹了spring中實(shí)現(xiàn)容器加載完成后再執(zhí)行自己的方法，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

spring容器加載完成后再執(zhí)行自己的方法

在開(kāi)發(fā)過(guò)程中遇到了要在項(xiàng)目啟動(dòng)后自動(dòng)開(kāi)啟某個(gè)服務(wù)，由于使用了spring，我在使用了spring的 listener ，它有 onApplicationEvent （）方法，在Spring容器將所有的Bean都初始化完成之后，就會(huì)執(zhí)行該方法。

應(yīng)用場(chǎng)景

很多時(shí)候我們想要在某個(gè)類(lèi)加載完畢時(shí)干某件事情，但是使用了spring管理對(duì)象，我們這個(gè)類(lèi)引用了其他類(lèi)（可能是更復(fù)雜的關(guān)聯(lián)），所以當(dāng)我們?nèi)ナ褂眠@個(gè)類(lèi)做事情時(shí)發(fā)現(xiàn)包空指針錯(cuò)誤，這是因?yàn)槲覀冞@個(gè)類(lèi)有可能已經(jīng)初始化完成，但是引用的其他類(lèi)不一定初始化完成，所以發(fā)生了空指針錯(cuò)誤

解決方案如下

1.寫(xiě)一個(gè)類(lèi)繼承spring的ApplicationListener監(jiān)聽(tīng)，并監(jiān)控ContextRefreshedEvent事件（容易初始化完成事件）

2.定義簡(jiǎn)單的bean：<bean id="startListener" class="com.itsm.core.service.table.StartListener"></bean> 或者直接使用@Service注解方式

@Service
public class StartListener implements ApplicationListener<ContextRefreshedEvent> {
? ? public static final Map<Integer, TableMapper> mappers = new HashMap<>();
? ? @Resource
? ? A_Mapper a_mapper;
? ? @Override
? ? public void onApplicationEvent(ContextRefreshedEvent event)
? ? {
? ? ? ? if(event.getApplicationContext().getParent() == null)//root application context 沒(méi)有parent，他就是老大.
? ? ? ? {
? ? ? ? ? ? //需要執(zhí)行的邏輯代碼，當(dāng)spring容器初始化完成后就會(huì)執(zhí)行該方法。
? ? ? ? ? ? System.out.println("\n\n\n\n\n______________\n\n\n加載了\n\n_________\n\n");
? ? ? ? }
? ? ? ? //或者下面這種方式
? ? ? ? if(event.getApplicationContext().getDisplayName().equals("Root WebApplicationContext"))
? ? ? ? {
? ? ? ? ? ? System.out.println("\n\n\n_________\n\n加載一次的 \n\n ________\n\n\n\n");
? ? ? ? }
? ? ? ? mappers.put(1,a_mapper);
? ? }
}

spring容器加載完成之后進(jìn)行開(kāi)啟一個(gè)線程進(jìn)行數(shù)據(jù)更新操作

需求：最近做項(xiàng)目遇到了一個(gè)需求，數(shù)據(jù)表中有些數(shù)據(jù)需要定時(shí)更新，這樣就需要啟動(dòng)一個(gè)線程完成，不想再新建一個(gè)項(xiàng)目來(lái)完成這些事，就想在spring啟動(dòng)之后來(lái)開(kāi)啟一個(gè)線程定時(shí)來(lái)完成這件事 ,直接上代碼

package com.irisian.picturelabel.listener;

import com.irisian.picturelabel.service.PictureService;
import com.irisian.picturelabel.service.TaskService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
?* Author:吳滿(mǎn)心
?* Date:2018/5/18
?* Function:負(fù)責(zé)在spring容器加載完成之后進(jìn)行圖片和任務(wù)數(shù)據(jù)表的更新
?*/
@Component
public class SpringFinishedListener implements InitializingBean {
? ? private static final Logger logger = LoggerFactory.getLogger(SpringFinishedListener.class);

? ? @Autowired
? ? private PictureService pictureService;

? ? @Autowired
? ? private TaskService taskService;

? ? @Override
? ? public void afterPropertiesSet() throws Exception {
? ? ? ? new Thread(() -> {
? ? ? ? ? ? while (true) {
? ? ? ? ? ? ? ? logger.info("開(kāi)始執(zhí)行圖片和任務(wù)的更新操作!");
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? pictureService.updatePictureStatus();
? ? ? ? ? ? ? ? ? ? //更新任務(wù)的完成狀態(tài)信息
? ? ? ? ? ? ? ? ? ? taskService.updateFinishStatus();
? ? ? ? ? ? ? ? } catch (Exception e) {
? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? ? ? logger.error(e.getMessage());
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? Thread.sleep(1800000); ? ? ?//30分鐘執(zhí)行一次進(jìn)行數(shù)據(jù)更新
? ? ? ? ? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? ? ? logger.error(e.getMessage());
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }).start();


? ? }
}

開(kāi)始還嘗試過(guò)servlet的方法，如

package com.irisian.picturelabel.servlet;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;

/**
?* Author:吳滿(mǎn)心
?* Date:2018/5/18
?* Function:
?*/
@WebServlet(name = "backServlet", urlPatterns = {"/backServlet"})
public class BackServlet extends HttpServlet {
? ? private static final Logger logger= LoggerFactory.getLogger(BackServlet.class);

? ? @Override
? ? public void init() throws ServletException {
? ? ? ? new Thread(()->{
? ? ? ? ? ? while(true){
? ? ? ? ? ? ? ? logger.info("我5秒鐘執(zhí)行一次");
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? Thread.sleep(5000);
? ? ? ? ? ? ? ? } catch (InterruptedException e) {
? ? ? ? ? ? ? ? ? ? logger.error(e.getMessage());
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }).start();
? ? }


? ? @Override
? ? public void destroy() {
? ? ? ? logger.info("服務(wù)器關(guān)閉了");
? ? }
}

配置Configuration

package com.irisian.picturelabel.configuration;
import com.irisian.picturelabel.exception.MyExceptionResolver;
import com.irisian.picturelabel.servlet.BackServlet;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.HandlerExceptionResolver;

/**
?* Author:吳滿(mǎn)心
?* Date:2018/5/15
?* Function:
?*/
@Configuration
public class SpringConfiguration {
? ? @Bean
? ? public HandlerExceptionResolver getHandlerExceptionResolver() {
? ? ? ? return new MyExceptionResolver();
? ? }

? ? /**
? ? ?* 配置一個(gè)后臺(tái)運(yùn)行的servlet
? ? ?* @return
? ? ?*/
? ? @Bean
? ? public ServletRegistrationBean servletRegistrationBean() {
? ? ? ? ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new BackServlet(), "/backServlet");
? ? ? ? servletRegistrationBean.setLoadOnStartup(1); ? ? ? ?//數(shù)字越小，啟動(dòng)優(yōu)先級(jí)越高，但是必須大于0
? ? ? ? return servletRegistrationBean;
? ? }

}

但是不滿(mǎn)足spring啟動(dòng)之后，spring不啟動(dòng)完成，就無(wú)法使用bean了，所以就按照前面的一種方法了