Java线程监听线程监听,意外退出线程后自动重启的实现方法意外退出线程后自动重启的实现方法
下面小编就为大家带来一篇Java线程监听,意外退出线程后自动重启的实现方法。小编觉得挺不错的，现在就分
享给大家，也给大家做个参考。一起跟随小编过来看看吧
Java线程监听，意外退出线程后自动重启
前一天写了一个微博爬行程序，主要工作原理就是每隔2分钟爬行一次微博，获取某N个关注朋友微博数量，然后将其保存起
来，2分钟之后再次爬行，再取 其微博数量，与2分钟前保存的微博数量比较，如果数量增加，说明该好友在此2分钟之内发布
微博，如果数量减少，则是删除微博。最后将爬行结果发送到指定手机上，作为通知！
今天看微博时发现自己关注的朋友发布了微博，然而自己手机却没有收到报警消息，查看爬行日志发现，在凌晨6点钟时，公
司网络曾经断网，导致网络堵 塞，程序在爬行的时候抛出网络异常UnknownHostException，此时线程就已经死掉，猝死。为
解决此问题，现有如下需求：线程死掉之后会自动重启。
常规解决办法有常规解决办法有2种：种：
1，开启另外一个线程，监听爬行线程，使用线程之间的通信，一般是消费者模式，如果爬行线程死掉之后，监听线程会收到
通知，但是如果监听线程先死掉，那么系统也就挂了！
2，使用心跳机制，爬行线程每隔一段时间往另一服务器进程发送数据包，如果服务器进程长时间没有收到心跳包，则说明爬
行线程已经死机！
两种方法都有合适的使用范围，但是对于监听线程猝死这种情况，个人觉得是使用观察者模式比较合适！现说明一下观察者模
式。
观察者模式：定义对象之间的一种一对多的依赖关系，当对象的状态发生改变时，所有依赖于它的对象都得到通知并且被自动
更新。
观察者模式在JDK中有现成的实现，java.util.Obserable，如何进行监听线程，请看例子：
被监听的线程类：被监听的线程类：
package cn.std.test;
import java.util.Observable;
import cn.std.util.DateUtil;
public class RunThread extends Observableimplements 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();
评论0