Tomcat关闭导致执行程序服务数据丢失？

Question

我有几个 Kafka 消费者从 Kafka 集群中提取消息，然后他们将这些消息放入执行器服务中进行处理。消息本身的处理是耗时的。当我尝试关闭应用程序时——即关闭 Tomcat，我注意到执行程序服务将继续工作，但速度要慢得多，并且出现一些套接字超时异常。这意味着我可能要等待很长时间才能完成 Tomcat 关闭过程，但它只是继续运行。如果我手动杀死 Tomcat 线程，那么我会丢失很多消息。我有办法解决这个问题吗？非常感谢！

Answer 1

线程池继续存在

执行器的线程池可能会在其父应用程序结束后继续运行。因此，您应该在退出应用程序时始终优雅地关闭执行程序。

ServletContextListener

对于基于Java Servlet 技术的网络应用程序，Servlet spec 定义了一个用于启动和退出网络应用程序的挂钩。

那个钩子是ServletContextListener 接口。该接口需要一对方法，一个由 Servlet 容器在处理 Web 应用程序的第一个传入请求之前调用，另一个在发出最后一个响应后调用。规范要求每个 Servlet 容器（例如 Tomcat）在适当的时间调用这些方法。

在这两种方法中，您可以实例化您的执行器服务，然后将其关闭。

您通过编写一个类来实现接口。您还必须将该类标记到容器中。标记它的最简单方法是使用 @WebListener 注释。

这已经在 Stack Overflow 上讨论过很多次了。所以search for more info 和例子。

JSR 236：Java^TM EE 的并发实用程序

如果使用成熟的Jakarta EE（以前的Java EE）实现（Glassfish、Payara、JBoss 等）而不是单纯的 Servlet 容器（Tomcat、Jetty 等），这项工作会容易得多。这样的服务器将提供JSR 236 的实现来自动处理执行程序的生命周期。所以你不需要实现ServletContextListener。

这也已在 Stack Overflow 上多次解决。所以搜索更多信息。