添加模板隔离

jossc · jossc · commit 7879b080c467 · 2019-06-30T14:55:31.000+08:00
diff --git a/.idea/compiler.xml b/.idea/compiler.xml
diff --git a/moduleA/pom.xml b/moduleA/pom.xml
@@ -0,0 +1,25 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+
+    <groupId>moduleA</groupId>
+    <artifactId>moduleTest</artifactId>
+    <packaging>jar</packaging>
+    <modelVersion>4.0.0</modelVersion>
+    <version>1.0-SNAPSHOT</version>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>8</source>
+                    <target>8</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+
+</project>
diff --git a/moduleA/src/main/java/org/moudleA/MoudleServiceA.java b/moduleA/src/main/java/org/moudleA/MoudleServiceA.java
@@ -0,0 +1,13 @@
+package org.moudleA;
+
+/**
+ * @ClassName MoudleServiceA
+ * @Author chenzhuo
+ * @Version 1.0
+ * @Date 2019-06-30 14:41
+ **/
+public class MoudleServiceA {
+    public String sayHelloServiceA(){
+        return "---sayHelloServiceA---";
+    }
+}
diff --git a/moduleA/src/main/java/org/package-info.java b/moduleA/src/main/java/org/package-info.java
@@ -0,0 +1 @@
+package org;
diff --git a/moduleB/pom.xml b/moduleB/pom.xml
@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+
+    <groupId>moduleB</groupId>
+    <artifactId>moduleBTest</artifactId>
+    <packaging>jar</packaging>
+    <modelVersion>4.0.0</modelVersion>
+    <version>1.0-SNAPSHOT</version>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>8</source>
+                    <target>8</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>
diff --git a/moduleB/src/main/java/org/moudleB/MoudleServiceB.java b/moduleB/src/main/java/org/moudleB/MoudleServiceB.java
@@ -0,0 +1,14 @@
+package org.moudleB;
+
+/**
+ * @ClassName MoudleServiceB
+ * @Author chenzhuo
+ * @Version 1.0
+ * @Date 2019-06-30 14:42
+ **/
+public class MoudleServiceB {
+
+    public String sayHelloServiceB(){
+        return "---sayHelloServiceB---";
+    }
+}
diff --git a/moduleB/src/main/java/org/package-info.java b/moduleB/src/main/java/org/package-info.java
@@ -0,0 +1 @@
+package org;
diff --git a/pom.xml b/pom.xml
@@ -6,6 +6,7 @@
 
     <groupId>com.cz</groupId>
     <artifactId>basics.code</artifactId>
+    <packaging>pom</packaging>
     <version>1.0-SNAPSHOT</version>
     <build>
         <plugins>
@@ -20,6 +21,7 @@
         </plugins>
     </build>
 
+
     <dependencies>
         <!-- https://mvnrepository.com/artifact/org.springframework/spring-aop -->
         <dependency>
diff --git a/src/main/java/com/basics/classloadertest/ClassLoaderManager.java b/src/main/java/com/basics/classloadertest/ClassLoaderManager.java
@@ -52,56 +52,4 @@ private String getClassName(JarEntry entry) {
         System.out.println("entryName: " +entryName);
         return entryName.substring(0, entryName.length() - 6);
     }
