前一天寫了一個微博爬行程序，主要工作原理就是每隔2分鐘爬行一次微博，獲取某N個關注朋友微博數量，然后將其保存起來，2分鐘之后再次爬行，再取 其微博數量，與2分鐘前保存的微博數量比較，如果數量增加，說明該好友在此2分鐘之內發布微博，如果數量減少，則是刪除微博。最后將爬行結果發送到指定手機上，作為通知！
今天看微博時發現自己關注的朋友發布了微博，然而自己手機卻沒有收到報警消息，查看爬行日志發現，在凌晨6點鐘時，公司網絡曾經斷網，導致網絡堵 塞，程序在爬行的時候拋出網絡異常UnknownHostException，此時線程就已經死掉，猝死。為解決此問題，現有如下需求：線程死掉之后會自動重啟。
常規解決辦法有2種：
1，開啟另外一個線程，監聽爬行線程，使用線程之間的通信，一般是消費者模式，如果爬行線程死掉之后，監聽線程會收到通知，但是如果監聽線程先死掉，那么系統也就掛了！
2，使用心跳機制，爬行線程每隔一段時間往另一服務器進程發送數據包，如果服務器進程長時間沒有收到心跳包，則說明爬行線程已經死機！
兩種方法都有合適的使用范圍，但是對于監聽線程猝死這種情況，個人覺得是使用觀察者模式比較合適！現說明一下觀察者模式。
觀察者模式：定義對象之間的一種一對多的依賴關系，當對象的狀態發生改變時，所有依賴于它的對象都得到通知并且被自動更新。
觀察者模式在JDK中有現成的實現，java.util.Obserable，如何進行監聽線程，請看例子：
被監聽的線程類：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
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
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
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方法，在方法內部重啟線程
以上這篇Java線程監聽,意外退出線程后自動重啟的實現方法就是小編分享給大家的全部內容了，希望能給大家一個參考，也希望大家多多支持服務器之家。
