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方法,在方法內部重啟線程

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM