+++ /dev/null
-package org.argeo.server.catalina;
-
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.net.URL;
-import java.net.URLConnection;
-import java.net.URLStreamHandler;
-import java.util.Properties;
-
-import javax.management.MBeanRegistration;
-
-import org.apache.catalina.Lifecycle;
-import org.apache.catalina.Server;
-import org.apache.catalina.Service;
-import org.apache.catalina.connector.Connector;
-import org.apache.catalina.core.StandardService;
-import org.apache.catalina.util.ServerInfo;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.apache.naming.resources.DirContextURLStreamHandler;
-import org.osgi.framework.Bundle;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.Constants;
-import org.osgi.framework.ServiceRegistration;
-import org.osgi.service.url.AbstractURLStreamHandlerService;
-import org.osgi.service.url.URLConstants;
-import org.osgi.service.url.URLStreamHandlerService;
-import org.springframework.beans.factory.DisposableBean;
-import org.springframework.beans.factory.InitializingBean;
-
-public class CatalinaServer implements DisposableBean,InitializingBean{
- /** logger */
- private static final Log log = LogFactory.getLog(CatalinaServer.class);
-
- /** default XML configuration */
- private static final String DEFAULT_XML_CONF_LOCATION = "conf/default-server.xml";
-
- /** user-configurable XML configuration */
- private static final String XML_CONF_LOCATION = "conf/server.xml";
-
- private BundleContext bundleContext;
-
- private StandardService server;
-
- private ServiceRegistration registration, urlRegistration;
-
- public void afterPropertiesSet() throws Exception {
- log.info("Starting " + ServerInfo.getServerInfo() + " ...");
-
- // default startup procedure
- ClassLoader cl = CatalinaServer.class.getClassLoader();
- Thread current = Thread.currentThread();
- ClassLoader old = current.getContextClassLoader();
-
- try {
- current.setContextClassLoader(cl);
-
- server = createCatalinaServer(bundleContext.getBundle());
-
- server.start();
-
- Connector[] connectors = server.findConnectors();
- for (int i = 0; i < connectors.length; i++) {
- Connector conn = connectors[i];
- log.info("Succesfully started " + ServerInfo.getServerInfo() + " @ " + conn.getDomain() + ":"
- + conn.getPort());
- }
-
- // register URL service
- urlRegistration = registerTomcatJNDIUrlService();
- // publish server as an OSGi service
- registration = publishServerAsAService(server);
- log.info("Published " + ServerInfo.getServerInfo() + " as an OSGi service");
- }
- catch (Exception ex) {
- String msg = "Cannot start " + ServerInfo.getServerInfo();
- log.error(msg, ex);
- throw new RuntimeException(msg, ex);
- }
- finally {
- current.setContextClassLoader(old);
- }
- }
-
- public void destroy() throws Exception {
- // unpublish service first
- registration.unregister();
- urlRegistration.unregister();
-
- log.info("Unpublished " + ServerInfo.getServerInfo() + " OSGi service");
-
- // default startup procedure
- ClassLoader cl = CatalinaServer.class.getClassLoader();
- Thread current = Thread.currentThread();
- ClassLoader old = current.getContextClassLoader();
-
- try {
- current.setContextClassLoader(cl);
- //reset CCL
- // current.setContextClassLoader(null);
- log.info("Stopping " + ServerInfo.getServerInfo() + " ...");
- server.stop();
- log.info("Succesfully stopped " + ServerInfo.getServerInfo());
- }
- catch (Exception ex) {
- log.error("Cannot stop " + ServerInfo.getServerInfo(), ex);
- throw ex;
- }
- finally {
- current.setContextClassLoader(old);
- }
- }
-
- private StandardService createCatalinaServer(Bundle bundle) throws Exception {
- // first try to use the XML file
- URL xmlConfiguration = bundle.getResource(XML_CONF_LOCATION);
-
- if (xmlConfiguration != null) {
- log.info("Using custom XML configuration " + xmlConfiguration);
- }
- else {
- xmlConfiguration = bundle.getResource(DEFAULT_XML_CONF_LOCATION);
- if (xmlConfiguration == null)
- log.error("No XML configuration found; bailing out...");
- else
- log.info("Using default XML configuration " + xmlConfiguration);
- }
-
- return createServerFromXML(xmlConfiguration);
- }
-
- private StandardService createServerFromXML(URL xmlConfiguration) throws IOException {
- OsgiCatalina catalina = new OsgiCatalina();
- catalina.setAwait(false);
- catalina.setUseShutdownHook(false);
- catalina.setName("Catalina");
- catalina.setParentClassLoader(Thread.currentThread().getContextClassLoader());
-
- // copy the URL file to a local temporary file (since Catalina doesn't use URL unfortunately)
- File configTempFile = File.createTempFile("dm.catalina", ".cfg.xml");
- configTempFile.deleteOnExit();
-
- // copy URL to temporary file
- copyURLToFile(xmlConfiguration.openStream(), new FileOutputStream(configTempFile));
- log.debug("Copied configuration " + xmlConfiguration + " to temporary file " + configTempFile);
-
- catalina.setConfigFile(configTempFile.getAbsolutePath());
-
- catalina.load();
-
- Server server = catalina.getServer();
-
- return (StandardService) server.findServices()[0];
- }
-
- private void copyURLToFile(InputStream inStream, FileOutputStream outStream) {
-
- int bytesRead;
- byte[] buf = new byte[4096];
- try {
- while ((bytesRead = inStream.read(buf)) >= 0) {
- outStream.write(buf, 0, bytesRead);
- }
- }
- catch (IOException ex) {
- throw (RuntimeException) new IllegalStateException("Cannot copy URL to file").initCause(ex);
- }
- finally {
- try {
- inStream.close();
- }
- catch (IOException ignore) {
- }
- try {
- outStream.close();
- }
- catch (IOException ignore) {
- }
- }
- }
-
- private ServiceRegistration publishServerAsAService(StandardService server) {
- Properties props = new Properties();
- // put some extra properties to easily identify the service
- props.put(Constants.SERVICE_VENDOR, "Spring Dynamic Modules");
- props.put(Constants.SERVICE_DESCRIPTION, ServerInfo.getServerInfo());
- props.put(Constants.BUNDLE_VERSION, ServerInfo.getServerNumber());
- props.put(Constants.BUNDLE_NAME, bundleContext.getBundle().getSymbolicName());
-
- // spring-dm specific property
- props.put("org.springframework.osgi.bean.name", "tomcat-server");
-
- // publish just the interfaces and the major classes (server/handlerWrapper)
- String[] classes = new String[] { StandardService.class.getName(), Service.class.getName(),
- MBeanRegistration.class.getName(), Lifecycle.class.getName() };
-
- return bundleContext.registerService(classes, server, props);
- }
-
- private ServiceRegistration registerTomcatJNDIUrlService() {
- Properties properties = new Properties();
- properties.put(URLConstants.URL_HANDLER_PROTOCOL, "jndi");
- final URLStreamHandler handler = new DirContextURLStreamHandler();
-
- return bundleContext.registerService(URLStreamHandlerService.class.getName(),
- new AbstractURLStreamHandlerService() {
-
- private final static String EMPTY_STRING = "";
-
-
- public URLConnection openConnection(URL u) throws IOException {
- return new URL(u, EMPTY_STRING, handler).openConnection();
- }
- }, properties);
- }
-
-}
projects / lgpl / argeo-commons.git / blobdiff