我们使用嵌入式 Tomcat 7 来托管 Web 应用程序。
它工作得很好,只有一点点例外。
我们使用嵌入式 Tomcat 的原因是我们需要在多个平台上运行,而我们的架构师已经做出了决定。
问题
我们希望让我们的用户能够在包装器/容器 Java 应用程序运行时检查 WAR 更新(实时更新)。目前,他们必须重新启动我们的应用程序,这是不可取的。
基本上,我们的代码只是检查远程服务器是否有较新的 WAR 文件,如果它们存在,它们就会被下载。问题是我们似乎无法让 Tomcat 服务器关闭或释放它在爆炸的 WAR 文件夹上的锁定。
如果我们完全销毁 Tomcat 实例,那么我们可以部署 WAR 文件并删除爆炸的 WAR 文件夹,但 Tomcat 不会爆炸并托管它们,直到我们完全杀死 wrapper/container JAVA 应用程序并重新启动。一旦我们重新启动,Tomcat 就会分解 WAR 文件并很好地托管应用程序。
我在寻找什么
我希望有一种方法可以取消部署正在更新的应用程序或正确关闭/停止 Tomcat 服务器。
代码示例
我通过不包括下载实现来简化下面的代码示例,因为它工作正常。
Tomcat 实例不是公开的,只是为了便于使用而将其公开。此外,线程内的睡眠只是为了简化示例。
无限循环只是为此示例添加的。
import org.apache.catalina.startup.Tomcat;
import org.apache.catalina.Context;
import org.apache.catalina.Globals;
import org.apache.catalina.LifecycleState;
import org.apache.catalina.loader.WebappLoader;
import org.apache.catalina.startup.Tomcat;
...
public class Testing123
{
public static void main(String[] args)
{
final Testing123 test = new Testing123();
test.createTomcat();
test.downloadUpdate();
(new Thread())
{
public void run()
{
Thread.sleep(10000);
test.downloadUpdate();
}
}.start();
while (true)
{
// this loop is just for this example...
}
}
public Tomcat tomcat = null;
private String webappsPath = "c:\\tomcat\\webapps";
private void createTomcat()
{
this.tomcat = new Tomcat();
this.tomcat.setBaseDir(this.webappsPath);
this.tomcat.setPort("5959");
this.tomcat.getServer().setPort("5960");
this.tomcat.getServer().setShutdown("SHUTDOWN");
this.tomcat.getHost().setCreateDirs(true);
this.tomcat.getHost().setDeployIgnore(null);
this.tomcat.getHost().setDeployOnStartup(true);
this.tomcat.getHost().setAutoDeploy(true);
this.tomcat.getHost().setAppBase(this.webappsPath);
Context ctx = this.tomcat.addWebapp(null, "/app1", "APP1");
ctx.setLoader(new WebappLoader(Testing123.class.getClassLoader()));
ctx.setReloadable(true);
}
private boolean isTomcatRunning()
{
if ((this.tomcat == null) || (LifecycleState.STARTED == this.tomcat.getServer().getState()))
{
return true;
}
return false;
}
private void shutdownTomcat() throws Exception
{
if (this.isTomcatRunning())
{
if ((this.tomcat!= null) && (this.tomcat.getServer() != null))
{
this.tomcat.stop();
while ((LifecycleState.STOPPING == this.tomcat.getServer().getState()) || (LifecycleState.STOPPING_PREP == this.tomcat.getServer().getState()))
{
// wait for the server to stop.
}
}
}
}
private void startTomcat() throws Exception
{
if (this.isTomcatRunning())
{
if ((this.tomcat!= null) && (this.tomcat.getServer() != null))
{
try
{
this.tomcat.init();
while (LifecycleState.INITIALIZING == this.tomcat.getServer().getState())
{
// wait for the server to initialize.
}
}
catch (Throwable e)
{
// ignore
}
this.tomcat.start();
while ((LifecycleState.STARTING == this.tomcat.getServer().getState()) || (LifecycleState.STARTING_PREP == this.tomcat.getServer().getState()))
{
// wait for the server to start.
}
}
}
}
private void downloadUpdate()
{
this.shutdownTomcat();
// Download the WAR file and delete the exploded WAR folder...
this.startTomcat();
}
}