spring中實(shí)現(xiàn)容器加載完成后再執(zhí)行自己的方法
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è)類加載完畢時(shí)干某件事情,但是使用了spring管理對(duì)象,我們這個(gè)類引用了其他類(可能是更復(fù)雜的關(guān)聯(lián)),所以當(dāng)我們?nèi)ナ褂眠@個(gè)類做事情時(shí)發(fā)現(xiàn)包空指針錯(cuò)誤,這是因?yàn)槲覀冞@個(gè)類有可能已經(jīng)初始化完成,但是引用的其他類不一定初始化完成,所以發(fā)生了空指針錯(cuò)誤
解決方案如下
1.寫(xiě)一個(gè)類繼承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:吳滿心
?* 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:吳滿心
?* 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:吳滿心
?* 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;
? ? }
}但是不滿足spring啟動(dòng)之后,spring不啟動(dòng)完成,就無(wú)法使用bean了,所以就按照前面的一種方法了
總結(jié)
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
java二進(jìn)制運(yùn)算基礎(chǔ)知識(shí)點(diǎn)詳解
Springboot中使用Filter實(shí)現(xiàn)Header認(rèn)證詳解
JAVA實(shí)現(xiàn)異步調(diào)用實(shí)例代碼

