Java 线程监听,意外退出线程后自动重启
某日,天朗气清,回公司,未到 9 点,刷微博,顿觉问题泛滥,惊恐万分!
前一天写了一个微博爬行程序,主要工作原理就是每隔 2 分钟爬行一次微博,获取某 N 个关注朋友微博数量,然后将其保存起来,2 分钟之后再次爬行,再取 其微博数量,与 2 分钟前保存的微博数量比较,如果数量增加,说明该好友在此 2 分钟之内发布微博,如果数量减少,则是删除微博。最后将爬行结果发送到指定手机上,作为通知!
今天看微博时发现自己关注的朋友发布了微博,然而自己手机却没有收到报警消息,查看爬行日志发现,在凌晨 6 点钟时,公司网络曾经断网,导致网络堵 塞,程序在爬行的时候抛出网络异常 UnknownHostException,此时线程就已经死掉,猝死。为解决此问题,现有如下需求:线程死掉之后会自动重启。
常规解决办法有 2 种:
1,开启另外一个线程,监听爬行线程,使用线程之间的通信,一般是消费者模式,如果爬行线程死掉之后,监听线程会收到通知,但是如果监听线程先死掉,那么系统也就挂了!
2,使用心跳机制,爬行线程每隔一段时间往另一服务器进程发送数据包,如果服务器进程长时间没有收到心跳包,则说明爬行线程已经死机!
两种方法都有合适的使用范围,但是对于监听线程猝死这种情况,个人觉得是使用观察者模式比较合适!现说明一下观察者模式。
观察者模式:定义对象之间的一种一对多的依赖关系,当对象的状态发生改变时,所有依赖于它的对象都得到通知并且被自动更新。
观察者模式在 JDK 中有现成的实现,java.util.Obserable,如何进行监听线程,请看例子:
被监听的线程类:
很简单,只要实现 Observer 接口,实现其 update 方法,在方法内部重启线程
欢迎来到这里!
我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。
注册 关于