标签:Java Thread UncaughtExceptionHandler lock 捕获 Hook 线程 多线程 异常
Java多线程捕获异常处理
在线程的run方法中,如果有受检异常必须进行捕获处理,如果想要获得run()方法中出现的运行时异常信息,可以通过回调UncaughtExceptionHandler接口获得哪个线程出现了运行时异常,在Thread类中有关处理运行异常的方法有:
- getDefaultUncaughtExceptionHandler() 获得全局的(默认的)UncaughtExceptionHandler。
- getUncaughtExceptionHandler() 获得当前线程的UncaughtExceptionHandler。
- setDefaultUncaughtExceptionHandler(Thread.UncaughtExceptionHandler eh) 设置全局的UncaughtExceptionHandler。
- setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler eh) 设置当前线程的UncaughtExceptionHandler。
当线程运行过程中出现异常,JVM会调用Thread类的dispatchUncaughtException(Throwable e)方法, 该方法会调用getUncaughtExceptionHandler().uncaughtException(this, e); 如果想要获得线程中出现异常的信息,就需要设置线程的UncaughtExceptionHandler。
package com.wkcto.threadexception; import java.io.FileInputStream; /** * 演示设置线程的UnCaughtExceptionHandler回调接口 */ public class Test01 { public static void main(String[] args) { //1)设置线程全局的回调接口 Thread.setDefaultUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() { @Override public void uncaughtException(Thread t, Throwable e) { //t参数接收发生异常的线程, e就是该线程中的异常 System.out.println(t.getName() + "线程产生了异常: " + e.getMessage()); } }); Thread t1 = new Thread(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName() + "开始运行"); try { Thread.sleep(2000); } catch (InterruptedException e) { //线程中的受检异常必须捕获处理 e.printStackTrace(); } System.out.println(12 / 0 ); //会产生算术异常 } }); t1.start(); new Thread(new Runnable() { @Override public void run() { String txt = null; System.out.println( txt.length()); //会产生空指针异常 } }).start(); /* 在实际开发中,这种设计异常处理的方式还是比较常用的,尤其是异常执行的方法 如果线程产生了异常, JVM会调用dispatchUncaughtException()方法,在该方法中调用了getUncaughtExceptionHandler().uncaughtException(this, e);
如果当前线程设置了UncaughtExceptionHandler回调接口就直接调用它自己的uncaughtException方法,
如果没有设置则调用当前线程所在线程组UncaughtExceptionHandler回调接口的uncaughtException方法,如果线程组也没有设置回调接口,则直接把异常的栈信息定向到System.err中 */ } }
Hook钩子线程注入
现在很多软件包括MySQL, Zookeeper, kafka等都存在Hook线程的校验机制, 目的是校验进程是否已启动,防止重复启动程序。
Hook线程也称为钩子线程, 当JVM退出的时候会执行Hook线程.经常在程序启动时创建一个.lock文件, 用.lock文件校验程序是否启动,在程序退出(JVM退出)时删除该.lock文件, 在Hook线程中除了防止重新启动进程外,还可以做资源释放, 尽量避免在Hook线程中进行复杂的操作。
package com.wkcto.hook; import java.io.IOException; import java.nio.file.Path; import java.nio.file.Paths; import java.util.concurrent.TimeUnit; /** * 通过Hook线程防止程序重复启动 */ public class Test { public static void main(String[] args) { //1)注入Hook线程,在程序退出时删除.lock文件 Runtime.getRuntime().addShutdownHook(new Thread(){ @Override public void run() { System.out.println("JVM退出,会启动当前Hook线程,在Hook线程中删除.lock文件"); getLockFile().toFile().delete(); } }); //2)程序运行时,检查lock文件是否存在,如果lock文件存在,则抛出异常 if ( getLockFile().toFile().exists()){ throw new RuntimeException("程序已启动"); }else { //文件不存在,说明程序是第一次启动,创建lock文件 try { getLockFile().toFile().createNewFile(); System.out.println("程序在启动时创建了lock文件"); } catch (IOException e) { e.printStackTrace(); } } //模拟程序运行 for (int i = 0; i < 10; i++) { System.out.println("程序正在运行"); try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); } } } private static Path getLockFile(){ return Paths.get("", "tmp.lock"); } }
本文转载自稀土掘金!
作者:不高兴就喝水叭
链接:https://juejin.cn/post/7026151862503997477
标签:Java,Thread,UncaughtExceptionHandler,lock,捕获,Hook,线程,多线程,异常 来源: https://www.cnblogs.com/zhusf/p/15513301.html
本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享; 2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关; 3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关; 4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除; 5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。