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

淩亂°似流年 2022-08-22 04:56 137阅读 0赞

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

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

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

1.  **监听（Listener）**  
    首先，我们创建一个监听的类，继承ServletContextListener，如下：  
    
    
    **\[java\]**  [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][]   [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][]   [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][]   [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/20220722/30c3f4b1b5484a269c031ba212e4386a.png
[0_132530966144xs.gif]: /images/20220722/f4a303b79f0147c69243c3922afa68e5.png