快捷導(dǎo)航

Java線程監(jiān)聽,意外退出線程后自動重啟的實(shí)現(xiàn)方法

更新時間：2017年03月04日 08:48:43 投稿：jingxian

下面小編就為大家?guī)硪黄狫ava線程監(jiān)聽,意外退出線程后自動重啟的實(shí)現(xiàn)方法。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧

Java線程監(jiān)聽，意外退出線程后自動重啟

前一天寫了一個微博爬行程序，主要工作原理就是每隔2分鐘爬行一次微博，獲取某N個關(guān)注朋友微博數(shù)量，然后將其保存起來，2分鐘之后再次爬行，再取其微博數(shù)量，與2分鐘前保存的微博數(shù)量比較，如果數(shù)量增加，說明該好友在此2分鐘之內(nèi)發(fā)布微博，如果數(shù)量減少，則是刪除微博。最后將爬行結(jié)果發(fā)送到指定手機(jī)上，作為通知！

今天看微博時發(fā)現(xiàn)自己關(guān)注的朋友發(fā)布了微博，然而自己手機(jī)卻沒有收到報警消息，查看爬行日志發(fā)現(xiàn)，在凌晨6點(diǎn)鐘時，公司網(wǎng)絡(luò)曾經(jīng)斷網(wǎng)，導(dǎo)致網(wǎng)絡(luò)堵塞，程序在爬行的時候拋出網(wǎng)絡(luò)異常UnknownHostException，此時線程就已經(jīng)死掉，猝死。為解決此問題，現(xiàn)有如下需求：線程死掉之后會自動重啟。

常規(guī)解決辦法有2種：

1，開啟另外一個線程，監(jiān)聽爬行線程，使用線程之間的通信，一般是消費(fèi)者模式，如果爬行線程死掉之后，監(jiān)聽線程會收到通知，但是如果監(jiān)聽線程先死掉，那么系統(tǒng)也就掛了！

2，使用心跳機(jī)制，爬行線程每隔一段時間往另一服務(wù)器進(jìn)程發(fā)送數(shù)據(jù)包，如果服務(wù)器進(jìn)程長時間沒有收到心跳包，則說明爬行線程已經(jīng)死機(jī)！

兩種方法都有合適的使用范圍，但是對于監(jiān)聽線程猝死這種情況，個人覺得是使用觀察者模式比較合適！現(xiàn)說明一下觀察者模式。

觀察者模式：定義對象之間的一種一對多的依賴關(guān)系，當(dāng)對象的狀態(tài)發(fā)生改變時，所有依賴于它的對象都得到通知并且被自動更新。

觀察者模式在JDK中有現(xiàn)成的實(shí)現(xiàn)，java.util.Obserable，如何進(jìn)行監(jiān)聽線程，請看例子：

被監(jiān)聽的線程類：

package cn.std.test;

import java.util.Observable;

import cn.std.util.DateUtil;

public class RunThread extends Observableimplements Runnable{

  // 此方法一經(jīng)調(diào)用，立馬可以通知觀察者，在本例中是監(jiān)聽線程

  publicvoid doBusiness(){

    if(true){

      super.setChanged();

    }

    notifyObservers();

  }

  @Override

  publicvoid run() {

    intc = 0;

    while(true){  //模擬線程運(yùn)行一段時間之后退出

      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();//在拋出異常時調(diào)用，通知觀察者，讓其重啟線程

        break;//異常拋出之后，一定要跳出循環(huán)，保證將線程送進(jìn)地獄

      }

    }  

  }

  publicstatic void main(String[] args) {

    RunThreadrun = new RunThread();

    Listener listen = new Listener();

    un.addObserver(listen);

    newThread(run).start();

    //run.doBusiness();

  }

}

被監(jiān)聽的線程需要繼承Observable類，繼承之后輕松變身為被觀察者doBusiness方法，此處可以加上你的業(yè)務(wù)處理內(nèi)容，接下來是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死機(jī)");

    RunThreadrun = new RunThread();

    run.addObserver(this);

    newThread(run).start();

    System.out.println("RunThread重啟");

  }

}

很簡單，只要實(shí)現(xiàn)Observer接口，實(shí)現(xiàn)其update方法，在方法內(nèi)部重啟線程

以上這篇Java線程監(jiān)聽,意外退出線程后自動重啟的實(shí)現(xiàn)方法就是小編分享給大家的全部內(nèi)容了，希望能給大家一個參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: