在具有单个 HTTP 请求的 servlet 线程上运行长时间运行的进程总是很糟糕吗？ [复制]

Question

我有一个 Java 应用程序（在 WAS 8.5 上运行），它充当客户端的一种服务器清单。该应用程序有一个 servlet，可触发长时间运行的进程。

流程：从第三方数据库获取数据，执行 Java 逻辑，将记录写回应用程序自己的数据库（这些数据库连接是池化的）。

servlet 不是在启动时加载的，并且每月仅由单个操作人员手动触发一次（在某个特定日期基于客户每月的选择）。 servlet 在历史上一直以这种方式使用 Timer 和 TimerTask：

public class SyncMissingServlet extends HttpServlet implements Servlet{

    public void doPost(HttpServletRequest req, HttpServletResponse resp)
        throws ServletException, IOException
        {               
            try{
                SyncMissing.runSync();
            }catch(Exception ex){
                logger.error(new LogMessage("ERROR: "), ex);
                this.sendReply(printWriter, "ERROR: " + ex.toString());
            }       
        }
}

public class SyncMissing
{
    public static void runSync() throws Exception 
    {
        Timer t = new Timer(true);

        SyncMissingTask task = new SyncMissingTask(); //SyncMissingTask is an instance of TimerTask
        // Start the synchronization 5 secs from now, and run it every 30 days.
        t.schedule(task, 5000, 2592000000l); //this 30 day timings never really worked out for the client, 
                                             //since the app server is restarted frequently for deployments.

    }
}

当前代码中没有使用 Timer.close() 或 TimerTask.close()。 最近这个 Servlet 似乎已经自动触发了，在系统重新启动并重新启动系统上的 WAS 服务之后......这就是担心。

虽然我无法向我的客户解释自动触发器，但我提出了以下选项：
1. 放弃使用 Timer 和 TimerTask（长时间运行的进程然后在 servlet 的线程本身上运行）
2. 代替 TimerTask，将其设为常规 Runnable，并在 servlet 线程内的单独线程中运行。
3.利用Java的Executor Service
4. 迁移到 Servlet 3.0，将 servlet 变成 Async servlet。
5. 完全放弃 servlet，并用批处理作业替换它。

我知道选项 3 和 4 确实是推荐的选项（或者可能是选项 5）。但我有一种感觉，在我的业务场景中 - 选项 3 和 4 可能是矫枉过正。

如果确实需要每月只有一个用户手动调用 servlet，选项 1 和 2 有那么糟糕吗？ （我的客户想要最快的解决方案，当然不会资助选项 5）

Answer 1

好吧，如果 servlet 应该一个月只运行一次，并且只有一个客户端触发它，那么可以在 servlet 的线程本身中运行它，或者在 servlet 中创建一个新线程并让它执行任务。当您有很多客户端同时发出请求时，就会出现负载和响应时间的问题，此时您可能想要使用 Executor 服务或异步 servlet。

Answer 2

无需通过调用 servlet 来激活后台任务。您的 Web 应用程序有自己的生命周期。 Servlet spec 为您的网络应用程序设置和拆除提供了挂钩。无需客户端用户调用 servlet 即可启动和退出后台任务的理想场所。

无需依赖人类用户记住启动后台任务。让您的网络应用技术为您完成工作。

此外，您可能经常听到/读到“从不从 JSP 或 Servlet 启动线程”。对于处理生成网页的每个传入请求，这是值得建议的。但是后台任务（与单个 servlet 请求没有直接关系）是另一回事；只要您正确处理它们，就可以将线程用于后台任务。 “正确”是指您明确地适当地结束这些线程，并处理thread-safety 问题。后台任务的一个示例可能是定期轮询 Web 服务或数据库以刷新数据缓存。

ServletContextListener

如果您希望在您的网络应用中定期执行自动化任务，请使用ServletContextListener。

该接口定义了一对方法。一，contextInitialized，在 Web 应用程序启动时自动调用，保证在处理任何 HTTP 请求之前运行。另一种方法contextDestroyed 在 Web 应用程序被拆除时运行。

提示：使用 @WebListener 注释标记您的侦听器将导致您的 Servlet 容器自动注意到它并在 Web 应用程序启动时进行实例化。

当心a nasty bug when doing development with NetBeans & Tomcat（仅是开发问题，不是部署问题），其中 Web 应用会进行两次启动。

ScheduledExecutorService

在您实现该接口的自定义类中，在contextInitialized 中，建立一个ScheduledExecutorService 对象以重复运行您的任务。在contextDestroyed 中，关闭该执行程序。这非常重要，因为该执行程序的线程将在您的 Web 应用程序甚至 servlet 容器关闭后继续存在。

ScheduledExecutorService 技术取代了Timer 和TimerTask 类。尤其不建议在 Java Servlet 环境中使用这些类。

您可以在侦听器对象中存储对执行器的引用。

@WebListener
class MonthlyTaskRunner implements ServletContextListener {
    private ScheduledExecutorService scheduledExecutorService;

    void contextInitialized(ServletContextEvent see) {
        // initialize your ScheduledExecutorService. 
        // The ScheduledExecutorService will use one or more threads for its work outside of this thread running now.
        this.scheduledExecutorService = … ;
    }

    void contextInitialized(ServletContextEvent see) {
        // Shutdown the executor along with its thread(s).
        this.scheduledExecutorService.shutDown();
    }


}

我和其他人已经在 Stack Overflow 上广泛发布了此内容，例如 this。所以search Stack Overflow。我已经在 Vaadin Web 应用程序的上下文中发布了大量示例，但这些原则适用于任何 servlet Web 应用程序。并查看Oracle Tutorial on Executors。

实例化后在哪里存储对 ScheduledExecutorService 的引用？您可以存储在上下文侦听器的成员变量中。但是更容易访问的地方将是作为 servlet 上下文的“属性”。我在对另一个问题的回答中详细描述了这一点以及示例代码和漂亮的图表：Start & Stop a ScheduledExecutorService in Java EE environment using servlet

YearMonth

在该执行程序任务中，获取您的业务上下文时区的当前日期的年月。将该年份月份与上次执行任务时记录的月份进行比较。在某个地方、一个文件、一个数据库、某个地方记录那个年份的月份。

安排您的ScheduledExecutorService 以不必要的频率运行。与其担心安排一个月，不如让它每天运行。将当前YearMonth 与存储的年月进行比较的检查几乎不需要执行时间。 KISS.

Java 包含一个YearMonth 类。

YearMonth ymThen = YearMonth.parse( "2016-11" );  // Retrieve that string from storage.

ZoneId z = ZoneId.of( "America/Montreal" );
YearMonth ymNow = YearMonth.now( z );
if( ymNow.isAfter( ymThen ) ) {
    // … run the task
    String ymOutput = ymNow.toString();  
    // … write that `ymOutput` string someplace in storage.
 } // Else do nothing. Let the ScheduledExecutorService run again after its designated rest period.

类似问题

• Background timer task in JSP/Servlet web application
• How to run a background task in a servlet based web application?