WAR共享的容器级版本库



在Java servlet容器(最好是Tomcat,但如果这可以在不同的容器中完成,那么就这么说)中,我想要一些理论上可能的东西。我在这里的问题是,是否存在支持它的工具,如果存在,是什么工具(或者我应该进一步研究什么名称)。

我的问题是:在一个servlet容器中,我想运行大量不同的WAR文件。它们共享一些大型公共库(如Spring)。乍一看,我有两个不可接受的选择:

  1. 在每个WAR文件中包括大型库(例如Spring)。这是不可接受的,因为它将加载大量的Spring副本,耗尽服务器上的内存。

  2. 将大型库放在容器类路径中。现在所有的WAR文件共享一个库实例(好)。但这是不可接受的,因为如果不同时升级所有WAR文件,我就无法升级Spring版本,而且如此大的更改几乎是不可能的。

然而,理论上,有一种替代方案可以奏效:

  1. 将大型库的每个版本放入容器级类路径中。做一些容器级的魔术,让每个WAR文件声明它希望使用的版本,并在其类路径中找到它

"魔术"必须在容器级别完成(我认为),因为这只能通过用不同的类加载器加载库的每个版本,然后调整每个WAR文件可见的类加载器来实现。

那么,你听说过这样做吗?如果是,如何?或者告诉我它叫什么,这样我就可以进一步研究了。

关于Tomcat,对于第7个版本,您可以像一样使用VirtualWebappLocader

<Context>
    <Loader className="org.apache.catalina.loader.VirtualWebappLoader"
            virtualClasspath="/usr/shared/lib/spring-3/*.jar,/usr/shared/classes" />
</Context>

对于第8版Pre&应该使用后期资源代替

<Context>
    <Resources>
        <PostResources className="org.apache.catalina.webresources.DirResourceSet"
                       base="/usr/shared/lib/spring-3" webAppMount="/WEB-INF/lib" />
        <PostResources className="org.apache.catalina.webresources.DirResourceSet"
                       base="/usr/shared/classes" webAppMount="/WEB-INF/classes" />
    </Resources>
</Context>

不要忘记将相应的context.xml放入Web应用程序的META-INF中。

对于码头和其他集装箱,可以使用相同的技术。唯一的区别在于如何为web应用程序指定额外的类路径元素。


更新上面的示例不共享加载的类,但其思想是相同的——使用自定义类加载器。这只是一个非常丑陋的示例,它还试图防止类加载器在取消部署期间泄漏。


共享WebappLoader

package com.foo.bar;
import org.apache.catalina.LifecycleException;
import org.apache.catalina.loader.WebappLoader;
public class SharedWebappLoader extends WebappLoader {
    private String pathID;
    private String pathConfig;
    static final ThreadLocal<ClassLoaderFactory> classLoaderFactory = new ThreadLocal<>();
    public SharedWebappLoader() {
        this(null);
    }
    public SharedWebappLoader(ClassLoader parent) {
        super(parent);
        setLoaderClass(SharedWebappClassLoader.class.getName());
    }
    public String getPathID() {
        return pathID;
    }
    public void setPathID(String pathID) {
        this.pathID = pathID;
    }
    public String getPathConfig() {
        return pathConfig;
    }
    public void setPathConfig(String pathConfig) {
        this.pathConfig = pathConfig;
    }
    @Override
    protected void startInternal() throws LifecycleException {
        classLoaderFactory.set(new ClassLoaderFactory(pathConfig, pathID));
        try {
            super.startInternal();
        } finally {
            classLoaderFactory.remove();
        }
    }
}

共享WebappClassLoader

package com.foo.bar;
import org.apache.catalina.LifecycleException;
import org.apache.catalina.loader.ResourceEntry;
import org.apache.catalina.loader.WebappClassLoader;
import java.net.URL;
public class SharedWebappClassLoader extends WebappClassLoader {
    public SharedWebappClassLoader(ClassLoader parent) {
        super(SharedWebappLoader.classLoaderFactory.get().create(parent));
    }
    @Override
    protected ResourceEntry findResourceInternal(String name, String path) {
        ResourceEntry entry = super.findResourceInternal(name, path);
        if(entry == null) {
            URL url = parent.getResource(name);
            if (url == null) {
                return null;
            }
            entry = new ResourceEntry();
            entry.source = url;
            entry.codeBase = entry.source;
        }
        return entry;
    }
    @Override
    public void stop() throws LifecycleException {
        ClassLoaderFactory.removeLoader(parent);
    }
}

