1. 程式人生 > >隨web應用啟動而自啟動的後臺執行緒

隨web應用啟動而自啟動的後臺執行緒

當前遇到一個需求:

需要在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;
import 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(); } } @Override
public 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(); } } } }
View Code

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");

經測試,可以使用。