监听线程死机，猝死 --使用观察者模式

某日，天朗气清，回公司，未到9点，刷微博，顿觉问题泛滥，惊恐万分！

前一天写了一个微博爬行程序，主要工作原理就是每隔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 Observable implements Runnable{
	
        // 此方法一经调用，立马可以通知观察者，在本例中是监听线程
	public void doBusiness(){
		if(true){
			super.setChanged();
		}
		notifyObservers();
	}
	
	@Override
	public void run() {
		int c = 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){
					String str = null;
					str.length();//此处将会抛出空指针异常
				}
			} catch (Exception e) {
				e.printStackTrace();
				doBusiness();//在抛出异常时调用，通知观察者，让其重启线程
				break;//异常抛出之后，一定要跳出循环，保证将线程送进地狱
			}
		}    
	}

	public static void main(String[] args) {
		RunThread run = new RunThread();
               
        Listener listen = new Listener();
		run.addObserver(listen);
		new Thread(run).start();
		//run.doBusiness();
	}
}

 被监听的线程需要继承Observable类，继承之后轻松变身为被观察者doBusiness方法，此处可以加上你的业务处理内容，接下来是Listener

package cn.std.test;

import java.util.Observable;
import java.util.Observer;

public class Listener implements Observer{

	@Override
	public void update(Observable o, Object arg) {
		System.out.println("RunThread 死机");
		RunThread run = new RunThread();
		run.addObserver(this);
		new Thread(run).start();
		System.out.println("RunThread 重启");
	}
}

 很简单，只要实现Observer接口，实现其update方法，在方法内部重启线程

 

评论

2 楼 sziitjiang 2012-10-23  

87869170 写道

感觉很神奇，不知道有这样的做法。
做java 3年的飘过...

呵呵，您是前辈，还请多指点，呵呵..

1 楼 87869170 2012-10-23  

感觉很神奇，不知道有这样的做法。
做java 3年的飘过...