ClassLoaderFactory

package com.foo.bar;
import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLClassLoader;
import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
public class ClassLoaderFactory {
    private static final class ConfigKey {
        private final String pathConfig;
        private final String pathID;
        private ConfigKey(String pathConfig, String pathID) {
            this.pathConfig = pathConfig;
            this.pathID = pathID;
        }
        @Override
        public boolean equals(Object o) {
            if (this == o) return true;
            if (o == null || getClass() != o.getClass()) return false;
            ConfigKey configKey = (ConfigKey) o;
            if (pathConfig != null ? !pathConfig.equals(configKey.pathConfig) : configKey.pathConfig != null)
                return false;
            if (pathID != null ? !pathID.equals(configKey.pathID) : configKey.pathID != null) return false;
            return true;
        }
        @Override
        public int hashCode() {
            int result = pathConfig != null ? pathConfig.hashCode() : 0;
            result = 31 * result + (pathID != null ? pathID.hashCode() : 0);
            return result;
        }
    }
    private static final Map<ConfigKey, ClassLoader> loaders = new HashMap<>();
    private static final Map<ClassLoader, ConfigKey> revLoaders = new HashMap<>();
    private static final Map<ClassLoader, Integer> usages = new HashMap<>();
    private final ConfigKey key;
    public ClassLoaderFactory(String pathConfig, String pathID) {
        this.key = new ConfigKey(pathConfig, pathID);
    }
    public ClassLoader create(ClassLoader parent) {
        synchronized (loaders) {
            ClassLoader loader = loaders.get(key);
            if(loader != null) {
                Integer usageCount = usages.get(loader);
                usages.put(loader, ++usageCount);
                return loader;
            }
            Properties props = new Properties();
            try (InputStream is = new BufferedInputStream(new FileInputStream(key.pathConfig))) {
                props.load(is);
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
            String libsStr = props.getProperty(key.pathID);
            String[] libs = libsStr.split(File.pathSeparator);
            URL[] urls = new URL[libs.length];
            try {
                for(int i = 0, len = libs.length; i < len; i++) {
                    urls[i] = new URL(libs[i]);
                }
            } catch (MalformedURLException e) {
                throw new RuntimeException(e);
            }
            loader = new URLClassLoader(urls, parent);
            loaders.put(key, loader);
            revLoaders.put(loader, key);
            usages.put(loader, 1);
            return loader;
        }
    }
    public static void removeLoader(ClassLoader parent) {
        synchronized (loaders) {
            Integer val = usages.get(parent);
            if(val > 1) {
                usages.put(parent, --val);
            } else {
                usages.remove(parent);
                ConfigKey key = revLoaders.remove(parent);
                loaders.remove(key);
            }
        }
    }
}

第一个应用程序的context.xml

<Context>
    <Loader className="com.foo.bar.SharedWebappLoader"
            pathConfig="${catalina.base}/conf/shared.properties"
            pathID="commons_2_1"/>
</Context>

第二个应用程序的context.xml

<Context>
    <Loader className="com.foo.bar.SharedWebappLoader"
            pathConfig="${catalina.base}/conf/shared.properties"
            pathID="commons_2_6"/>
</Context>

$TOMCAT_HOME/conf/shared.properties

commons_2_1=file:/home/xxx/.m2/repository/commons-lang/commons-lang/2.1/commons-lang-2.1.jar
commons_2_6=file:/home/xxx/.m2/repository/commons-lang/commons-lang/2.6/commons-lang-2.6.jar

我能够为Tomcat实现这一点(在Tomcat 7.0.52上测试)。我的解决方案包括实现自定义版本的WebAppLoader,它扩展了标准Tomcat的WebAppLoader。有了这个解决方案,您可以传递自定义的类加载器来加载每个web应用程序的类。

要使用这个新的加载器,您需要为每个应用程序声明它(可以在每个war中的Context.xml文件中,也可以在Tomcat的server.xml文件中)。此加载程序接受一个额外的自定义参数webappName,该参数稍后传递给LibrariesStorage类,以确定哪个应用程序应使用哪些库。

