JavaWeb 服务启动时，在后台启动加载一个线程

短命女 2022-09-19 05:29 164阅读 0赞

JavaWeb 服务启动时，在后台启动加载一个线程。

目前，我所掌握的一共有两种方法，第一种是监听（Listener），第二种是配置随项目启动而启动的Servlet。

下面对这两种方法做一简单的介绍，（Mark一下，防止以后急用又忘记了）：

1.  **监听（Listener）**  
    首先，我们创建一个监听的类，继承ServletContextListener，如下：  
    
    
    **\[java\]** [ view plain][view plain] [copy][view plain]
    
    1.  package com.wxp.thread;  
    2.    
    3.  import javax.servlet.ServletContextEvent;  
    4.  import javax.servlet.ServletContextListener;  
    5.    
    6.  /\*\* 
    7.   \* Listener的方式在后台执行一线程 
    8.   \*  
    9.   \* @author Champion.Wong 
    10.  \*  
    11.  \*/  
    12. public class MyListener implements ServletContextListener \{  
    13.     private MyThread myThread;  
    14.   
    15.     public void contextDestroyed(ServletContextEvent e) \{  
    16.         if (myThread != null && myThread.isInterrupted()) \{  
    17.             myThread.interrupt();  
    18.         \}  
    19.     \}  
    20.   
    21.     public void contextInitialized(ServletContextEvent e) \{  
    22.         String str = null;  
    23.         if (str == null && myThread == null) \{  
    24.             myThread = new MyThread();  
    25.             myThread.start(); // servlet 上下文初始化时启动 socket  
    26.         \}  
    27.     \}  
    28. \}  
    29.   
    30. /\*\* 
    31.  \* 自定义一个 Class 线程类继承自线程类，重写 run() 方法，用于从后台获取并处理数据 
    32.  \*  
    33.  \* @author Champion.Wong 
    34.  \*  
    35.  \*/  
    36. class MyThread extends Thread \{  
    37.     public void run() \{  
    38.         while (!this.isInterrupted()) \{ // 线程未中断执行循环  
    39.             try \{  
    40.                 Thread.sleep(2000); //每隔2000ms执行一次  
    41.             \} catch (InterruptedException e) \{  
    42.                 e.printStackTrace();  
    43.             \}  
    44.               
    45. //           ------------------ 开始执行 ---------------------------  
    46.             System.out.println("\_\_\_\_FUCK TIME:" + System.currentTimeMillis());  
    47.         \}  
    48.     \}  
    49. \}  
    
      
    然后，在web.xml中配置如下：  
    
    
    **\[html\]** [ view plain][view plain] [copy][view plain]
    
    1.  <listener>  
    2.      <listener-class>com.wxp.thread.MyListener</listener-class>  
    3.  </listener>  
    
      
    OK，启动项目，我们可以在控制台看到隔时间段输出的文字内容。  
    ![0_1325309429JEn7.gif][]
2.  **使用Servlet，在项目启动的时候启动它。**  
    首先，创建一个Servlet，继承HttpServlet  
    
    
    **\[java\]** [ view plain][view plain] [copy][view plain]
    
    1.  package com.wxp.thread;  
    2.    
    3.  import java.io.IOException;  
    4.  import javax.servlet.ServletException;  
    5.  import javax.servlet.http.HttpServlet;  
    6.  import javax.servlet.http.HttpServletRequest;  
    7.  import javax.servlet.http.HttpServletResponse;  
    8.  import com.ite.common.Constants;  
    9.    
    10. public class MyServlet extends HttpServlet\{  
    11.   
    12.     private static final long serialVersionUID = 1L;  
    13.     private MyThread1 myThread1;  
    14.       
    15.     public MyServlet()\{  
    16.     \}  
    17.   
    18.     public void init()\{  
    19.         String str = null;  
    20.         if (str == null && myThread1 == null) \{  
    21.             myThread1 = new MyThread1();  
    22.             myThread1.start(); // servlet 上下文初始化时启动 socket  
    23.         \}  
    24.     \}  
    25.   
    26.     public void doGet(HttpServletRequest httpservletrequest, HttpServletResponse httpservletresponse)  
    27.         throws ServletException, IOException\{  
    28.     \}  
    29.   
    30.     public void destory()\{  
    31.         if (myThread1 != null && myThread1.isInterrupted()) \{  
    32.             myThread1.interrupt();  
    33.         \}  
    34.     \}  
    35. \}  
    36.   
    37. /\*\* 
    38.  \* 自定义一个 Class 线程类继承自线程类，重写 run() 方法，用于从后台获取并处理数据 
    39.  \*  
    40.  \* @author Champion.Wong 
    41.  \*  
    42.  \*/  
    43. class MyThread1 extends Thread \{  
    44.     public void run() \{  
    45.         while (!this.isInterrupted()) \{ // 线程未中断执行循环  
    46.             try \{  
    47.                 Thread.sleep(2000);  
    48.             \} catch (InterruptedException e) \{  
    49.                 e.printStackTrace();  
    50.             \}  
    51.               
    52.             // ------------------ 开始执行 ---------------------------  
    53.             System.out.println("\_\_\_\_FUCK TIME:" + System.currentTimeMillis());  
    54.         \}  
    55.     \}  
    56. \}  
    
      
    然后，在web.xml中配置  
    
    
    **\[html\]** [ view plain][view plain] [copy][view plain]
    
    1.    
    2.  <servlet>  
    3.      <servlet-name>MyListener</servlet-name>  
    4.      <servlet-class>com.ite.wxp.MyServlet</servlet-class>  
    5.      <load-on-startup>9</load-on-startup>  
    6.  </servlet>  
    7.  <servlet-mapping>    
    8.          <servlet-name>MyListener</servlet-name>    
    9.          <url-pattern>/test</url-pattern>     
    10. </servlet-mapping>  
    
      
    OK。启动项目，依然可以看到如图所示：  
    ![0_132530966144xs.gif][]

其中，Listener的方式，该线程肯定是项目中首先启动的，优先于任何一个Servlet。而Servlet的方式，可以设置与其它Servlet启动的顺序。如果有时候需要首先启动一个Servlet或者它们之间的启动顺序有特殊要求的时候，这个就很有作用了。

[view plain]: http://blog.csdn.net/it_wangxiangpan/article/details/7168286#
[0_1325309429JEn7.gif]: /images/20220828/678466309a614ef78367a027c7271e6a.png
[0_132530966144xs.gif]: /images/20220828/eb4de8a02dee4e29a4d70fd4761a581b.png