Rribbit 与Weblogic集成

Rribbit不支持直接部署进Weblogic，原因在于Weblogic解析jar文件的协议是zip，而其它如tomcat，jetty是jar协议。

解决办法如下：

import java.io.File;

import java.io.IOException;

import java.net.URL;

import java.net.URLDecoder;

import java.util.ArrayList;

import java.util.Collection;

import java.util.Enumeration;

import java.util.jar.JarFile;

import java.util.regex.Matcher;

import java.util.regex.Pattern;

import java.util.zip.ZipEntry;

import java.util.zip.ZipFile;

 

import org.rribbit.creation.SpringBeanClassBasedListenerObjectCreator;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

 

/**

 * 

 * @author wangx

 * @date Nov 4, 2015

 * @version

 */

 

public class CustomListenerObjectCreator extends SpringBeanClassBasedListenerObjectCreator {

private static final Logger log = LoggerFactory.getLogger(SpringBeanClassBasedListenerObjectCreator.class);

 

/*

* (non-Javadoc)

* 

* @see

* org.rribbit.creation.AbstractClassBasedListenerObjectCreator#getClasses

* (java.lang.String, boolean)

*/

@Override

protected Collection<Class<?>> getClasses(String packageName, boolean scanSubPackages) throws ClassNotFoundException, IOException {

 

String path = packageName.replace('.', '/');

Enumeration<URL> resources = getClassLoader().getResources(path);

Collection<Class<?>> classes = new ArrayList();

while (resources.hasMoreElements()) {

URL resource = (URL) resources.nextElement();

String filename = URLDecoder.decode(resource.getFile(), "UTF-8");

log.debug("Processing resource '{}' with filename '{}'", resource, filename);

 

if (resource.getProtocol().equals("jar")) {

String jarFilename = filename.substring(5, filename.indexOf("!"));

JarFile jarFile = new JarFile(jarFilename);

classes.addAll(findClassesInJarFile(jarFile, path, scanSubPackages));

} else if (resource.getProtocol().equals("zip")) {

String zipFilename = filename.substring(0, filename.indexOf("!"));

ZipFile jarFile = new ZipFile(zipFilename);

classes.addAll(findClassesInZipFile(jarFile, path, scanSubPackages));

} else {

File directory = new File(filename);

classes.addAll(findClassesInDirectory(directory, packageName, scanSubPackages));

}

}

return classes;

}

 

protected Collection<Class<?>> findClassesInZipFile(ZipFile jarFile, String path, boolean scanSubPackages) throws ClassNotFoundException {

 

log.debug("Scanning jarFile '{}' for classes in package '{}'", jarFile.getName(), path);

Collection<Class<?>> classes = new ArrayList<Class<?>>();

Enumeration<ZipEntry> jarEntries = (Enumeration<ZipEntry>) jarFile.entries();

while(jarEntries.hasMoreElements()) {

String entryName = jarEntries.nextElement().getName();

log.debug("Entry name: '{}'", entryName);

Pattern p;

if(scanSubPackages) {

p = Pattern.compile("(" + path + "/[\\w/]+)\\.class");

} else {

p = Pattern.compile("(" + path + "/\\w+)\\.class");

}

Matcher m = p.matcher(entryName);

if(m.matches()) {

String className = m.group(1).replaceAll("/", ".");

log.debug("Adding Class {}", className);

classes.add(Class.forName(className));

}

}

return classes;

}

｝

<bean id="creator"

class="com.geone.its.CustomListenerObjectCreator">

<property name="packageNames">

<list>

<value>com</value>

</list>

</property>

<property name="scanSubpackages" value="true" />

</bean>