1. 程式人生 > >web專案中啟動一個執行緒,的方法

web專案中啟動一個執行緒,的方法

JavaWeb 服務啟動時,在後臺啟動載入一個執行緒。

目前,我所掌握的一共有兩種方法,第一種是監聽(Listener),第二種是配置隨專案啟動而啟動的Servlet。

下面對這兩種方法做一簡單的介紹,(Mark一下,防止以後急用又忘記了):

1.監聽(Listener)
首先,我們建立一個監聽的類,繼承ServletContextListener,如下:

package com.wxp.thread;
 
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
 
/**
 * Listener的方式在後臺執行一執行緒
 * 
 * @author Champion.Wong
 * 
 */
public class MyListener implements ServletContextListener {
	private MyThread myThread;
 
	public void contextDestroyed(ServletContextEvent e) {
		if (myThread != null && myThread.isInterrupted()) {
			myThread.interrupt();
		}
	}
 
	public void contextInitialized(ServletContextEvent e) {
		String str = null;
		if (str == null && myThread == null) {
			myThread = new MyThread();
			myThread.start(); // servlet 上下文初始化時啟動 socket
		}
	}
}
 
/**
 * 自定義一個 Class 執行緒類繼承自執行緒類,重寫 run() 方法,用於從後臺獲取並處理資料
 * 
 * @author Champion.Wong
 * 
 */
class MyThread extends Thread {
	public void run() {
		while (!this.isInterrupted()) {// 執行緒未中斷執行迴圈
			try {
				Thread.sleep(2000); //每隔2000ms執行一次
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			
//			 ------------------ 開始執行 ---------------------------
			System.out.println("____FUCK TIME:" + System.currentTimeMillis());
		}
	}
}

然後再web.xml重配置

<listener>
	<listener-class>com.wxp.thread.MyListener</listener-class>
</listener>

OK,啟動專案,我們可以在控制檯看到隔時間段輸出的文字內容。

2.使用Servlet,在專案啟動的時候啟動它。
首先,建立一個Servlet,繼承HttpServlet

package com.wxp.thread;
 
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import com.ite.common.Constants;
 
public class MyServlet extends HttpServlet{
 
    private static final long serialVersionUID = 1L;
    private MyThread1 myThread1;
    
    public MyServlet(){
    }
 
    public void init(){
    	String str = null;
		if (str == null && myThread1 == null) {
			myThread1 = new MyThread1();
			myThread1.start(); // servlet 上下文初始化時啟動 socket
		}
    }
 
    public void doGet(HttpServletRequest httpservletrequest, HttpServletResponse httpservletresponse)
        throws ServletException, IOException{
    }
 
    public void destory(){
    	if (myThread1 != null && myThread1.isInterrupted()) {
    		myThread1.interrupt();
		}
    }
}
 
/**
 * 自定義一個 Class 執行緒類繼承自執行緒類,重寫 run() 方法,用於從後臺獲取並處理資料
 * 
 * @author Champion.Wong
 * 
 */
class MyThread1 extends Thread {
	public void run() {
		while (!this.isInterrupted()) {// 執行緒未中斷執行迴圈
			try {
				Thread.sleep(2000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			
			// ------------------ 開始執行 ---------------------------
			System.out.println("____FUCK TIME:" + System.currentTimeMillis());
		}
	}
}

在web.xml中進行配置

<!-- LISTENER FOR THREAD -->
<servlet>
	<servlet-name>MyListener</servlet-name>
	<servlet-class>com.ite.wxp.MyServlet</servlet-class>
	<load-on-startup>9</load-on-startup><!-- 數字越小,啟動的優先順序越高,必須大於0 -->
</servlet>
<servlet-mapping>  
        <servlet-name>MyListener</servlet-name>  
        <url-pattern>/test</url-pattern>   
</servlet-mapping>

  其中,Listener的方式,該執行緒肯定是專案中首先啟動的,優先於任何一個Servlet。而Servlet的方式,可以設定與其它Servlet啟動的順序。如果有時候需要首先啟動一個Servlet或者它們之間的啟動順序有特殊要求的時候,這個就很有作用了。

 

轉載:https://blog.csdn.net/it_wangxiangpan/article/details/7168286