mJ李明杰老师的服务器MJServer

package io.majiang.core; import io.majiang.annotation.GameService; import java.net.JarURLConnection; import java.net.URL; import java.net.URLDecoder; import java.io.File; import java.io.FilenameFilter; import java.io.IOException; import java.util.Collections; import java.util.Enumeration; import java.util.HashMap; import java.util.LinkedHashSet; import java.util.Map; import java.util.Scanner; import java.util.Set; import java.util.jar.JarEntry; import java.util.jar.JarFile; public class ClassScanner { private static Map<String, Class<?>> uriMap; private static FilenameFilter myFilter; public static void scan(){ Map<String, Class<?>> tmpMap = new HashMap<String, Class<?>>(); Set<Class<?>> classSet; try { //设置扫描的报位置 classSet = getClasses("io.majiang"); if (classSet != null) { for (Class<?> clazz : classSet) { if (clazz.isAnnotationPresent(GameService.class)) { GameService annotation = clazz.getAnnotation(GameService.class); tmpMap.put(annotation.Route(), clazz); } } } } catch (ClassNotFoundException e) { System.out.println("ClassUtils 初始化失败"); e.printStackTrace(); } catch (IOException e) { System.out.println("ClassUtils 初始化失败"); e.printStackTrace(); } uriMap = Collections.unmodifiableMap(tmpMap); } public static Class<?>getUriClass(String uri){ return uriMap.get(uri); } public void setClass(String uri,Class<?>uriClass){ uriMap.put(uri, uriClass); } /** * 从包package中获取所有的Class * * @param pack * @return 返回class对象Set * @throws ClassNotFoundException * @throws IOException */ public static Set<Class<?>> getClasses(String pack) throws ClassNotFoundException, IOException { // 第一个class类的集合 Set<Class<?>> classes = new LinkedHashSet<Class<?>>(); // 是否循环迭代 boolean recursive = true; // 获取包的名字，并进行替换 String packageName = pack; String packageDirName = packageName.replace('.', '/'); // 定义一个枚举的集合，并进行循环来处理这个目录下的things Enumeration<URL> dirs; dirs = Thread.currentThread().getContextClassLoader() .getResources(packageDirName); // 循环迭代下去 while (dirs.hasMoreElements()) { // 获取下一个元素 URL url = dirs.nextElement(); // 得到协议的名称 String protocol = url.getProtocol(); // 如果是以文件的形式保存在文件系统上 if ("file".equals(protocol)) { System.err.println("file类型的扫描"); // 获取包的物理路径 String filePath = URLDecoder.decode(url.getFile(), "UTF-8"); // 以文件的方式扫描整个包下的文件，并添加到集合中 findAndAddClassesInPackageByFile(packageName, filePath, recursive, classes); } else if ("jar".equals(protocol)) { // 如果是jar包文件 // 定义一个JarFile System.err.println("jar类型的扫描"); JarFile jar; // 获取jar JarURLConnection jarURLConnection = (JarURLConnection) url .openConnection(); jar = jarURLConnection.getJarFile(); // 从此jar包，得到一个枚举类 Enumeration<JarEntry> entries = jar.entries(); // 同样的进行循环迭代 while (entries.hasMoreElements()) { // 获取jar里的一个实体，可以是目录，和一些jar包里的其他文件，如META-INF等文件 JarEntry entry = entries.nextElement(); String name = entry.getName(); // 如果是以/开头的 if (name.charAt(0) == '/') { // 获取后面的字符串 name = name.substring(1); } // 如果前半部分和定义的包名相同 if (name.startsWith(packageDirName)) { int idx = name.lastIndexOf('/'); // 如果以"/"结尾，是一个包 if (idx != -1) { // 获取包名，把"/"替换成"." packageName = name.substring(0, idx) .replace('/', '.'); } // 如果可以迭代下去，并且是一个包 if ((idx != -1) || recursive) { // 如果是一个.class文件，而且不是目录 if (name.endsWith(".class") && !entry.isDirectory()) { // 去掉后面的".class"，获取真正的类名 String className = name.substring( packageName.length() + 1, name.length() - 6); // 添加到classes classes.add(Class.forName(packageName + '.' + className)); } } } } } } return classes; } /** * 以文件的形式来获取包下的所有Class * * @param packageName * @param packagePath * @param recursive * @param classes * @throws ClassNotFoundException */ private static void findAndAddClassesInPackageByFile(String packageName, String packagePath, final boolean recursive, Set<Class<?>> classes) throws ClassNotFoundException { // 获取此包的目录，建立一个File File dir = new File(packagePath); // 如果不存在或者，也不是目录就直接返回 if (!dir.exists() || !dir.isDirectory()) { return; } // 如果存在，就获取包下的所有文件，包括目录 File[] dirfiles = dir.listFiles(myFilter); // 循环所有文件 for (File file : dirfiles) { // 如果是目录，则继续扫描 if (file.isDirectory()) { findAndAddClassesInPackageByFile( packageName + "." + file.getName(), file.getAbsolutePath(), recursive, classes); } else { // 如果是java类文件，去掉后面的.class，只留下类名 String className = file.getName().substring(0, file.getName().length() - 6); // 添加到集合中去 classes.add(Thread.currentThread().getContextClassLoader() .loadClass(packageName + '.' + className)); } } } }