开发PowerCloud时,有一个线程专门用来处理RabbitMQ投递过来的消息,如果意外中断则所有的消息都不会被处理,这就得有一个监听机制,一旦这个线程被意外关闭,必须重启!
常规解决办法有2种:
1,开启另外一个线程,监听爬行线程,使用线程之间的通信,一般是消费者模式,如果爬行线程死掉之后,监听线程会收到通知,但是如果监听线程先死掉,那么系统也就挂了!
2,使用心跳机制,爬行线程每隔一段时间往另一服务器进程发送数据包,如果服务器进程长时间没有收到心跳包,则说明爬行线程已经死机!
两种方法都有合适的使用范围,但是对于监听线程猝死这种情况,个人觉得是使用观察者模式比较合适!现说明一下观察者模式。
观察者模式:定义对象之间的一种一对多的依赖关系,当对象的状态发生改变时,所有依赖于它的对象都得到通知并且被自动更新。
观察者模式在JDK中有现成的实现,java.util.Obserable,如何进行监听线程,请看例子:
package cn.std.test; import java.util.Observable; import cn.std.util.DateUtil; public class RunThread extends Observable implements Runnable{ // 此方法一经调用,立马可以通知观察者,在本例中是监听线程 publicvoid doBusiness(){ if(true){ super.setChanged(); } notifyObservers(); } @Override publicvoid run() { intc = 0; while(true){ //模拟线程运行一段时间之后退出 System.out.println("Runing- "+c+" "+DateUtil.getStdDateTime()); try{ Thread.sleep(2000); }catch (InterruptedException e) { e.printStackTrace(); doBusiness(); break; } c++; //模拟抛出异常 try{ if(c== 4){ Stringstr = null; str.length();//此处将会抛出空指针异常 } }catch (Exception e) { e.printStackTrace(); doBusiness();//在抛出异常时调用,通知观察者,让其重启线程 break;//异常抛出之后,一定要跳出循环,保证将线程送进地狱 } } } publicstatic void main(String[] args) { RunThreadrun = new RunThread(); Listener listen = new Listener(); un.addObserver(listen); newThread(run).start(); //run.doBusiness(); } }
package cn.std.test; import java.util.Observable; import java.util.Observer; public class Listener implements Observer{ @Override publicvoid update(Observable o, Object arg) { System.out.println("RunThread死机"); RunThreadrun = new RunThread(); run.addObserver(this); newThread(run).start(); System.out.println("RunThread重启"); } }
相关推荐
下面小编就为大家带来一篇Java线程监听,意外退出线程后自动重启的实现方法。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
java创建线程监听端口,创建线程处理连接
Java线程池及观察者模式解决多线程意外死亡重启问题,附件含两个要运行代码!
监听器配置,java监听器,登陆监听,Listener,struts监听器配置,用户在线统计 所谓线程(或称线索,thread),指程序中的以单一的顺序控制流。线程按顺序执行,即在一个线程中,一个时刻只能由一个执行点。显然...
Java线程讲解Java线程讲解Java线程讲解Java线程讲解Java线程讲解Java线程讲解Java线程讲解Java线程讲解Java线程讲解Java线程讲解
电子书相关:包含4个有关JAVA线程的电子书(几乎涵盖全部有关线程的书籍) OReilly.Java.Threads.3rd.Edition.Sep.2004.eBook-DDU Java Thread Programming (Sams) java线程第二版中英文 java线程第二版中英文 ...
Java线程Java线程Java线程Java线程Java线程Java线程Java线程Java线程Java线程Java线程Java线程Java线程Java线程Java线程Java线程
Java线程Java线程Java线程Java线程Java线程Java线程
Java线程:概念与原理 Java线程:创建与启动 Java线程:线程栈模型与线程的变量 Java线程:线程状态的转换 Java线程:线程的同步与锁 Java线程:线程的交互 Java线程:线程的调度-休眠 Java线程:线程的调度-优先级 ...
多线程监听代码,不同的线程来监听主线程是否发生变换,如果变换,根据相应的参数调用不同的线程执行相关代码
java 线程java 线程java 线程java 线程java 线程java 线程java 线程java 线程java 线程
Java 线程系列博文总结word化,编目如下,欢迎互相学习交流: Java线程:概念与原理 Java线程:创建与启动 Java线程:线程栈模型与线程的变量 Java线程:线程状态的转换 Java线程:线程的同步与锁 Java线程:...
这个bat脚本资源可以在Windows环境下实现Java程序的守护进程和自动重启。它通过一个循环监控Java程序进程,如果检测到程序异常退出,会自动重启程序。同时具有可配置的重启次数和重启间隔时间。 这个小巧但实用的bat...
Java线程模块Java线程之秒表新手学习Java线程模块时,利用Java中设置线程的暂停间隔,做的简易秒表
java 线程Dump 分析工具: Java的TDA线程转储分析器是一个用于分析Sun Java VM生成的线程转储和堆信息的小型Swing GUI(目前用1.4测试)。它从提供的日志文件中解析线程转储和类直方图。它提供关于发现的线程转储的...
java线程 线程 教程 java线程教程 java线程学习资料 本教程有什么内容? 本教程研究了线程的基础知识— 线程是什么、线程为什么有用以及怎么开始编写使用线程的简单 程序。 我们还将研究更复杂的、使用线程的应用...
java线程同步java线程同步java线程同步
Java线程:概念与原理 2 一、操作系统中线程和进程的概念 2 二、Java中的线程 3 三、Java中关于线程的名词解释 3 四、线程的状态转换和生命周期 4 Java线程:创建与启动 7 Java线程:线程名称的设定及获取 10 Java...
1,保证无毒;2.简单易用 3.创建线程自动侦测掉线程序 4.能自动重启掉线程序
Java的线程和Java AppletJava的线程和Java AppletJava的线程和Java AppletJava的线程和Java AppletJava的线程和Java Applet