您好,登錄后才能下訂單哦!
Java線程監(jiān)聽(tīng),意外退出線程后自動(dòng)重啟
前一天寫(xiě)了一個(gè)微博爬行程序,主要工作原理就是每隔2分鐘爬行一次微博,獲取某N個(gè)關(guān)注朋友微博數(shù)量,然后將其保存起來(lái),2分鐘之后再次爬行,再取 其微博數(shù)量,與2分鐘前保存的微博數(shù)量比較,如果數(shù)量增加,說(shuō)明該好友在此2分鐘之內(nèi)發(fā)布微博,如果數(shù)量減少,則是刪除微博。最后將爬行結(jié)果發(fā)送到指定手機(jī)上,作為通知!
今天看微博時(shí)發(fā)現(xiàn)自己關(guān)注的朋友發(fā)布了微博,然而自己手機(jī)卻沒(méi)有收到報(bào)警消息,查看爬行日志發(fā)現(xiàn),在凌晨6點(diǎn)鐘時(shí),公司網(wǎng)絡(luò)曾經(jīng)斷網(wǎng),導(dǎo)致網(wǎng)絡(luò)堵 塞,程序在爬行的時(shí)候拋出網(wǎng)絡(luò)異常UnknownHostException,此時(shí)線程就已經(jīng)死掉,猝死。為解決此問(wèn)題,現(xiàn)有如下需求:線程死掉之后會(huì)自動(dòng)重啟。
常規(guī)解決辦法有2種:
1,開(kāi)啟另外一個(gè)線程,監(jiān)聽(tīng)爬行線程,使用線程之間的通信,一般是消費(fèi)者模式,如果爬行線程死掉之后,監(jiān)聽(tīng)線程會(huì)收到通知,但是如果監(jiān)聽(tīng)線程先死掉,那么系統(tǒng)也就掛了!
2,使用心跳機(jī)制,爬行線程每隔一段時(shí)間往另一服務(wù)器進(jìn)程發(fā)送數(shù)據(jù)包,如果服務(wù)器進(jìn)程長(zhǎng)時(shí)間沒(méi)有收到心跳包,則說(shuō)明爬行線程已經(jīng)死機(jī)!
兩種方法都有合適的使用范圍,但是對(duì)于監(jiān)聽(tīng)線程猝死這種情況,個(gè)人覺(jué)得是使用觀察者模式比較合適!現(xiàn)說(shuō)明一下觀察者模式。
觀察者模式:定義對(duì)象之間的一種一對(duì)多的依賴(lài)關(guān)系,當(dāng)對(duì)象的狀態(tài)發(fā)生改變時(shí),所有依賴(lài)于它的對(duì)象都得到通知并且被自動(dòng)更新。
觀察者模式在JDK中有現(xiàn)成的實(shí)現(xiàn),java.util.Obserable,如何進(jìn)行監(jiān)聽(tīng)線程,請(qǐng)看例子:
被監(jiān)聽(tīng)的線程類(lèi):
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)聽(tīng)線程 publicvoid doBusiness(){ if(true){ super.setChanged(); } notifyObservers(); } @Override publicvoid run() { intc = 0; while(true){ //模擬線程運(yùn)行一段時(shí)間之后退出 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();//此處將會(huì)拋出空指針異常 } }catch (Exception e) { e.printStackTrace(); doBusiness();//在拋出異常時(shí)調(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)聽(tīng)的線程需要繼承Observable類(lèi),繼承之后輕松變身為被觀察者doBusiness方法,此處可以加上你的業(yè)務(wù)處理內(nèi)容,接下來(lá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重啟"); } }
很簡(jiǎn)單,只要實(shí)現(xiàn)Observer接口,實(shí)現(xiàn)其update方法,在方法內(nèi)部重啟線程
以上這篇Java線程監(jiān)聽(tīng),意外退出線程后自動(dòng)重啟的實(shí)現(xiàn)方法就是小編分享給大家的全部?jī)?nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持億速云。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。