classloader实战:如何不重启校验数据库驱动链接
场景介绍
使用过was的时候,我们常见的建立数据源时有一个验证数据库信息的正确性的按钮。但是如果没有相应的驱动包的时候,校验是失败的,如果想校验成功,那就加入对应的数据库驱动包即可,但是was本身并不是热部署的,要想验证那就必须重启was。这个在服务器还是可以接受的,因为你建立数据源肯定是是先有规划的,驱动包都是放入指定地点的,weblogic11g was本身还提供了很多数据库的Jar包以备使用。但是换成一个配置系统的话,那这样的操作就不能忍受了。因为要验证一下数据库连接是否正确还要去重启远程的机器,这听起来就比较麻烦。
解决方案
java的热部署方案可以解决这个问题。java利用classloader的双亲委托机制可以解决这个问题。思路就是用新的classloader去加载类,然后去做校验,打破双亲委托。类加载的目录就是我们指定的目录,每次可以上传jar包到固定目录。然后用新的classloader去加载。
代码实现
首先要写一个破坏双亲委托的classloader。
package com.xp.classloader; import java.net.URL; import java.net.URLClassLoader; import java.util.HashMap; import java.util.Map; public class DriverLoader extends URLClassLoader { // class cache Map<String, Class<?>> loadedClasses = new HashMap<>(); public DriverLoader(URL[] urls) { super(urls); } @Override public Class<?> loadClass(String name) throws ClassNotFoundException { if (loadedClasses.containsKey(name)) { return loadedClasses.get(name); } try { Class<?> findClass = this.findClass(name); loadedClasses.put(name, findClass); return findClass; } catch (ClassNotFoundException e) { // ignore it } return super.loadClass(name); } @Override protected Package getPackage(String name) { return super.getPackage(name); } }
当有新的jar包上传的时候,就需要重新加载类,这里的类是可以配置的。然后根据配置读取加载的类。
package com.xp.classloader; import java.io.File; import java.io.FilenameFilter; import java.net.URL; public class ClassManager { public static final String DIR = "d:/jarFile/"; public static Class<?> getClass(String className) throws Exception { File jarDir = new File(DIR); File[] listFiles = jarDir.listFiles(new FilenameFilter() { @Override public boolean accept(File dir, String name) { // check jar file if (name.endsWith(".jar")) { return true; } return false; } }); URL[] urls; if (listFiles == null) { urls = new URL[0]; } else { int count = 0; urls = new URL[listFiles.length]; for (File listFile : listFiles) { urls[count++] = listFile.toURI().toURL(); } } ClassLoader loader = new DriverLoader(urls); return loader.loadClass(className); } }
为了发现文件上传就可以出发这个操作,所以此时需要使用java7的新特性---目录监控。
package com.xp.dir; import java.io.IOException; import java.nio.file.FileSystems; import java.nio.file.Paths; import java.nio.file.StandardWatchEventKinds; import java.nio.file.WatchEvent; import java.nio.file.WatchEvent.Kind; import java.nio.file.WatchKey; import java.nio.file.WatchService; public class DirWatcher { private WatchService service; public DirWatcher(String filePath) throws IOException { service = FileSystems.getDefault().newWatchService(); // register create event Paths.get(filePath).register(service, StandardWatchEventKinds.ENTRY_CREATE); } public void watch(WatcherHandler handler) throws InterruptedException { while (true) { WatchKey key = service.take(); for (WatchEvent<?> event : key.pollEvents()) { Kind<?> kind = event.kind(); if (kind == StandardWatchEventKinds.ENTRY_CREATE) { handler.handler(); } } key.reset(); } } }
为了完成功能代码简洁,这里使用了回调。增加一个接口。
package com.xp.dir; public interface WatcherHandler { public void handler(); }
接下来就是调用的主体。
package com.xp; import com.xp.classloader.ClassManager; import com.xp.dir.DirWatcher; import com.xp.dir.WatcherHandler; public class Main { public static void main(String[] args) throws Exception { new DirWatcher(ClassManager.DIR).watch(new WatcherHandler() { @Override public void handler() { Class<?> class1; try { class1 = ClassManager.getClass("com.mysql.jdbc.Driver"); if (class1 != null) { System.out.println("success"); } } catch (Exception e) { e.printStackTrace(); } } }); } }
开启目录监控,然后直接使用回调去加载mysql的驱动类。这里已经获取到驱动类了,再通过这个驱动类就能直接获取链接。
总结
classloader让Java的操作更加灵活,很多需要重启应用的问题,都可以考虑加入classloader来做到热更新。
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
手把手教你搭建一个基于Java的分布式爬虫系统
在不用爬虫框架的情况下,我经过多方学习,尝试实现了一个分布式爬虫系统,并且可以将数据保存到不同地方,类似 MySQL、HBase 等。 因为此系统基于面向接口的编码思想来开发,所以具有一定的扩展性,有兴趣的朋友直接看一下代码,就能理解其设计思想。 虽然代码目前来说很多地方还是比较紧耦合,但只要花些时间和精力,很多都是可抽取出来并且可配置化的。 因为时间的关系,我只写了京东和苏宁易购两个网站的爬虫,但是完全可以实现不同网站爬虫的随机调度,基于其代码结构,再写国美、天猫等的商品爬取,难度不大,但是估计需要花些时间和精力。 因为在解析网页的数据时,比如我在爬取苏宁易购商品的价格时,价格是异步获取的,并且其 API 是一长串的数字组合,我花了几个小时的时间才发现其规律,当然也承认,我的经验不足。 这个系统的设计,除了基本的数据爬取以外,更关注以下几
- 下一篇
Android开发bug收集(疑难bug 持续更新)
一、关于FloatingActionButton的bug 1、错误信息: Error inflating class android.support.design.widget.FloatingActionButton 2、解决方法: 将android:backgroundTint="#ffffff"换成app:backgroundTint="#ffffff" 某次删除一个adapter之后出现的bug 1、错误信息: The activity must be exported or contain an intent-filter bug显示 2、解决策略: 点击下拉框选择app,即可运行 解决方法 二、关于 A/chromium: [FATAL:jni_android.cc(243)] Please include Java exception stack in crash report 的bug 1、错误信息 A/chromium: [FATAL:jni_android.cc(243)] Please include Java exception stack in crash r...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
-
Docker使用Oracle官方镜像安装(12C,18C,19C)
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- CentOS8编译安装MySQL8.0.19
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- MySQL8.0.19开启GTID主从同步CentOS8
- CentOS7,8上快速安装Gitea,搭建Git服务器
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
推荐阅读
最新文章
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- CentOS6,CentOS7官方镜像安装Oracle11G
- SpringBoot2整合Redis,开启缓存,提高访问速度
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- SpringBoot2整合MyBatis,连接MySql数据库做增删改查操作
- Hadoop3单机部署,实现最简伪集群
- MySQL8.0.19开启GTID主从同步CentOS8
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果