三:如果更新的功能包括应用逻辑,也就是class改变了,那就稍微麻烦点,你需要了解ClassLoader的原理。使用你定制的ClassLoader重新Load 已经编译好的class,就好比你重启应用一样。下面将简单介绍ClassLoader原理,以及举出一个例子来说明如何避免重启应用程序。 虚拟机通过Classloader来转载类。bootstrap loader 负责load jdk的class(java.*,javax.*), system class loader是bootstrap的子类,负责load 所有在chasspath指定的变量。ClassLoader将字节流转化为Class类,这些字节流可能来源文件,也可能来源于网络或者数据库。转化方法是调用ClassLoader提供的final defineClass(className, classBytes, 0, classBytes.length)方法来实现。需要记住的是虚拟机里一个类的唯一标识是通过类的包名+类名+装载此类的ClassLoader。同一个ClassLoader实例只能装载Class一次,重复装载将抛出重复类定义异常。 如下自定义ClassLoader将从classpath里转载指定的类,来说明如上对ClassLoader的介绍,同时,我们用此ClassLoader演示如何避免重启动应用程序 public class DyLoader extends ClassLoader { public DyLoader() { super(DyLoader.class.getClassLoader()); }
public Class loadFromCustomRepository(String className) { /**取环境变量*/ String classPath = System.getProperty("java.class.path"); List classRepository = new ArrayList(); /**取得该路径下的所有文件夹 */ if ( (classPath != null) && ! (classPath.equals(""))) { StringTokenizer tokenizer = new StringTokenizer(classPath, File.pathSeparator); while (tokenizer.hasMoreTokens()) { classRepository.add(tokenizer.nextToken()); } } Iterator dirs = classRepository.iterator(); byte[] classBytes = null; /**在类路径上查找该名称的类是否存在,如果不存在继续查找*/ while (dirs.hasNext()) { String dir = (String) dirs.next(); //replace '.' in the class name with File.separatorChar & append .class to the name String classFileName = className.replace('.', File.separatorChar); classFileName += ".class"; try { File file = new File(dir + File.separatorChar + classFileName); if (file.exists()) { InputStream is = new FileInputStream(file); /**把文件读到字节文件*/ classBytes = new byte[is.available()]; is.read(classBytes); break; } } catch (IOException ex) { System.out.println("IOException raised while reading class file data"); ex.printStackTrace(); return null; } } return this.defineClass(className, classBytes, 0, classBytes.length);//加载类 }
}
如下调用 DyLoader loader = new DyLoader(); Class a = loader.loadFromCustomRepository("com.lijz.SampleDyService"); Class b = loader.loadFromCustomRepository("com.lijz.SampleDyService"); 第三行代码将会抛出 java.lang.LinkageError: duplicate class definition: com/lijz/SampleDyService
如果如下调用,则一切正常,这是因为你使用新的ClassLoader实例来装载com.lijz.SampleDyService" DyLoader loader= new DyLoader(); Class a loader.loadFromCustomRepository("com.lijz.SampleDyService"); DyLoader newLoader = new DyLoader(); Class b = newLoader.loadFromCustomRepository("com.lijz.SampleDyService");
言归正传,停止介绍Classloader,回到利用Classloader来避免重新启动你的应用程序
首先定义业务逻辑处理模块接口
public interface IDyService { public void start(); public void close(); public void doBusiness(); }
start方法用于初始化,close用于清除此服务。doBusiness用来模拟处理业务
一个实现的例子如下: public class SampleDyService implements IDyService { public SampleDyService() { } public void doBusiness() { System.out.println("hello boy"); } public void start() { System.out.println("Start SampleDyService:"); System.out.println(SampleDyService.class.getClassLoader()); }
public void close() { System.out.println("close SampleDyService:"); } }
start方法 close方法仅打印出提示信息。doBuinsess输出"hello boy"。主程序将循环调用doBusiness方法
public class Main() { private IDyService service = null; public Main() throws Exception { DyLoader loader = new DyLoader(); service = (IDyService) loader.loadFromCustomRepository( "com.gctech.service.test.dyloader.SampleDyService").newInstance(); service.start(); while (true) {
service.doBusiness(); Thread.sleep(1000 * 3); } } public static void main(String[] args) throws Exception { Main main = new Main(); } } 假设业务逻辑改变,要求SampleDyService的doBusiness打印出"hello girl"。新编译好的SampleDyService已经覆盖了原来的类。在不启动应用程序前提条件下如何更新新的业务逻辑呢? 分俩部来完成 第一步,在Main类里添加notifyReLoad方法,用新的classloader重新生成SampleDyService实例 public void notifyReLoad() throws Exception { service.close(); DyLoader loader = new DyLoader(); service = (IDyService) loader.loadFromCustomRepository( "com.gctech.service.test.dyloader.SampleDyService").newInstance(); service.start();
} 第二步:使用某种机制检测来检测SampleDyService.class已经改变,如可以通过上面的例子启动一个线程检测SampleDyService.class是否被改变,如果改变则调用Main.notifyReLoad().也可以采用主动通知方式,如web应用中,提供这样的界面调用。在此例子中提供一个检测线程。 public class DyServciceChecker extends Thread { Main main = null; public DyServciceChecker() { } public void setMain(Main main) { this.main = main;
}
public void run() { while(!interrupted()) { try { boolean isChanged = check(); if(isChanged) { main.notifyReLoad();
} else { Thread.sleep(1000*50);
} } catch (Exception ex) { ex.printStackTrace(); } } } }
修改Main类的构造函数成如下
public Main() throws Exception { DyLoader loader = new DyLoader(); service = (IDyService) loader.loadFromCustomRepository( "com.gctech.service.test.dyloader.SampleDyService").newInstance(); service.start(); //添加检测线程 DyServciceChecker checker = new DyServciceChecker(); checker.setMain(this); checker.start(); while (true) {
service.doBusiness(); Thread.sleep(1000 * 3); } } 好了,运行Main类。并在运行过程中用新的SampleDyService.class覆盖旧的SampleDyService.class。控制台输出信息如下:
Start SampleDyService:
com.gctech.service.test.dyloader.DyLoader@108786b
hello boy
hello boy
hello boy
............... close SampleDyService:
Start SampleDyService:
com.gctech.service.test.dyloader.DyLoader@c1cd1f
hello girl
hello girl
总结: 如果应用程序不可避免的在运行中要重启动,你首先要做好的工作是采取合理的设计,保证用户的请求和对用户的相应不丢失。否则,只能等到用户访问量最少的时候去启动。还有你在写你的业务逻辑的时候,即使当时你很肯定你的代码写死也没关系也不要这么做,尽量采用配置文件的方法,并提供如上的检测线程,现在的web container都提供检测web.xml文件是否改变来确定是否需要重新部署web。最后Classloader能帮助你动态加载类,从而在不停止应用程序的情况下动态更新类 
|