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

我有一个嵌入式Jetty 6.1.26实例。 我希望通过发送到/shutdown HTTP GET将其/shutdown 。 所以我创建了一个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不会停止 – 一个线程一直挂在带有this.wait()的行上的org.mortbay.thread.QueuedThreadPool

  // 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 ); } 

需要在start()之后调用setMaxIdleTimeMs() ,因为在start()中创建了threadPool。 但是,线程已经创建并等待,因此它仅在所有线程至少使用一次后才适用。

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

有任何想法吗? 有一个好方法吗?

Graceful不会按照您的想法执行操作 – 它允许服务器正常关闭,但它不允许您从servlet内部关闭。

问题是您链接到的邮件列表post中描述的 – 您正在尝试停止服务器,而您仍在处理服务器内部的连接。

您应该尝试将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可以在服务器关闭时完成处理,并且不会阻止关闭过程。