问题背景
最近在搞数据中台项目,用到了flink框架,在获取flink指标项的时候出现了异常. ? ? ?
异常调用代码
ClusterClient.getAccumulators(JobID var1);
出现了类加载不到的异常
ClassNotFoundException: org.apache.flink.util.OptionalFailure
奇怪的是,本地运行没有任何问题,我们是springboot项目,打包运行后出现类找不到的异常。
解决思路:
追踪代码后,基本定位到是classloader加载的问题。于是在项目中增加测试用例。
@GetMapping("/load")
public Object load() {
ClassLoader systemClassLoader = ClassLoader.getSystemClassLoader();
System.out.println("getSystemClassLoader ----> " + systemClassLoader);
String classPath = System.getProperty("java.class.path");
for (String path : classPath.split(":")) {
System.out.println(path);
}
System.out.println("getThreadClassLoader ----> " + Thread.currentThread().getContextClassLoader());
System.out.println("OptionalFailureLoader ---->" +
OptionalFailure.class.getClassLoader());
return AjaxResult.success();
}
结果发现,本地运行和springboot打包后,同一个类的classloader是不一样的,本地启动的classlaoder是sun.misc.Launcher$AppClassLoader。
但是执行java -jar启动后,类加载器是org.springframework.boot.loader.LaunchedURLClassLoader,这是因为spring项目自定义了classloader来加载文件。
那么他们两个是什么关系呢?
打包后,输出结果
getSystemClassLoader ----> sun.misc.Launcher$AppClassLoader@70dea4e
getThreadClassLoader ----> TomcatEmbeddedWebappClassLoader
? context: ROOT
? delegate: true
----------> Parent Classloader:
org.springframework.boot.loader.LaunchedURLClassLoader@533ddba
OptionalFailureLoader ---->org.springframework.boot.loader.LaunchedURLClassLoader@533ddba
可以看到,打包后,OptionalFailtureLoader的类加载器是springboot的classloader加载的,但是我们调用方法传递的是getSystemclassloader,--> sun.misc.Launcher$AppClassLoader,这样根据双亲委派机制,向上寻找肯定是找不到的。
修改方案
?在调用时传递classloader,将当前线程的classloader传递进去。根据上图,当前线程的classsloader是TomcatEmbeddedWebappClassLoader,父classloader是org.springframework.boot.loader.LaunchedURLClassLoader,而打包后,OptionalFailureLoader就是由org.springframework.boot.loader.LaunchedURLClassLoader加载的,双亲委派向上查找,就可以找到对应的java类。这样就可以解决问题。
|