    <Context  path="/pl-app" >
        <Loader className="web.DynamicWebappLoader" webappName="pl-app"/>
    </Context>      
    <Context  path="/my-webapp" >
        <Loader className="web.DynamicWebappLoader" webappName="myApplication2"/>
    </Context>

定义好后,您需要将此DynamicWebappLoader安装到Tomcat。要做到这一点,请将所有复制的类复制到Tomcat的lib目录中(因此您应该有以下文件[Tomcat dir]/lib/web/DynamicWebappLoader.class、[Tomcat dir]/lib/web/LibrariesStorage.class、[Tomcat dir]/lib/web/LibraryAndVersion.class和[Tomcat dir]/lib/web/WebAppAwareClassLoader.class)。

您还需要下载xbean-classloader-4.0.jar,并将其放置在Tomcat的lib目录中(因此您应该有[Tomcat dir]/lib/xbean-classloader-4.0.jar。注意:xbean classloader提供了classloader的特殊实现(org.apache.xbean.classloader.JarFileClassLoader),它允许在运行时加载所需的jar。

主要技巧是在LibraryStorgeClass中完成的(完整的实现在最后)。它存储每个应用程序(由webappName定义)与允许此应用程序加载的库之间的映射。在当前的实现中,这是硬编码的,但可以重写以动态生成每个应用程序所需的库列表。每个库都有自己的JarFileClassLoader实例,确保每个库只加载一次(库与其类加载器之间的映射存储在static字段"libraryToClassLoader"中,因此由于字段的静态性质,该映射对每个web应用程序都是相同的)

class LibrariesStorage {
    private static final String JARS_DIR = "D:/temp/idea_temp_proj2_/some_jars";
  private static Map<LibraryAndVersion, JarFileClassLoader> libraryToClassLoader = new HashMap<>();
  private static Map<String, List<LibraryAndVersion>> webappLibraries = new HashMap<>();
  static {
    try {
      addLibrary("commons-lang3", "3.3.2", "commons-lang3-3.3.2.jar"); // instead of this lines add some intelligent directory scanner which will detect all jars and their versions in JAR_DIR
      addLibrary("commons-lang3", "3.3.1", "commons-lang3-3.3.1.jar");
      addLibrary("commons-lang3", "3.3.0", "commons-lang3-3.3.0.jar");
      mapApplicationToLibrary("pl-app", "commons-lang3", "3.3.2"); // instead of manually mapping application to library version, some more intelligent code should be here (for example you can scann Web-Inf/lib of each application and detect needed jars
      mapApplicationToLibrary("myApplication2", "commons-lang3", "3.3.0");
     (...)    
 } 

在上面的例子中,假设在包含所有jar的目录中(这里由jars_DIR定义),我们只有一个公共的lang3-3.3.2.jar文件。这意味着由"pl-app"名称标识的应用程序(该名称来自Context.xml中标记中的webappName属性,如上所述)将能够从commons-lang-jar加载类。由"myApplication2"标识的应用程序此时将获得ClassNotFoundException,因为它只能访问commons-lang3-3.3.0.jar,但JARS_DIR目录中不存在此文件。

此处全面实施:

package web;
import org.apache.catalina.loader.WebappLoader;
import org.apache.xbean.classloader.JarFileClassLoader;
import java.io.File;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class DynamicWebappLoader extends WebappLoader {
  private String webappName;
  private WebAppAwareClassLoader webAppAwareClassLoader;
  public static final ThreadLocal lastCreatedClassLoader = new ThreadLocal();
  public DynamicWebappLoader() {
    super(new WebAppAwareClassLoader(Thread.currentThread().getContextClassLoader()));
    webAppAwareClassLoader = (WebAppAwareClassLoader) lastCreatedClassLoader.get(); // unfortunately I did not find better solution to access new instance of WebAppAwareClassLoader created in previous line so I passed it via thread local
    lastCreatedClassLoader.remove();
  }
  // (this method is called by Tomcat because of Loader attribute in Context.xml - <Context> <Loader className="..." webappName="myApplication2"/> )
  public void setWebappName(String name) {
    System.out.println("Setting webapp name: " + name);
    this.webappName = name;
    webAppAwareClassLoader.setWebAppName(name); // pass web app name to ClassLoader 
  }

}

class WebAppAwareClassLoader extends ClassLoader {
  private String webAppName;
  public WebAppAwareClassLoader(ClassLoader parent) {
    super(parent);
    DynamicWebappLoader.lastCreatedClassLoader.set(this); // store newly created instance in ThreadLocal .. did not find better way to access the reference later in code
  }
  @Override
  public Class<?> loadClass(String className) throws ClassNotFoundException {
    System.out.println("Load class: " + className + " for webapp: " + webAppName);
    try {
      return LibrariesStorage.loadClassForWebapp(webAppName, className);
    } catch (ClassNotFoundException e) {
      System.out.println("JarFileClassLoader did not find class: " + className + " " + e.getMessage());
      return super.loadClass(className);
    }
  }
  public void setWebAppName(String webAppName) {
    this.webAppName = webAppName;
  }
}
class LibrariesStorage {
  private static final String JARS_DIR = "D:/temp/idea_temp_proj2_/some_jars";
  private static Map<LibraryAndVersion, JarFileClassLoader> libraryToClassLoader = new HashMap<>();
  private static Map<String, List<LibraryAndVersion>> webappLibraries = new HashMap<>();
  static {
    try {
      addLibrary("commons-lang3", "3.3.2", "commons-lang3-3.3.2.jar"); // instead of this lines add some intelligent directory scanner which will detect all jars and their versions in JAR_DIR
      addLibrary("commons-lang3", "3.3.1", "commons-lang3-3.3.1.jar");
      addLibrary("commons-lang3", "3.3.0", "commons-lang3-3.3.0.jar");
      mapApplicationToLibrary("pl-app", "commons-lang3", "3.3.2"); // instead of manually mapping application to library version, some more intelligent code should be here (for example you can scann Web-Inf/lib of each application and detect needed jars
      mapApplicationToLibrary("myApplication2", "commons-lang3", "3.3.0");
    } catch (MalformedURLException e) {
      throw new RuntimeException(e.getMessage(), e);
    }
  }
  private static void mapApplicationToLibrary(String applicationName, String libraryName, String libraryVersion) {
    LibraryAndVersion libraryAndVersion = new LibraryAndVersion(libraryName, libraryVersion);
    if (!webappLibraries.containsKey(applicationName)) {
      webappLibraries.put(applicationName, new ArrayList<LibraryAndVersion>());
    }
    webappLibraries.get(applicationName).add(libraryAndVersion);
  }
  private static void addLibrary(String libraryName, String libraryVersion, String filename)
                          throws MalformedURLException {
    LibraryAndVersion libraryAndVersion = new LibraryAndVersion(libraryName, libraryVersion);
    URL libraryLocation = new File(JARS_DIR + File.separator + filename).toURI().toURL();
    libraryToClassLoader.put(libraryAndVersion,
      new JarFileClassLoader("JarFileClassLoader for lib: " + libraryAndVersion,
        new URL[] { libraryLocation }));
  }
  private LibrariesStorage() {
  }

  public static Class<?> loadClassForWebapp(String webappName, String className) throws ClassNotFoundException {
    System.out.println("Loading class: " + className + " for web application: " + webappName);
    List<LibraryAndVersion> webappLibraries = LibrariesStorage.webappLibraries.get(webappName);
    for (LibraryAndVersion libraryAndVersion : webappLibraries) {
      JarFileClassLoader libraryClassLoader = libraryToClassLoader.get(libraryAndVersion);
      try {
        return libraryClassLoader.loadClass(className); // ok current lib contained class to load
      } catch (ClassNotFoundException e) {
        // ok.. continue in loop... try to load the class from classloader connected to next library
      }
    }
    throw new ClassNotFoundException("Class " + className + " was not found in any jar connected to webapp: " +
      webappLibraries);
  }
}

class LibraryAndVersion {
  private final String name;
  private final String version;
  LibraryAndVersion(String name, String version) {
    this.name = name;
    this.version = version;
  }
  @Override
  public boolean equals(Object o) {
    if (this == o) {
      return true;
    }
    if ((o == null) || (getClass() != o.getClass())) {
      return false;
    }
    LibraryAndVersion that = (LibraryAndVersion) o;
    if ((name != null) ? (!name.equals(that.name)) : (that.name != null)) {
      return false;
    }
    if ((version != null) ? (!version.equals(that.version)) : (that.version != null)) {
      return false;
    }
    return true;
  }
  @Override
  public int hashCode() {
    int result = (name != null) ? name.hashCode() : 0;
    result = (31 * result) + ((version != null) ? version.hashCode() : 0);
    return result;
  }
  @Override
  public String toString() {
    return "LibraryAndVersion{" +
      "name='" + name + ''' +
      ", version='" + version + ''' +
      '}';
  }
}

JBoss有一个名为Modules的框架来解决这个问题。您可以保存共享库及其版本,并从您的war文件中引用它。

我不知道它是否适用于Tomcat,但它在Wildfly上起到了魅力的作用。

相关内容

  • 没有找到相关文章

最新更新