隨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();
    }
    
}
}
}

 然后需要將Listener配置到web.xml中：

 

<listener>
<listener-class>com.web.cloudAgent.servlet.LoadBalanceServlet</listener-class>
</listener>

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();
    }
    
}
}
}

 然后需要配置到web.xml中：

題外話：我遇倒的一些意外情況，在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");

經測試，可以使用。