Java線程監聽，意外退出線程後自動重啓

 

Java線程監聽，意外退出線程後自動重啓

　　某日，天朗氣清，回公司，未到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 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();

                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();

    }

}

 

　　被監聽的線程須要繼承Observable類，繼承以後輕鬆變身爲被觀察者doBusiness方法，此處能夠加上你的業務處理內容，接下來是Listener

 

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重啓");

    }

}

 

很簡單，只要實現Observer接口，實現其update方法，在方法內部重啓線程