Java 线程监听,意外退出线程后自动重启

本贴最后更新于 2414 天前,其中的信息可能已经斗转星移

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 Observable implements 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死机"); RunThread run = new RunThread(); run.addObserver(this); newThread(run).start(); System.out.println("RunThread重启"); } }

很简单,只要实现 Observer 接口,实现其 update 方法,在方法内部重启线程

  • Java

    Java 是一种可以撰写跨平台应用软件的面向对象的程序设计语言,是由 Sun Microsystems 公司于 1995 年 5 月推出的。Java 技术具有卓越的通用性、高效性、平台移植性和安全性。

    3203 引用 • 8217 回帖 • 2 关注

相关帖子

欢迎来到这里!

我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。

注册 关于
请输入回帖内容 ...
  • 你把问题想得有点复杂了。。。

    只需要在一个方法里面,循环调用你想要的那个采集方法就可以 🙏

推荐标签 标签

  • Windows

    Microsoft Windows 是美国微软公司研发的一套操作系统,它问世于 1985 年,起初仅仅是 Microsoft-DOS 模拟环境,后续的系统版本由于微软不断的更新升级,不但易用,也慢慢的成为家家户户人们最喜爱的操作系统。

    229 引用 • 476 回帖 • 1 关注
  • Hibernate

    Hibernate 是一个开放源代码的对象关系映射框架,它对 JDBC 进行了非常轻量级的对象封装,使得 Java 程序员可以随心所欲的使用对象编程思维来操纵数据库。

    39 引用 • 103 回帖 • 726 关注
  • Sym

    Sym 是一款用 Java 实现的现代化社区(论坛/BBS/社交网络/博客)系统平台。

    下一代的社区系统,为未来而构建

    524 引用 • 4601 回帖 • 710 关注
  • OAuth

    OAuth 协议为用户资源的授权提供了一个安全的、开放而又简易的标准。与以往的授权方式不同之处是 oAuth 的授权不会使第三方触及到用户的帐号信息(如用户名与密码),即第三方无需使用用户的用户名与密码就可以申请获得该用户资源的授权,因此 oAuth 是安全的。oAuth 是 Open Authorization 的简写。

    36 引用 • 103 回帖 • 34 关注
  • Node.js

    Node.js 是一个基于 Chrome JavaScript 运行时建立的平台, 用于方便地搭建响应速度快、易于扩展的网络应用。Node.js 使用事件驱动, 非阻塞 I/O 模型而得以轻量和高效。

    139 引用 • 269 回帖 • 1 关注
  • 酷鸟浏览器

    安全 · 稳定 · 快速
    为跨境从业人员提供专业的跨境浏览器

    3 引用 • 59 回帖 • 52 关注
  • Thymeleaf

    Thymeleaf 是一款用于渲染 XML/XHTML/HTML5 内容的模板引擎。类似 Velocity、 FreeMarker 等,它也可以轻易的与 Spring 等 Web 框架进行集成作为 Web 应用的模板引擎。与其它模板引擎相比,Thymeleaf 最大的特点是能够直接在浏览器中打开并正确显示模板页面,而不需要启动整个 Web 应用。

    11 引用 • 19 回帖 • 397 关注
  • Facebook

    Facebook 是一个联系朋友的社交工具。大家可以通过它和朋友、同事、同学以及周围的人保持互动交流,分享无限上传的图片,发布链接和视频,更可以增进对朋友的了解。

    4 引用 • 15 回帖 • 438 关注
  • Lute

    Lute 是一款结构化的 Markdown 引擎,支持 Go 和 JavaScript。

    29 引用 • 202 回帖 • 32 关注
  • RYMCU

    RYMCU 致力于打造一个即严谨又活泼、专业又不失有趣,为数百万人服务的开源嵌入式知识学习交流平台。

    4 引用 • 6 回帖 • 62 关注
  • MyBatis

    MyBatis 本是 Apache 软件基金会 的一个开源项目 iBatis,2010 年这个项目由 Apache 软件基金会迁移到了 google code,并且改名为 MyBatis ,2013 年 11 月再次迁移到了 GitHub。

    173 引用 • 414 回帖 • 357 关注
  • Laravel

    Laravel 是一套简洁、优雅的 PHP Web 开发框架。它采用 MVC 设计,是一款崇尚开发效率的全栈框架。

    19 引用 • 23 回帖 • 743 关注
  • Webswing

    Webswing 是一个能将任何 Swing 应用通过纯 HTML5 运行在浏览器中的 Web 服务器,详细介绍请看 将 Java Swing 应用变成 Web 应用

    1 引用 • 15 回帖 • 644 关注
  • SendCloud

    SendCloud 由搜狐武汉研发中心孵化的项目,是致力于为开发者提供高质量的触发邮件服务的云端邮件发送平台,为开发者提供便利的 API 接口来调用服务,让邮件准确迅速到达用户收件箱并获得强大的追踪数据。

    2 引用 • 8 回帖 • 509 关注
  • MySQL

    MySQL 是一个关系型数据库管理系统,由瑞典 MySQL AB 公司开发,目前属于 Oracle 公司。MySQL 是最流行的关系型数据库管理系统之一。

    694 引用 • 537 回帖
  • 知乎

    知乎是网络问答社区,连接各行各业的用户。用户分享着彼此的知识、经验和见解,为中文互联网源源不断地提供多种多样的信息。

    10 引用 • 66 回帖
  • 钉钉

    钉钉,专为中国企业打造的免费沟通协同多端平台, 阿里巴巴出品。

    15 引用 • 67 回帖 • 261 关注
  • Log4j

    Log4j 是 Apache 开源的一款使用广泛的 Java 日志组件。

    20 引用 • 18 回帖 • 39 关注
  • NGINX

    NGINX 是一个高性能的 HTTP 和反向代理服务器,也是一个 IMAP/POP3/SMTP 代理服务器。 NGINX 是由 Igor Sysoev 为俄罗斯访问量第二的 Rambler.ru 站点开发的,第一个公开版本 0.1.0 发布于 2004 年 10 月 4 日。

    315 引用 • 547 回帖 • 2 关注
  • 快应用

    快应用 是基于手机硬件平台的新型应用形态;标准是由主流手机厂商组成的快应用联盟联合制定;快应用标准的诞生将在研发接口、能力接入、开发者服务等层面建设标准平台;以平台化的生态模式对个人开发者和企业开发者全品类开放。

    15 引用 • 127 回帖 • 1 关注
  • 创造

    你创造的作品可能会帮助到很多人,如果是开源项目的话就更赞了!

    187 引用 • 1021 回帖
  • Kotlin

    Kotlin 是一种在 Java 虚拟机上运行的静态类型编程语言,由 JetBrains 设计开发并开源。Kotlin 可以编译成 Java 字节码,也可以编译成 JavaScript,方便在没有 JVM 的设备上运行。在 Google I/O 2017 中,Google 宣布 Kotlin 成为 Android 官方开发语言。

    19 引用 • 33 回帖 • 89 关注
  • WebClipper

    Web Clipper 是一款浏览器剪藏扩展,它可以帮助你把网页内容剪藏到本地。

    3 引用 • 9 回帖
  • 开源

    Open Source, Open Mind, Open Sight, Open Future!

    415 引用 • 3599 回帖
  • Solidity

    Solidity 是一种智能合约高级语言,运行在 [以太坊] 虚拟机(EVM)之上。它的语法接近于 JavaScript,是一种面向对象的语言。

    3 引用 • 18 回帖 • 446 关注
  • HTML

    HTML5 是 HTML 下一个的主要修订版本,现在仍处于发展阶段。广义论及 HTML5 时,实际指的是包括 HTML、CSS 和 JavaScript 在内的一套技术组合。

    108 引用 • 295 回帖
  • 脑图

    脑图又叫思维导图,是表达发散性思维的有效图形思维工具 ,它简单却又很有效,是一种实用性的思维工具。

    32 引用 • 100 回帖