Jetty：以编程方式停止会导致“无法停止 1 个线程”

Question

我有一个嵌入式 Jetty 6.1.26 实例。 我想通过发送到/shutdown 的 HTTP GET 来关闭它。 于是我创建了一个JettyShutdownServlet：

@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {

 resp.setStatus(202, "Shutting down.");
 resp.setContentType("text/plain");
 ServletOutputStream os = resp.getOutputStream();
 os.println("Shutting down.");
 os.close();
 resp.flushBuffer();

 // Stop the server.
 try {
    log.info("Shutting down the server...");
    server.stop();
 } catch (Exception ex) {
    log.error("Error when stopping Jetty server: "+ex.getMessage(), ex);
 }

但是，当我发送请求时，Jetty 并没有停止 - 一个线程一直挂在 org.mortbay.thread.QueuedThreadPool 与 this.wait() 的行上：

   // We are idle
   // wait for a dispatched job
   synchronized (this)
   {
       if (_job==null)
          this.wait(getMaxIdleTimeMs());
       job=_job;
       _job=null;
   }

...

2011-01-10 20:14:20,375 INFO  org.mortbay.log jetty-6.1.26
2011-01-10 20:14:34,756 INFO  org.mortbay.log Started SocketConnector@0.0.0.0:17283
2011-01-10 20:25:40,006 INFO  org.jboss.qa.mavenhoe.MavenHoeApp Shutting down the server...
2011-01-10 20:25:40,006 INFO  org.mortbay.log Graceful shutdown SocketConnector@0.0.0.0:17283
2011-01-10 20:25:40,006 INFO  org.mortbay.log Graceful shutdown org.mortbay.jetty.servlet.Context@1672bbb{/,null}
2011-01-10 20:25:40,006 INFO  org.mortbay.log Graceful shutdown org.mortbay.jetty.webapp.WebAppContext@18d30fb{/jsp,file:/home/ondra/work/Mavenhoe/trunk/target/classes/org/jboss/qa/mavenhoe/web/jsp}
2011-01-10 20:25:43,007 INFO  org.mortbay.log Stopped SocketConnector@0.0.0.0:17283
2011-01-10 20:25:43,009 WARN  org.mortbay.log 1 threads could not be stopped
2011-01-10 20:26:43,010 INFO  org.mortbay.log Shutdown hook executing
2011-01-10 20:26:43,011 INFO  org.mortbay.log Shutdown hook complete

它会阻塞整整一分钟，然后关闭。 我添加了 Graceful shutdown，它应该允许我从 servlet 关闭服务器；但是，从日志中可以看出，它不起作用。

我是这样解决的：

Server server = new Server( PORT );
server.setGracefulShutdown( 3000 );
server.setStopAtShutdown(true);
...
server.start();

if( server.getThreadPool() instanceof QueuedThreadPool ){
   ((QueuedThreadPool) server.getThreadPool()).setMaxIdleTimeMs( 2000 );
}

setMaxIdleTimeMs()需要在start()之后调用，因为threadPool是在start()中创建的。但是，线程已经创建并等待，所以它只适用于所有线程至少使用一次之后。

除了中断所有线程或System.exit() 之类的可怕事情之外，我不知道还能做什么。

有什么想法吗？有什么好办法吗？

Answer 1

Graceful 不会像您认为的那样做 - 它允许服务器正常关闭，但它不允许您从 servlet 内部关闭。

问题如您链接到的邮件列表帖子中所述 - 您正在尝试停止服务器，而您仍在处理服务器内部的连接。

您应该尝试将 servlet 的实现更改为：

// Stop the server.
new Thread()
{
   public void run() {
     try {
        log.info("Shutting down the server...");
        server.stop();
        log.info("Server has stopped.");
     } catch (Exception ex) {
        log.error("Error when stopping Jetty server: "+ex.getMessage(), ex);
     }
   }
}.start();

这样 servlet 可以在服务器关闭时完成处理，并且不会阻止关闭过程。