我有一个嵌入式 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()
之后调用,因为线程池是在 start()
中创建的。但是,线程已经创建并等待,因此它仅在所有线程至少使用一次后才适用。
除了中断所有线程或 System.exit()
之类的可怕事情外,我不知道还能做什么。
有什么想法吗?有什么好的方法吗?
最佳答案
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 可以在服务器关闭时完成处理,并且不会阻止关闭进程。
关于java - Jetty:以编程方式停止导致 "1 threads could not be stopped",我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/4650713/