隨web應用啟動而自啟動的後臺執行緒
阿新 • • 發佈:2018-12-12
當前遇到一個需求:
需要在web應用啟動的時候就啟動一個執行緒定時的來做某項工作。
有兩種解決方法:
1.增加一個監聽器Listener來實現相關功能。
2.增加一個隨專案啟動的servlet來實現相關功能。
這裡Listener和隨專案啟動的servlet都可以隨著專案啟動而啟動,只是啟動的時序有所不同:
接下來分別實現下:
1.Listener實現:看程式碼
package com.web.cloudAgent.servlet; import java.text.SimpleDateFormat; import java.util.Date; import javax.servlet.ServletContextEvent;View Codeimport javax.servlet.ServletContextListener; public class LoadBalanceListener implements ServletContextListener { private MyThread myThread; @Override public void contextDestroyed(ServletContextEvent arg0) { // TODO Auto-generated method stub if (myThread != null && myThread.isInterrupted()) { myThread.interrupt(); } } @Overridepublic void contextInitialized(ServletContextEvent arg0) { // TODO Auto-generated method stub String str = null; if (str == null && myThread == null) { myThread = new MyThread(); myThread.start(); } } } /** * 自定義一個 Class 執行緒類繼承自執行緒類,重寫 run() 方法,用於從後臺獲取並處理資料*/ class MyThread extends Thread { public void run(){ while (!this.isInterrupted()) {// 執行緒未中斷執行迴圈 try { Thread.sleep(2000); //每隔2000ms執行一次 System.out.println("定時執行"); SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//設定日期格式 System.out.println(df.format(new Date()));// new Date()為獲取當前系統時間 } catch (InterruptedException e) { e.printStackTrace(); } } } }
2.servlet實現:
package com.web.cloudAgent.servlet; import java.io.IOException; import java.text.SimpleDateFormat; import java.util.Date; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; public class LoadBalancesServlet extends HttpServlet { private static final long serialVersionUID = 1L; private MyThread myThread; public LoadBalancesServlet(){ } public void init(){ String str = null; if (str == null && myThread == null) { myThread = new MyThread(); myThread.start(); } } public void doGet(HttpServletRequest httpservletrequest, HttpServletResponse httpservletresponse) throws ServletException, IOException{ } public void destory(){ if (myThread != null && myThread.isInterrupted()) { myThread.interrupt(); } } } /** * 自定義一個 Class 執行緒類繼承自執行緒類,重寫 run() 方法,用於從後臺獲取並處理資料 */ class MyThread extends Thread { public void run(){ while (!this.isInterrupted()) {// 執行緒未中斷執行迴圈 try { Thread.sleep(2000); //每隔2000ms執行一次 System.out.println("定時執行"); SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//設定日期格式 System.out.println(df.format(new Date()));// new Date()為獲取當前系統時間 } catch (InterruptedException e) { e.printStackTrace(); } } } }View Code
題外話:我遇倒的一些意外情況,在servlet中需要呼叫一些service,service中包含一些dao,在起初測試的時候發現service會抱錯NullException,後來看到網友的一句話:
因為你的servlet不是由spring管理的,所以spring就不能往servlet裡注入物件,而你的action是spring管理的,所以可以注入成功。
所以最終我們通過spring 的上下文來獲取相應的service。具體方法如下:
//獲取當前上下文環境,spring容器 WebApplicationContext wac = ContextLoader.getCurrentWebApplicationContext(); RegularTaskService regularTaskService = (RegularTaskService)wac.getBean("regularTaskService");
經測試,可以使用。