-
-    public void init(){
-
-        System.out.println("---- load all ----");
-        List<Future<String>> futureList = new ArrayList<>();
-        for(String moudle:moudleList){
-            Future<String> future = executor.submit(() -> {
-                try{
-                    URL[] moduleUrl = new URL[]{new URL("file://"+ moudle)};
-                    @SuppressWarnings("resource")
-                    URLClassLoader classLoader = new URLClassLoader(moduleUrl );
-                    @SuppressWarnings("resource")
-                    JarFile jar = new JarFile(new File(moudle));
-                    Enumeration<JarEntry> entries = jar.entries();
-                    while (entries.hasMoreElements()) {
-                        JarEntry entry = entries.nextElement();
-                        String className = getClassName(entry);
-                        if (className == null ) {
-                            continue;
-                        }
-
-                        try {
-                            Class<?> clazz = classLoader.loadClass(className);
-                            //放到内存里
-                            cache.put(className, clazz);
-                        } catch (Throwable t) {
-                            //System.out.println(t.getLocalizedMessage());
-                        }
-                    }
-                }catch(Exception e){
-                    System.out.println(e.getLocalizedMessage());
-                }
-
-                return moudle;
-            });
-            futureList.add(future);
-        }
-
-        for(Future<String> future:futureList){
-            try {
-                String moduleName = future.get();
-                System.out.println("---load moudle " + moduleName + " ok" );
-            } catch (InterruptedException e) {
-                e.printStackTrace();
-            } catch (ExecutionException e) {
-                e.printStackTrace();
-            }
-        }
-        executor.shutdown();
-        System.out.println("----end load All module----");
-
-    }
 }
