`
webdev2014
  • 浏览: 680028 次
文章分类
社区版块
存档分类
最新评论

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

 
阅读更多

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

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

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

  1. 监听（Listener）
    首先，我们创建一个监听的类，继承ServletContextListener，如下：
    [java] view plaincopyprint?
    1. package com.wxp.thread;
    3. import javax.servlet.ServletContextEvent;
    4. import javax.servlet.ServletContextListener;
    6. /**
    7. * Listener的方式在后台执行一线程
    8. *
    9. * @author Champion.Wong
    10. *
    11. */
    12. public class MyListener implements ServletContextListener {
    13. private MyThread myThread;
    15. public void contextDestroyed(ServletContextEvent e) {
    16. if (myThread != null && myThread.isInterrupted()) {
    17. myThread.interrupt();
    18. }
    19. }
    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. }
    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. }
    45. // ------------------ 开始执行 ---------------------------
    46. System.out.println("____FUCK TIME:" + System.currentTimeMillis());
    47. }
    48. }
    49. }

    然后，在web.xml中配置如下：
    [html] view plaincopyprint?
    1. <listener>
    2. <listener-class>com.wxp.thread.MyListener</listener-class>
    3. </listener>

    OK，启动项目，我们可以在控制台看到隔时间段输出的文字内容。
  2. 使用Servlet，在项目启动的时候启动它。
    首先，创建一个Servlet，继承HttpServlet
    [java] view plaincopyprint?
    1. package com.wxp.thread;
    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;
    10. public class MyServlet extends HttpServlet{
    12. private static final long serialVersionUID = 1L;
    13. private MyThread1 myThread1;
    15. public MyServlet(){
    16. }
    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. }
    26. public void doGet(HttpServletRequest httpservletrequest, HttpServletResponse httpservletresponse)
    27. throws ServletException, IOException{
    28. }
    30. public void destory(){
    31. if (myThread1 != null && myThread1.isInterrupted()) {
    32. myThread1.interrupt();
    33. }
    34. }
    35. }
    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. }
    52. // ------------------ 开始执行 ---------------------------
    53. System.out.println("____FUCK TIME:" + System.currentTimeMillis());
    54. }
    55. }
    56. }

    然后，在web.xml中配置
    [html] view plaincopyprint?
    1. <!-- LISTENER FOR THREAD -->
    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><!-- 数字越小，启动的优先级越高，必须大于0 -->
    6. </servlet>
    7. <servlet-mapping>
    8. <servlet-name>MyListener</servlet-name>
    9. <url-pattern>/test</url-pattern>
    10. </servlet-mapping>

    OK。启动项目，依然可以看到如图所示：


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

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

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

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

  1. 监听（Listener）
    首先，我们创建一个监听的类，继承ServletContextListener，如下：
    [java] view plaincopyprint?
    1. package com.wxp.thread;
    3. import javax.servlet.ServletContextEvent;
    4. import javax.servlet.ServletContextListener;
    6. /**
    7. * Listener的方式在后台执行一线程
    8. *
    9. * @author Champion.Wong
    10. *
    11. */
    12. public class MyListener implements ServletContextListener {
    13. private MyThread myThread;
    15. public void contextDestroyed(ServletContextEvent e) {
    16. if (myThread != null && myThread.isInterrupted()) {
    17. myThread.interrupt();
    18. }
    19. }
    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. }
    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. }
    45. // ------------------ 开始执行 ---------------------------
    46. System.out.println("____FUCK TIME:" + System.currentTimeMillis());
    47. }
    48. }
    49. }

    然后，在web.xml中配置如下：
    [html] view plaincopyprint?
    1. <listener>
    2. <listener-class>com.wxp.thread.MyListener</listener-class>
    3. </listener>

    OK，启动项目，我们可以在控制台看到隔时间段输出的文字内容。
  2. 使用Servlet，在项目启动的时候启动它。
    首先，创建一个Servlet，继承HttpServlet
    [java] view plaincopyprint?
    1. package com.wxp.thread;
    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;
    10. public class MyServlet extends HttpServlet{
    12. private static final long serialVersionUID = 1L;
    13. private MyThread1 myThread1;
    15. public MyServlet(){
    16. }
    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. }
    26. public void doGet(HttpServletRequest httpservletrequest, HttpServletResponse httpservletresponse)
    27. throws ServletException, IOException{
    28. }
    30. public void destory(){
    31. if (myThread1 != null && myThread1.isInterrupted()) {
    32. myThread1.interrupt();
    33. }
    34. }
    35. }
    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. }
    52. // ------------------ 开始执行 ---------------------------
    53. System.out.println("____FUCK TIME:" + System.currentTimeMillis());
    54. }
    55. }
    56. }

    然后，在web.xml中配置
    [html] view plaincopyprint?
    1. <!-- LISTENER FOR THREAD -->
    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><!-- 数字越小，启动的优先级越高，必须大于0 -->
    6. </servlet>
    7. <servlet-mapping>
    8. <servlet-name>MyListener</servlet-name>
    9. <url-pattern>/test</url-pattern>
    10. </servlet-mapping>

    OK。启动项目，依然可以看到如图所示：


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

分享到：
| vb.net 工程打包（advanced installer打包 ...
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

Magicbox
Global site tag (gtag.js) - Google Analytics