diff --git a/src/main/java/com/share/classloader/DriverTest.java b/src/main/java/com/share/classloader/DriverTest.java
@@ -0,0 +1,29 @@
+package com.share.classloader;
+
+
+import java.sql.Driver;
+import java.util.Iterator;
+import java.util.ServiceLoader;
+
+/**
+ * @ClassName DriverTest
+ * @Author chenzhuo
+ * @Version 1.0
+ * @Date 2019-06-30 14:16
+ **/
+public class DriverTest {
+
+    public static void main(String[] args) {
+        ServiceLoader<Driver> loader = ServiceLoader.load(Driver.class);
+        //(2)
+        Iterator<Driver> iterator = loader.iterator();
+        while (iterator.hasNext()) {
+            Driver driver = (Driver) iterator.next();
+            System.out.println("driver:" + driver.getClass() + ",loader:" + driver.getClass().getClassLoader());
+        }
+        //(3)
+        System.out.println("current thread contextloader:" + Thread.currentThread().getContextClassLoader());
+        //(4)
+        System.out.println("ServiceLoader loader:" + ServiceLoader.class.getClassLoader());
+    }
+}
diff --git a/src/main/java/com/share/classloader/ModuleClassLoader.java b/src/main/java/com/share/classloader/ModuleClassLoader.java
@@ -0,0 +1,32 @@
+package com.share.classloader;
+
+import java.net.URL;
+import java.net.URLClassLoader;
+
+/**
+ * @ClassName ModuleClassLoader
+ * @Author chenzhuo
+ * @Version 1.0
+ * @Date 2019-06-30 14:30
+ **/
+public class ModuleClassLoader extends URLClassLoader {
+
+    private ModuleManager manager;
+
+    public ModuleClassLoader(URL[] urls, ModuleManager manager) {
+        super(urls);
+        this.manager = manager;
+    }
+
+    @Override
+    protected Class<?> loadClass(String name, boolean resolve)
+            throws ClassNotFoundException {
+
+        if (manager.getCache().containsKey(name)) {
+            return manager.getCache().get(name);
+        } else {
+            return super.loadClass(name, resolve);
+        }
+    }
+
+}
diff --git a/src/main/java/com/share/classloader/ModuleManager.java b/src/main/java/com/share/classloader/ModuleManager.java
@@ -0,0 +1,99 @@
+package com.share.classloader;
+
+import java.io.File;
+import java.net.URL;
+import java.net.URLClassLoader;
+import java.util.ArrayList;
+import java.util.Enumeration;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.*;
+import java.util.jar.JarEntry;
+import java.util.jar.JarFile;
+
+/**
+ * @ClassName ModuleManager
+ * @Author chenzhuo
+ * @Version 1.0
+ * @Date 2019-06-30 14:22
+ **/
+public class ModuleManager {
+    private ExecutorService executor = Executors.newFixedThreadPool(8);
+    private Map<String, Class> cache = new ConcurrentHashMap<>();
+    private List<String> moudleList = new ArrayList<>();
+
+
+    private String getClassName(JarEntry entry) {
+        String endsWith = ".class";
+        String entryName = entry.getName();
+        if (!entryName.endsWith(endsWith)) {
+            return null;
+        }
+        if (entryName.charAt(0) == '/') {
+            entryName = entryName.substring(1);
+        }
+        entryName = entryName.replace("/", ".");
+        return entryName.substring(0, entryName.length() - 6);
+    }
+
+    public void init() {
+
+        System.out.println("----begin load  All module----");
+        List<Future<String>> futureList = new ArrayList<>();
+        for (String module : moudleList) {
+            Future<String> future = executor.submit(() -> {
+                try {
+                    URL[] moduleUrl = new URL[]{new URL("file://" + module)};
+                    @SuppressWarnings("resource")
+                    URLClassLoader classLoader = new URLClassLoader(moduleUrl);
+                    @SuppressWarnings("resource")
+                    JarFile jar = new JarFile(new File(module));
+                    Enumeration<JarEntry> entries = jar.entries();
+                    while (entries.hasMoreElements()) {
+                        JarEntry entry = entries.nextElement();
+                        String className = getClassName(entry);
+                        if (className == null) {
+                            continue;
+                        }
+
+                        try {
+                            Class<?> clazz = classLoader.loadClass(className);
+                            //缓存jar 里面的 Class 对象。
+                            cache.put(className, clazz);
+                        } catch (Throwable t) {
+
+                        }
+                    }
+                } catch (Exception e) {
+                    System.out.println(e.getLocalizedMessage());
+                }
+                return module;
+            });
+            futureList.add(future);
+        }
+
+        for (Future<String> future : futureList) {
+            try {
+                String moduleName = future.get();
+                System.out.println("---load module " + moduleName + " ok");
+            } catch (InterruptedException | ExecutionException e) {
+                e.printStackTrace();
+            }
+        }
+        executor.shutdown();
+        System.out.println("----end load All module----");
+
+    }
+
+    public Map<String, Class> getCache() {
+        return cache;
+    }
+
+    public List<String> getMoudleList() {
+        return moudleList;
+    }
+
+    public void setMoudleList(List<String> moudleList) {
+        this.moudleList = moudleList;
+    }
+}
diff --git a/src/main/java/com/share/classloader/Test1.java b/src/main/java/com/share/classloader/Test1.java
@@ -0,0 +1,33 @@
+package com.share.classloader;
+
+import java.lang.reflect.InvocationTargetException;
+import java.lang.reflect.Method;
+import java.net.URLClassLoader;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @ClassName Test1
+ * @Author chenzhuo
+ * @Version 1.0
+ * @Date 2019-06-30 14:32
+ **/
+public class Test1 {
+    public static void main(String[] args) throws Exception {
+        System.out.println("Hello World!");
+        ModuleManager manager = new ModuleManager();
+        List<String> jarList = new ArrayList<String>();
+        jarList.add("/Users/demons/IdeaProjects/JavaCode/moduleB/target/moduleBTest-1.0-SNAPSHOT.jar");
+        jarList.add(
+                "/Users/demons/IdeaProjects/JavaCode/moduleA/target/moduleTest-1.0-SNAPSHOT.jar");
+        manager.setMoudleList(jarList);
+        manager.init();
+
+        ModuleClassLoader classLoader = new ModuleClassLoader(((URLClassLoader) Test1.class.getClassLoader()).getURLs(), manager);
+
+        Class serviceA = classLoader.loadClass("org.moudleA.MoudleServiceA");
+        Method sayHelloServiceA = serviceA.getMethod("sayHelloServiceA");
+        String result = (String) sayHelloServiceA.invoke(serviceA.newInstance(), null);
+        System.out.println(result);
+    }
+}
